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

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日

    悬赏问题

    • ¥15 深海控制器DSE7320MKII和博世ECU间can通讯知识
    • ¥15 Ru的复折射率用于FDTD 200nm到1200nm
    • ¥15 使用Fiddler抓包,textview的乱码如何解决
    • ¥50 trio连接驱动器报错
    • ¥15 有谁懂nhanes的权重计算啊
    • ¥15 欧姆龙PLC 电机控制 限位
    • ¥30 如何处理shell命令接收到的视频流并实时播放出来
    • ¥15 虚心请教C#的代码优化问题
    • ¥15 有偿求做台风过境全过程模拟仿真
    • ¥50 求!AutomationDesk 如何自动导入Variant数据