使用python,导入了2个数据库包,然后初始化参数:
from sqlalchemy import create_engine
import pymysql
engine=create_engine('mysql+pymysql://root:123456@127.0.0.1:3306/myfinance') #连接本机数据库
db=pymysql.Connect(host='127.0.0.1',user='root',passwd='123456',db='myfinance')#连接本机数据库
首先利用dataframe的to_sql方法、sqlalchemy的ingine,将最新日期的增量导入mysql
df_week.to_sql("all_stock_weekly",engine,if_exists='append', index=False)
然后没有其他操作,
df_now = pd.read_sql(sql,db)#sql的内容是查询最新日期的数据,可结果得到的是上个语句写入增量前的旧数据。
请教:
在oralce中,利用commit确保数据的一致性。可mysql确保一致性的原理是什么?我的这个问题应当如何解决?谢谢!