ORM框架 使用Flask进行数据库开发
时间: 2025-01-01 22:27:39 浏览: 6
### Flask与ORM框架(如SQLAlchemy)进行Web应用数据库开发的最佳实践
#### 设置环境和安装依赖库
为了使用Flask和SQLAlchemy构建应用程序,需先配置好运行环境并安装必要的包。这通常涉及创建虚拟环境来隔离项目的依赖项,并利用pip工具安装`flask`和`flask-sqlalchemy`等扩展模块[^1]。
```bash
$ python3 -m venv myprojectvenv
$ source myprojectvenv/bin/activate # Windows下应使用 `myprojectvenv\Scripts\activate.bat`
(myprojectvenv)$ pip install flask flask_sqlalchemy
```
#### 配置数据库连接
在Flask程序实例初始化之后,应当立即设定数据库URI以便告知Flask-SQLAlchemy要使用的具体数据库位置。此过程可通过修改app.config字典完成,其中键名为'SQLALCHEMY_DATABASE_URI',其值则取决于所选的数据库类型及其访问路径。
```python
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///site.db'
db = SQLAlchemy(app)
```
#### 定义模型类
定义数据表结构的关键在于编写相应的Python类表示法——即所谓的“模型”。这些类继承自`db.Model`基类,并且每一个属性代表了未来将在对应的数据表里存在的字段名;同时还可以指定额外参数用于控制列的行为特性,比如是否允许为空、默认值是什么等等。
```python
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(20), unique=True, nullable=False)
email = db.Column(db.String(120), unique=True, nullable=False)
def __repr__(self):
return f"User('{self.username}', '{self.email}')"
```
#### 创建迁移脚本和支持版本控制系统
当首次设计好了所有的模型后,应该考虑采用Alembic这样的自动化迁移工具帮助追踪模式变化历史记录,从而简化部署流程中的升级操作。通过命令行界面生成初始修订版文件,并据此建立实际物理存储空间内的相应表格实体。
```bash
(flask_app_env)$ flask db init
(flask_app_env)$ flask db migrate -m "initial migration"
(flask_app_env)$ flask db upgrade
```
#### 执行CRUD操作
一旦完成了上述准备工作,则可以在视图函数内部轻松调用各种方法来进行增删改查动作。例如新增一条记录只需构造对象实例再提交会话即可;查询特定条件下的多条或多条目可以通过`.query.filter_by()`接口配合链式调用来达成目的;更新现有资料同样遵循类似的逻辑思路;而删除则是定位目标节点后执行对应的销毁指令。
```python
@app.route("/add_user", methods=['POST'])
def add_user():
user_data = request.form.to_dict()
new_user = User(username=user_data.get('username'), email=user_data.get('email'))
try:
db.session.add(new_user)
db.session.commit()
flash(f'{new_user} has been added!', category='success')
except Exception as e:
db.session.rollback()
flash(str(e), category='danger')
return redirect(url_for('home'))
@app.route('/users/<int:user_id>/delete', methods=["GET"])
@login_required
def delete_post(user_id):
target_user = User.query.get_or_404(user_id)
try:
db.session.delete(target_user)
db.session.commit()
flash("The selected user was successfully deleted.", "info")
except IntegrityError:
db.session.rollback()
flash("Failed to remove the specified user due to integrity constraints.", "warning")
return redirect(url_for('manage_users'))
```
阅读全文