使用Python和Sqlalchemy将查询结果插入Singlestore表

Question

我用f字符串参数化了查询，这样查询将从一系列表和联接中选择一些数据，我想将结果数据集插入另一个预先创建的表中(表的设计目的是容纳这些结果(。

Python执行代码，但查询结果从未显示在我的表中。

假设target_table已经在singlestore数据库中创建：

qry_load = 'insert into target_table select * from some_tables'
conn = engine.connect()
trans = conn.begin()
try:
conn.execute(qry_load)
trans.commit()
except:
trans.rollback()
raise

代码执行并表现得好像一切正常，但数据永远不会显示在目标表中。

如何查看singlestore正在传递的信息，以便更好地调试数据库中发生的事情？

Answer 1

只需将begin()替换为cursor()函数：

conn = engine.connect()
trans = conn.cursor()

如果未解决

1-验证源表和目标表的结构是否相同。

2-删除try ,except and rollback()块，这样您就可以知道实际错误。

Ex。

qry_load = 'insert into target_table select * from some_tables'
conn = engine.connect()
trans = conn.cursor()
conn.execute(qry_load)
trans.commit()