如何将我的烧瓶应用程序连接到我的 SQLite3 数据库？

Question

您好，我正在尝试创建客户反馈表；我已经设法创建了我需要的页面，但是我在将我的应用程序连接到我的 SQLite3 数据库时遇到了困难。

所以在我的代码 python 代码中，我试图从客户反馈表中收集数据并将其保存在数据库中。

在反馈表中，系统会提示他们输入自己的姓名，从下拉框中选择一些答案，并在最后写评论。

答案将保存在数据库中（供将来参考 - 例如报告等），用户将被重定向回主页，在那里他们将能够看到他们的姓名和评论（取自反馈表）。

我看过关于 sqlite3 的教程，这些教程很容易理解和执行（对我来说比 MySQL 容易得多），但我遗漏了一些东西，因为它无法连接到我的数据库。

我的python烧瓶代码：

from flask import Flask, render_template, redirect, url_for, request, session, flash, g
from functools import wraps
import sqlite3

app = Flask(__name__)
app.secret_key = "random_character_generator" # this would be random or anything the developer wants
app.database = "gymdatabase.db"

conn = sqlite3.connect(app.database)
c = conn.cursor()

def connect_db():
    return sqlite3.connect(app.database)

@app.route('/')
def home():
    g.db = connect_db()
    cur = g.db.execute('select * from posts')
    posts = [dict(name=row[0], welcome=row[1], equipment=row[2], cleanliness=row[3], interaction=row[4], comments=row[5], contact=row[6]) for row in cur.fetchall()]
    g.db.close()
    return render_template('gym_index.html', posts=posts)

@app.route('/feedback', methods=['POST'])
def feedback():
    return render_template('gym_feedback.html')

@app.route('/process', methods=['GET', 'POST'])
def process():
    g.db = connect_db()
    name = request.form['name']
    welcome = request.form['welcome']
    equipment = request.form['equipment']
    cleanliness = request.form['cleanliness']
    interaction = request.form['interaction']
    comment = request.form['comment']
    contact = request.form['yes_no']
    conn.commit()
    cur = g.db.execute(select * from posts)
    posts = [dict(name=row[0], welcome=row[1], equipment=row[2], cleanliness=row[3], interaction=row[4], comments=row[5], contact=row[6]) for row in cur.fetchall()]
    g.db.close()
    return redirect(url_for('home', posts=posts))   

当我尝试提交反馈表时，我得到： sqlite3.ProgrammingError: 在一个线程中创建的 SQLite 对象只能在同一个线程中使用。

我可以根据要求上传 html 文件；我不太确定我是否有空间与我的 python 文件一起这样做。

Answer 1

我认为这是由于您的 conn.commit() 行在您的 process() 函数中。您在 Flask 首次启动时声明了 conn = sqlite3.connect(app.database)，但是使用 @app.route(...) 函数装饰器定义的每个函数都会在不同的线程中调用以响应 HTTP 请求（如上述函数装饰器中所定义）。你可能想做这样的事情：

@app.route('/process', methods=['GET', 'POST'])
def process():
    ...
    db = connect_db()
    cur = db.cursor()
    cur.execute("select * from posts")
    results = cur.fetchall()
    ...

您可以查看此链接以获取更多文档：https://docs.python.org/2/library/sqlite3.html

如果您提供有关代码失败位置的更多上下文，我可以编辑我的答案。