我正在尝试将代码库从使用 MySQLdb 转换为 pymysql。我遇到了以下问题,想知道是否有人见过类似的问题。
简而言之,如果我通过 pymysql 游标 callproc() 方法调用存储过程,则使用相同或不同游标通过 execute() 方法进行的后续“选择”调用将返回不正确的结果。我看到 Python 2.7.2 和 Python 3.2.2 的结果相同
callproc() 方法是否以某种方式锁定了服务器?代码如下:
conn = pymysql.connect(host='localhost', user='me', passwd='pwd',db='mydb')
curr = conn.cursor()
rargs = curr.callproc("getInputVar", (args,))
resultSet = curr.fetchone()
print("Result set : {0}".format(resultSet))
# curr.close()
#
# curr = conn.cursor()
curr.execute('select * from my_table')
resultSet = curr.fetchall()
print("Result set len : {0}".format(len(resultSet)))
curr.close()
conn.close()
我可以取消注释上面的 close() 和游标创建调用,但这不会改变结果。如果我注释掉 callproc() 调用,select 语句就可以正常工作。
最佳答案
我有一个类似的问题,即(提交的)INSERT 语句没有出现在数据库中。 PyMySQL 0.5 用于 Python 3.2 和 MySQL Community Server 5.5.19。
我找到了适合我的解决方案:我没有使用 execute() 方法,而是使用了 executemany 方法,在 http://code.google.com/p/pymssql/wiki/PymssqlModuleReference 还有一个示例链接。
更新 稍后,今天,我发现这还不是完整的解决方案。 python 脚本末尾的 exit() 太快会使数据在数据库中丢失。 所以,我在关闭连接之前和 exit() 脚本之前添加了一个 time.sleep() ,最后所有数据都出现了! (我也切换到使用 myisam 表)
import pymysql
conn = pymysql.connect(host='localhost', user='root', passwd='', db='mydb', charset='utf8')
conn.autocommit(True)
cur = conn.cursor()
# CREATE tables (SQL statements generated by MySQL workbench, and exported with Menu -> Database -> Forward Engineer)
cur.execute("""
SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0;
SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0;
SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='TRADITIONAL';
DROP SCHEMA IF EXISTS `mydb` ;
CREATE SCHEMA IF NOT EXISTS `mydb` DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci ;
USE `mydb` ;
# […]
SET SQL_MODE=@OLD_SQL_MODE;
SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS;
SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS;
""")
# Fill lookup tables:
cur.executemany("insert into mydb.number(tagname,name,shortform) values (%s, %s, %s)", [('ЕД','singular','sg'), ('МН','plural','p')] )
cur.executemany("insert into mydb.person(tagname,name,shortform) values (%s, %s, %s)", [('1-Л','first','1st'), ('2-Л','second','2nd'), ('3-Л','third','3rd')] )
cur.executemany("insert into mydb.pos(tagname,name,shortform) values (%s, %s, %s)", [('S','noun','s'), ('A','adjective','a'), ('ADV','adverb','adv'), ('NUM','numeral','num'), ('PR','preposition','pr'), ('COM','composite','com'), ('CONJ','conjunction','conj'), ('PART','particle','part'), ('P','word-clause','p'), ('INTJ','interjection','intj'), ('NID','foreign-named-entity','nid'), ('V','verb','v')] )
#[…]
import time
time.sleep(3)
cur.close()
conn.close()
time.sleep(3)
exit()
我建议论坛/群组https://groups.google.com/forum/#!forum/pymysql-users与开发者进一步讨论。
关于python - pymysql callproc() 似乎影响后续选择,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8218870/