用python在后端将数据写入到数据库:
# coding:utf-8import pandas as pdfrom sqlalchemy import create_engine# 初始化数据库连接,使用pymysql模块# MySQL的用户:root, 密码:147369, 端口:3306,数据库:mydbengine = create_engine(‘mysql+pymysql://root:123456@localhost:3306/python1‘)import numpy as npimport datetimestart = datetime.datetime.now().strftime(‘%Y-%m-%d‘)end = (datetime.datetime.now()+datetime.timedelta(days=100)).strftime(‘%Y-%m-%d‘)# 新建pandas中的DataFrame, 只有id,num两列df = pd.DataFrame(data=np.random.randint(-100,100,(100,100)),index=pd.date_range(‘2018-1-1‘,periods=100,dtype=‘datetime64[ns]‘, freq=‘D‘),columns=None,dtype=int)print(df.shape)# 将新建的DataFrame储存为MySQL中的数据表,不储存index列df.to_sql(‘data‘, engine, if_exists=‘append‘,index= True)
读取:
# -*- coding: utf-8 -*-# 导入必要模块import pandas as pdfrom sqlalchemy import create_engine# 初始化数据库连接,使用pymysql模块# MySQL的用户:root, 密码:147369, 端口:3306,数据库:mydbengine = create_engine(‘mysql+pymysql://root:123456@localhost:3306/python1‘)# 查询语句,选出employee表中的所有数据sql = ‘‘‘ select * from student; ‘‘‘# read_sql_query的两个参数: sql语句, 数据库连接df = pd.read_sql_query(sql, engine)# 输出employee表的查询结果print(df.shape)