下面的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语句。
应该会为您提供您要查找的示例。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((方法在其中移动。