使用MySQLdb执行多个SQL查询

Question

如何使用python执行几个SQL语句（脚本模式）？

试图做这样的事情：

ProgrammingError: (2014, "Commands out of sync; you can't run this command now")

我正在写将接受从几个人的SQL增量更改，并将它们应用到数据库的部署引擎：

import MySQLdb 
mysql = MySQLdb.connect(host='host...rds.amazonaws.com', db='dbName', user='userName', passwd='password') 
sql = """ 
insert into rollout.version (`key`, `value`) VALUES ('maxim0', 'was here0'); 
insert into rollout.version (`key`, `value`) VALUES ('maxim1', 'was here1'); 
insert into rollout.version (`key`, `value`) VALUES ('maxim2', 'was here1'); 
""" 
mysql.query(sql) 

与失败在版本部署上。

我看着这个代码http://sujitpal.blogspot.com/2009/02/python-sql-runner.html和实施__sanitize_sql：

def __sanitize_sql(sql): 
    # Initial implementation from http://sujitpal.blogspot.com/2009/02/python-sql-runner.html 
    sql_statements = [] 

    incomment = False 
    in_sqlcollect = False 

    sql_statement = None 
    for sline in sql.splitlines(): 
     # Remove white space from both sides. 
     sline = sline.strip() 

     if sline.startswith("--") or len(sline) == 0: 
      # SQL Comment line, skip 
      continue 

     if sline.startswith("/*"): 
      # start of SQL comment block 
      incomment = True 
     if incomment and sline.endswith("*/"): 
      # end of SQL comment block 
      incomment = False 
      continue 

     # Collect line which is part of 
     if not incomment: 
      if sql_statement is None: 
       sql_statement = sline 
      else: 
       sql_statement += sline 

      if not sline.endswith(";"): 
       in_sqlcollect = True 

      if not in_sqlcollect: 
       sql_statements.append(sql_statement) 
       sql_statement = None 
       in_sqlcollect = False 

    if not incomment and not sql_statement is None and len(sql_statement) != 0: 
     sql_statements.append(sql_statement) 

    return sql_statements 

if __name__ == "__main__": 
    sql = sql = """update tbl1; 
/* This 
is my 
beautiful 
comment*/ 
/*this is comment #2*/ 
some code...; 
-- comment 
sql code 
""" 
    print __sanitize_sql(sql) 

不知道这是最好的解决方案，但似乎对于不太复杂解析SQL语句的工作。

现在的问题是如何运行这段代码，我可以做一些类似于this dude的东西，但它看起来很丑，我不是一个Python专家（我们在这里只是在过去的2周里一直在做python），但似乎以这种方式滥用光标是不好的做法。

想法/博客文章会有帮助。

谢谢你，
Maxim。

Answer 1

在游标对象上调用executemany方法。这里更多的信息： http://mysql-python.sourceforge.net/MySQLdb.html

Answer 2

这里是你如何使用executemany()：

import MySQLdb 
connection = MySQLdb.connect(host='host...rds.amazonaws.com', db='dbName', user='userName', passwd='password') 
cursor = connection.cursor() 

my_data_to_insert = [['maxim0', 'was here0'], ['maxim1', 'was here1'], ['maxim2', 'was here1']] 
sql = "insert into rollout.version (`key`, `value`) VALUES (%s, %s);" 

cursor.executemany(sql, my_data_to_insert) 

connection.commit() 
connection.close()