如何使用pyodbc单独提交多个查询

Question

我试图使用pyodbc将数据插入到AZURE表中。这里我使用了三个SQL查询，当我试图将数据插入到表中时，只有最后一个sql语句正在插入。

def dbQuery_Multiple_Row(sql,li):
  global cursor, conn
  cursor, conn =db_connection_dev01()
  try:
    cursor.execute(sql)
  except Exception as e:
    li.append("Error-"+str(e))
sql1 = "insert into stars.sampledata values ('Suneel Kummar I', 2, 'Sullurepeta')"
sql2 = "insert into stars.sampledata values ('Suneel Kummar Il', 3, 'Sullurepeta')"
sql3 = "insert into stars.sampledata values ('Suneel Kummar Ill', 4, 'Sullurepeta')"

import pyodbc
sql = [sql1, sql2, sql3]
li = []
dbQuery_Multiple_Row(sql1, li)
dbQuery_Multiple_Row(sql2, li)
dbQuery_Multiple_Row(sql3, li)
conn.commit()
conn.close()

我的任务是为所有sql查询提交一次，但提交只对最后一次SQL查询进行。请帮帮我。提前谢谢。

Answer 1

您的问题是db_connection_dev01，它打开了一个新的连接。

因此，每次对dbQuery_Multiple_Row的调用都会打开一个连接，但提交只在最后一个调用中执行。

它解释了为什么只看到第三个查询的结果。要解决这个问题，您需要使用相同的连接。

修复的一种方法是在dbQuery_Multiple_Row之前打开它并将其作为参数传递