oldbee0925 2022-05-24 08:08 采纳率: 91.4%
浏览 38
已结题

dataframe与mysql的交互,我的mysql为何查询不到最新数据?

使用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确保一致性的原理是什么?我的这个问题应当如何解决?谢谢!

  • 写回答

1条回答 默认 最新

  • 於黾 2022-05-24 09:02
    关注

    mysql也有commit啊
    你不执行commit,那写入的都是脏数据

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

问题事件

  • 系统已结题 6月7日
  • 已采纳回答 5月30日
  • 创建了问题 5月24日