python的cursor.execute可以一次性接受多个查询吗？

Question

下面的cursor.execute调用可以一次性执行多个SQL查询吗？

cursor.execute("use testdb;CREATE USER MyLogin")

我还没有安装Python，但想知道cursor.execute是否支持上述形式？

import pyodbc 
# Some other example server values are
# server = 'localhost\sqlexpress' # for a named instance
# server = 'myserver,port' # to specify an alternate port
server = 'tcp:myserver.database.windows.net' 
database = 'mydb' 
username = 'myusername' 
password = 'mypassword' 
cnxn = pyodbc.connect('DRIVER={ODBC Driver 17 for SQL Server};SERVER='+server+';DATABASE='+database+';UID='+username+';PWD='+ password)
cursor = cnxn.cursor()
#Sample select query
cursor.execute("SELECT @@version;") 
row = cursor.fetchone() 
while row: 
    print(row[0])
    row = cursor.fetchone()

Answer 1

是的，这是可能的。

operation = 'SELECT 1; INSERT INTO t1 VALUES (); SELECT 2'
for result in cursor.execute(operation, multi=True):

但这并不是一个全面的解决方案。例如，在有两个选择的查询中，您会遇到问题。

考虑到两种类型的答案必须全部提取到光标中！

所以最好的解决方案是将查询分解为子查询并逐步完成工作。 例如：

s = "USE some_db; SELECT * FROM some_table;"
s = filter(None, s.split(';'))

for i in s:
    cur.execute(i.strip() + ';')

Answer 2

单个字符串中的多个 SQL 语句通常称为“匿名代码块”。

pyodbc（或 pypyodbc）中没有任何内容可以阻止您将包含匿名代码块的字符串传递给

Cursor.execute()

方法。他们只是将字符串传递给 ODBC 驱动程序管理器 (DM)，后者又将其传递给 ODBC 驱动程序。

但是，并非所有 ODBC 驱动程序默认都接受匿名代码块。有些数据库默认只允许每个

.execute()

使用一条 SQL 语句，以保护我们免受 SQL 注入问题。

例如，MySQL/Connector ODBC 默认

MULTI_STATEMENTS

为

0

（关闭），因此如果您想运行匿名代码块，则必须在连接字符串中包含

MULTI_STATEMENTS=1

。

另请注意，通过在匿名代码块中包含

USE …

语句来更改当前数据库有时会导致问题，因为数据库上下文在事务中间发生变化。通常最好单独执行一条

USE …

语句，然后继续执行其他 SQL 语句。

Answer 3

在 pyodbc 文档中应该为您提供您正在寻找的示例。更多信息请参见 GitHub wiki：https://github.com/mkleehammer/pyodbc/wiki/Objects#cursors

您可以在这里查看示例：

cnxn   = pyodbc.connect(...)
cursor = cnxn.cursor()

cursor.execute("""
               select user_id, last_logon
                 from users
                where last_logon > ?
                  and user_type <> 'admin'
               """, twoweeks)

rows = cursor.fetchall()

for row in rows:
    print('user %s logged on at %s' % (row.user_id, row.last_logon))

通过这个示例并探索代码，我想说你的下一步是测试多光标.execute(“”)。

如果此测试有效，也许可以尝试创建一个类，然后为要运行的每个查询创建该类的实例。

这将是开发人员复制文档的努力的基本演变...希望这对您有帮助:)

Answer 4

是的，您可以使用 nextset() 方法获得多个查询的结果...

query = "select * from Table1; select * from Table2"
cursor = connection.cursor()
cursor.execute(query)

table1 = cursor.fetchall()

cursor.nextset()

table2 = cursor.fetchall()

代码解释了这一点...游标返回结果“集合”，您可以使用 nextset() 方法在它们之间移动。

Answer 5

很奇怪，我在一个exec函数中执行了两个查询，并且这个SQL查询是用';'分隔的，并且我确实使用通用日志收到了两个日志，但是第二个SQL没有执行，这是什么问题？

    product_query = request.args.get('prodLine')
    db_connection = get_connection()



    product_desc = db_query(db_connection,"SELECT * FROM products WHERE productLine='" + product_query + "'" )
    db_connection.close()

     return render_template('pages.html',product_desc=product_desc)