python cursor.execute能一次接受多个查询吗



下面的cursor.execute调用能一次执行多个SQL查询吗?

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

我还没有python的设置,但想知道cursor.execute是否支持上面的表单?

import pyodbc 
# Some other example server values are
# server = 'localhostsqlexpress' # 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()

是的,这是可能的。

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() + ';')

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

pyodbc(或pypyodbc(中没有任何内容可以阻止您将包含匿名代码块的字符串传递给Cursor.execute()方法。他们只需将字符串传递给ODBC驱动程序管理器(DM(,后者再将字符串传递到ODBC驱动程序。

但是,并非所有ODBC驱动程序都默认接受匿名代码块。有些数据库默认为每个.execute()只允许一条SQL语句,以保护我们免受SQL注入问题的影响。

例如,MySQL/Connector ODBC将MULTI_STATEMENTS默认为0(关闭(,因此如果要运行匿名代码块,则必须在连接字符串中包含MULTI_STATEMENTS=1

还要注意,通过在匿名代码块中包含USE …语句来更改当前数据库有时会导致问题,因为数据库上下文会在事务过程中发生更改。通常最好是自己执行USE …语句,然后继续执行其他SQL语句。

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))

从这个例子和代码中,我想说您的下一步是测试一个多游标.execure(<your_sql_Querie>(。

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

这将是开发人员复制文档工作的基本演变。。。希望这能帮助你:(

是的,您可以通过使用nextset((方法得到多个查询的结果。。。

query = "select * from Table1; select * from Table2"
cursor = connection.cursor()
cursor.execute(query)
table1 = cursor.fetchall()
cursor.nextset()
table2 = cursor.fetchall()

代码解释了它…游标返回结果";集合";,您可以使用nextset((方法在其中移动。

相关内容

  • 没有找到相关文章

最新更新