一、导入库函数

import pymysql

import pandas as pd

from sqlalchemy import create_engine

   

二、建立连接

建立连接的格式如下：coon=create_engine('mysql+pymysql://user:password@IP:3306/databasename')

#建立连接

conn = create_engine('mysql+pymysql://root:669988@10.19.XXXXX:3306/test') #

#查询语句代码sql

sql='select * from EMPLOYEE'

   

三、读取数据

这里使用pandas的pd.read_sql读取数据，存储为数据框DataFrame

df1 = pd.read_sql(sql,conn)

   

四、函数效果

只要需要读取数据的时候就直接使用函数query直接读取就可以了

def query(table):#定义一个函数用来专门从数据库中读取数据

host = '10.19.XXXXX'

user = 'root'

password = '669988'

database = 'test'

port = 3306

conn = create_engine(f'mysql+pymysql://{user}:{password}@{host}:{port}/{database}'))

sql = 'select * from '+str(table)

results = pd.read_sql(sql,conn)

return results

df2 = query("EMPLOYEE")

   

五、写回数据库

#把数据保存到数据库中

df2.to_sql('dfdb',con=conn,index=False)

   

六、整体代码和结果展示

navicat的效果：