安裝模塊
pip install pymysql
pip install sqlalchemy
import pymysql
from sqlalchemy import create_engine
建立連接(不推薦使用pymysql 占用內存)
conn=pymysql.connect(host='localhost',user='root',password='123',database='my_work',charset='utf8')
使用sqlalchemy建立連接
db_info = {
'host':'localhost',
'user':'root',
'password':'123',
'database':'my_work',
'charset':'utf8'
}
conn_2 = create_engine( 'mysql+pymysql://%(user)s:%(password)s@%(host)s/%(database)s?charset=utf8' % db_info,
encoding='utf-8')
輸入並執行sql語句
sql = 'sql語句'
table = pd.read_sql(sql,conn)
table
保存到mysql
processed_data_table.to_sql('after_processed', conn, index=False, if_exists='append')
參數依次是 存儲在數據庫中的表名稱,conn,不保存第一列 索引列,如果數據庫中有同名表 將數據追加到表后面