Flask SQLite

17 Mar 2025 | 6 分钟阅读

Flask 可以使用 Python 的 SQLite3 模块来创建数据库 Web 应用程序。在本教程的这一部分中，我们将创建一个 CRUD（创建 - 读取 - 更新 - 删除）应用程序。

由于我们已经详细介绍了 Python 应用程序如何与 SQLite 数据库交互，要复习该概念，请访问此链接：Python SQLite。

Flask 中的 CRUD 应用程序

在这里，我们将使用 Flask 脚本来管理 SQLite 数据库中的员工信息，管理员可以与该脚本进行交互。为此，数据库 employee.db 包含相关表，而 Employees 表包含员工信息。

首先，让我们使用以下 Python 脚本在 SQLite 中创建数据库 employee.DB 和表 Employees。

EmoloyeeDB.py

import sqlite3

con = sqlite3.connect("employee.db")
print("Database opened successfully")

con.execute("create table Employees (id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, email TEXT UNIQUE NOT NULL, address TEXT NOT NULL)")

print("Table created successfully")

con.close()

要在 Flask 中构建 CRUD 应用程序，我们必须关注视图函数（用于获取输入）和控制器（用于将数据保存到数据库中）。

让我们看看与 URL (/) 关联的视图函数：index()。它渲染模板 index.html。

@app.route("/")
def index():
	return render_template("index.html");

以下 HTML 模板 (index.html) 被视为我们应用程序的主页。它提供了链接，我们可以使用这些链接添加、查看和删除存储在数据库中的数据。

index.html

<!DOCTYPE html>
<html>
<head>
	<title>home</title>
</head>
<body>
	<h2>Hi, welcome to the website</h2>
	<a href="/add">Add Employee</a><br><br>
	<a href ="/view">List Records</a><br><br>
	<a href="/delete">Delete Record</a><br><br>
</body>
</html>

与 URL (/add) 关联的视图函数 add() 渲染下面给出的模板 add.html。它提供了输入员工信息的表单。

add.html

<!DOCTYPE html>
<html>
<head>
	<title>Add Employee</title>
</head>
<body>
	<h2>Employee Information</h2> 
	<form action = "/savedetails" method="post">
	<table>
		<tr><td>Name</td><td><input type="text" name="name"></td></tr>
		<tr><td>Email</td><td><input type="email" name="email"></td></tr>
		<tr><td>Address</td><td><input type="text" name="address"></td></tr>
		<tr><td><input type="submit" value="Submit"></td></tr>
	</table>
	</form>
</body>
</html>

管理员输入的所有详细信息都发布到与函数 saveDetails() 关联的 URL /savedetails。下面给出了 saveDetails() 函数，其中包含用于提取管理员输入的数据并将该数据保存到 Employees 表中的代码。

它还根据数据成功插入或发生错误的情况生成消息。

@app.route("/savedetails",methods = ["POST","GET"])
def saveDetails():
	msg = "msg"
	if request.method == "POST":
		try:
			name = request.form["name"]
			email = request.form["email"]
			address = request.form["address"]
			with sqlite3.connect("employee.db") as con:
				cur = con.cursor()
				cur.execute("INSERT into Employees (name, email, address) values (?,?,?)",(name,email,address))
				con.commit()
				msg = "Employee successfully Added"
		except:
			con.rollback()
			msg = "We can not add the employee to the list"
		finally:
			return render_template("success.html",msg = msg)
			con.close()

它渲染模板 success.html 以向管理员显示消息。它还包含一个链接，用于查看用户输入的记录。

success.html

<!DOCTYPE html>
<html>
<head>
	<title>save details</title>
</head>
<body>
	<h3>Hi Admin, {{msg}}</h3>
	<a href="/view">View Employees</a>
</body>
</html>

delete() 函数与 URL /delete 关联。它渲染一个 HTML 模板 delete.html，该模板向管理员提供一个表单，提示输入要删除记录的 Employee_Id。它还包含一个指向 /view URL 的链接，该链接向管理员显示所有记录。

HTML 模板 delete.html 如下所示。

delete.html

<!DOCTYPE html>
<html>
<head>
	<title>delete record</title>
</head>
<body>

	<h3>Remove Employee from the list</h3>

<form action="/deleterecord" method="post">
Employee Id <input type="text" name="id">
<input type="submit" value="Submit">
</form>
</body>
</html>

管理员输入的 Employee_Id 被发布到 URL /deleterecord，其中包含建立数据库连接然后删除指定 Employee ID 的所有记录的 Python 代码。URL /deleterecord 与下面给出的函数 deleterecord() 关联。

@app.route("/deleterecord",methods = ["POST"])
def deleterecord():
	id = request.form["id"]
	with sqlite3.connect("employee.db") as con:
		try:
			cur = con.cursor()
			cur.execute("delete from Employees where id = ?",id)
			msg = "record successfully deleted"
		except:
			msg = "can't be deleted"
		finally:
			return render_template("delete_record.html",msg = msg)

deleterecord() 函数根据数据是否成功删除或发生错误的情况生成消息。它渲染 HTML 模板 delete_record.html 以向管理员显示消息。

delete_record.html

<!DOCTYPE html>
<html>
<head>
	<title>delete record</title>
</head>
<body>
<h3>{{msg}}</h3>
<a href="/view">View List</a>
</body>
</html>

模板 delete_record.html 包含一个指向 URL /view 的链接，该链接向管理员显示员工记录。

它与函数 view() 关联，该函数建立与数据库的连接，获取所有信息并将该信息传递给 HTML 模板 view.html 以在客户端浏览器上显示。

app.route("/view")
def view():
	con = sqlite3.connect("employee.db")
	con.row_factory = sqlite3.Row
	cur = con.cursor()
	cur.execute("select * from Employees")
	rows = cur.fetchall()
	return render_template("view.html",rows = rows) 

在浏览器上显示所有信息的 HTML 模板 view.html 如下所示。

view.html

<!DOCTYPE html>
<html>
<head>
	<title>List</title>
</head>
<body>

<h3>Employee Information</h3>
<table border=5>
	<thead>
		<td>ID</td>
		<td>Name</td>
		<td>Email</td>
		<td>Address</td>
	</thead>
	
	{% for row in rows %}
	
		<tr>
			<td>{{row["id"]}}</td>
			<td>{{row["name"]}}</td>
			<td>{{row["email"]}}</td>
			<td>{{row["address"]}}</td>
		</tr>
	
	{% endfor %}
</table>
<br><br>

<a href="/">Go back to home page</a>

</body>
</html>

完整的 Python 脚本如下所示。

crud.py

from flask import *
import sqlite3

app = Flask(__name__)

@app.route("/")
def index():
	return render_template("index.html");

@app.route("/add")
def add():
	return render_template("add.html")

@app.route("/savedetails",methods = ["POST","GET"])
def saveDetails():
	msg = "msg"
	if request.method == "POST":
		try:
			name = request.form["name"]
			email = request.form["email"]
			address = request.form["address"]
			with sqlite3.connect("employee.db") as con:
				cur = con.cursor()
				cur.execute("INSERT into Employees (name, email, address) values (?,?,?)",(name,email,address))
				con.commit()
				msg = "Employee successfully Added"
		except:
			con.rollback()
			msg = "We can not add the employee to the list"
		finally:
			return render_template("success.html",msg = msg)
			con.close()

@app.route("/view")
def view():
	con = sqlite3.connect("employee.db")
	con.row_factory = sqlite3.Row
	cur = con.cursor()
	cur.execute("select * from Employees")
	rows = cur.fetchall()
	return render_template("view.html",rows = rows)


@app.route("/delete")
def delete():
	return render_template("delete.html")

@app.route("/deleterecord",methods = ["POST"])
def deleterecord():
	id = request.form["id"]
	with sqlite3.connect("employee.db") as con:
		try:
			cur = con.cursor()
			cur.execute("delete from Employees where id = ?",id)
			msg = "record successfully deleted"
		except:
			msg = "can't be deleted"
		finally:
			return render_template("delete_record.html",msg = msg)

if __name__ == "__main__":
	app.run(debug = True)

在终端上使用以下命令运行 Python 脚本 EmployeeDB.py 来创建数据库和 Employees 表。

现在，运行 Flask 脚本 crud.py 并在浏览器上访问 https://:5000。