尝试在函数中使用 mysql 连接器

Question

from flask_wtf import FlaskForm
from wtforms import StringField, PasswordField, BooleanField, SubmitField,IntegerField
from wtforms.validators import DataRequired
from flask import Flask,render_template
import os
import requests
import mysql.connector
import sys
import json
mydb = mysql.connector.connect(
    host="localhost",
    user="tester",
    password="test@123",
    database="flaskapp"
    )
cur=mydb.cursor()
def insert_steamid(s):
    
    api_key=""
    res=requests.get("https://api.brawlhalla.com/search?steamid="+str(s)+"&api_key="+api_key);
    data=json.loads(res.text)
    brawl_id=str(data['brawlhalla_id'])
    res2=requests.get("https://api.brawlhalla.com/player/"+brawl_id+"/ranked?api_key="+api_key)
    data2=json.loads(res2.text)
    rank=data2['global_rank']
    # if(rank==0):
    #     return("no competitive stats available")
    temp=(rank,data2['name'],data2['brawlhalla_id'],data2['region'],data2['legends'][0]['legend_id'])
    sql = "insert into test_table  values (%s,%s,%s,%s,%s)"
    try:
        cur.execute(sql,temp)
        mydb.commit()
        return("data added")
    except mysql.connector.Error as err:
        return(err)



class Config(object):
    SECRET_KEY = os.environ.get('SECRET_KEY') or 'you-will-never-guess'


app = Flask(__name__)
app.config.from_object(Config)



class LoginForm(FlaskForm):
    username = IntegerField('Username', validators=[DataRequired()])
    submit = SubmitField('Sign In')


main_query="select players_1v1.rankp , players_1v1.name , players_1v1.region , legends.legend_name_key  from players_1v1,legends where players_1v1.best_legend = legends.legend_id ;"
cur.execute(main_query)
data=cur.fetchall()
cur.close()
mydb.close()




@app.route('/',methods=['GET','POST'])
def example(): 
    print("ss")
    # cursor.execute("select * from legends") 
    # data = cursor.fetchall() 
    return render_template("index.html", test=data) 

@app.route('/ent',methods=['GET','POST'])
def login():
    steam_id=int(0)
    form = LoginForm()
    msg=str('')
    if form.validate_on_submit():
        msg=insert_steamid(form.username.data)
        print(msg)
        # print('Login requested for user {}, remember_me={}'.format(
        #     form.username.data, "u"))
    else:
        print("no")
    return render_template('form.html', title='Sign In', form=form, message=msg)
if __name__ == '__main__':
    app.run(debug=True) 

这是我的程序，我想做的是从一个函数运行一些 SQL 查询，但这似乎效果不佳。我必须再次在函数中重新定义 mydb 和 cur 才能使其正常工作。我究竟做错了什么？ 编辑：在执行main_query 之后，insert_steamid 函数调用光标之前，我关闭了光标。这是我的一个愚蠢的错误

Answer 1

我认为你需要调试你的代码。

我去掉了一些，并做了一个测试：

import mysql.connector

mydb = mysql.connector.connect(
host="localhost",
user="test",
password="test",
database="test"
)
cur=mydb.cursor()
def insert_steamid(s):
        sql = "SELECT count(*) as i FROM numm"
        print("test")
        try:
            cur.execute(sql)
            for (i) in cur:
                print(s,i)
            mydb.commit()
            return("data added")
        except mysql.connector.Error as err:
            return(err)

mydb = mysql.connector.connect(
host="localhost",
user="test",
password="test",
database="test"
)
cur=mydb.cursor()
print(insert_steamid("abc"))

结果是：

test
abc (10,) 
data added

哪些是正确的，因为我的numm 表中有 10 条记录。

也许我应该投票赞成“因为不可复制而关闭”？