主要使用python中集成的SQLAlchemy
、PyMySQL
的两个库来向数据库中新增行记录。SQLAlchemy
为Python提供了不同数据库的统一接口,可用于连接大多数常见的数据库,比如Postges、MySQL、SQLite、Oracle等。PyMySQL
是在 Python3.x 版本中用于连接 MySQL 服务器的一个库。
1.向表中新增记录
import pandas as pd
from sqlalchemy import create_engine
import pymysql
engine=create_engine(r"mysql+pymysql://root:[email protected]:3301/database_name")#root:[email protected]:3301/database_name 用户名:密码@ip地址:端口号/表名称
data_sale.to_sql('table_name_1',engine,if_exists='append',index= False)#向table_name_1表中新增data_sale记录,非覆盖新增
data_order.to_sql('table_name_2',engine,if_exists='append',index= False)#向table_name_2表中新增data_order记录,非覆盖新增
2.执行查询语句
sql='''
select * from table_name_1
'''
df = pd.read_sql_query(sql, engine)#执行查询语句并将查询结果赋值给df