安装依赖包
pip install pymysql
pip install sqlalchemy
构造数据并写入MySQL
import numpy as np
import pandas as pd
from sqlalchemy import create_engine
connect = create_engine('mysql+pymysql://root:123456@localhost:3306/model?charset=utf8')
for i in range(2):
df = pd.DataFrame(np.random.randn(50000,6),columns=list('abcdef'))
df.to_sql('bit_data_test', connect, index=False,if_exists='append')
读取MySQL表
sql = ''' select * from bit_data_test; '''
df = pd.read_sql_query(sql, engine)
print(df)
网友评论