Flask (flask-restful) 和 MySQLdb (PyMySQL) 的奇怪并发问题

如何解决Flask (flask-restful) 和 MySQLdb (PyMySQL) 的奇怪并发问题

我有一个使用 MysqL 数据库的flask-restful 项目，我目前正在使用 PyMysqL 连接到数据库，我之前尝试使用flask-MysqLdb 和flask-MysqL 但它们并没有真正起作用，因为我需要在请求方法外部使用数据库连接（主要用于装饰器），所以我开始使用 PyMysqL，但现在我发现并发问题，每当我尝试同时发出 2 个以上的并发请求时时间（这意味着 2 个并发查询）我收到此错误：

MysqLdb._exceptions.programmingerror: (2014,"commands out of sync; you can't run this command Now")

我确实在每次查询后调用 cursor.nextset 以确保结果被完全消耗，并且我确实确保我的所有查询和存储过程都是正确的并且没有任何问题，我开始认为该问题是由服务器仅使用一个游标引起的，因为游标是在一个单独的模块中定义的，所有视图/资源都将其导入以执行工作（它们不会创建新游标），但是在我创建了每个视图/资源之后方法创建一个新的游标来处理并在之后关闭它，我仍然遇到同样的错误。 这就是我执行查询的方式：

cursor.callproc('do_something',(arg1,arg2))
result = cursor.fetch_all()
cursor.nextset()

它与竞争条件无关，因为查询不写任何内容。我尝试通过 Waitress 为应用程序提供服务，但问题仍然存在。

解决方法

对于MySQLdb 存储过程

cursor.callproc('do_something',(arg1,arg2))

这里你必须为所有输出参数添加一个变量

cursor.execute('SELECT @outparameter1,@outparameter2,@outparameter3')

cursor.fetchall()

对于 pymyslq，您需要进行更多更改，因为没有 callproc

cusrorType      = pymysql.cursors.DictCursor

 

databaseConnection   = pymysql.connect(host=hostName,user=userName,password=userPassword,db=databaseName,charset=databaseCharset,cursorclass=cusrorType)

                                    

try:

    # Cursor object creation

    cursorObject    = databaseConnection.cursor()                                    

 

    # Execute the sqlQuery

    cursorObject.execute("call do_something(?,?)",arg1,arg2)

 

    # Print the result of the executed stored procedure

    for result in cursorObject.fetchall():

        print(result)

对于 mysq.connector 你必须像

一样事先调用`store_result

cursor.callproc('do_something',arg2))
for result in cursor.stored_results():
    result.fetchall()