为什么 MySql 连接在 Flask Python API 上不起作用

如何解决为什么 MySql 连接在 Flask Python API 上不起作用

我使用的是 sqlite 但是转移到了 MysqL

有效的sqlite代码：

@app.route('/api/v1/users/user',methods=['GET'])
def api_filter():
    query_parameters = request.args
userid = query_parameters.get('userid')
username = query_parameters.get('username')

query = "SELECT * FROM tblUser WHERE"
to_filter = []

if userid:
    query += ' user_id=? AND'
    to_filter.append(userid)
if username:
    query += ' username=? AND'
    to_filter.append(username)
if not (userid or username):
    return page_not_found(404)

query = query[:-4] + ';'

conn = sqlite3.connect('dbApp.db')
conn.row_factory = dict_factory
cur = conn.cursor()

results = cur.execute(query,to_filter).fetchall()

return jsonify(results)

现在，当我将其更改为 MysqL 时，它不起作用：

@app.route('/api/v1/users/user',methods=['GET'])
def api_filter():
    query_parameters = request.args
userid = query_parameters.get('userid')
username = query_parameters.get('username')

query = "SELECT * FROM tblUser WHERE"
to_filter = []

if userid:
    query += ' user_id=? AND'
    to_filter.append(userid)
if username:
    query += ' username=? AND'
    to_filter.append(username)
if not (userid or username):
    return page_not_found(404)

query = query[:-4] + ';'

conn = MysqL.connector.connect(host="localhost",user="root",password="green",database="dbApp")
conn.row_factory = dict_factory
cur = conn.cursor()

results = cur.execute(query,to_filter).fetchall()

return jsonify(results)

错误返回： 结果 = cur.execute(query,to_filter).fetchall() 文件“/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/MysqL/connector/cursor_cext.py”，第260行，在执行 引发错误。编程错误（ MysqL.connector.errors.ProgrammingError: sql 语句中未使用所有参数 127.0.0.1 - - [2020 年 12 月 28 日 17:47:11]“

这是运行后： http://127.0.0.1:5000/api/v1/users/user?userid=3&username=Jo

http://127.0.0.1:5000/api/v1/users/user?userid=3

http://127.0.0.1:5000/api/v1/users/user?username=Jo

还添加了这个： 从烧瓶导入请求，jsonify 导入 MysqL.connector

解决方法

documentation 是这样说的：

cursor.execute(operation,params=None,multi=False) 此方法执行给定的数据库操作（查询或命令）。 在元组或字典参数中找到的参数绑定到 操作中的变量。使用 %s 或 %(name)s 指定变量 参数样式（即使用 format 或 pyformat 样式）。执行（） 如果 multi 为 True，则返回一个迭代器。

我认为您的代码有两个问题：您使用的是 ?对于绑定变量而不是 %s，并且您传入的是列表而不是元组。或者使用命名参数并使用字典传递值。两者都试一下，看看你最喜欢什么。

1. user_id = %s" 和 to_filter = (userid,)。您可以使用您现在拥有的列表，只需将其转换为 tuple()。
2. " user_id = %{user_id}" 并设置 to_filter = {'user_id': userid }。

先构建一个条件列表，然后使用' AND '.join(conditions) 而不是删除额外的AND 会更简洁。您可以通过省略“;”来稍微简化代码。