SQLALchemy介绍:
具体详情:flask连接数据库
sqlalchemy是数据库的orm框架,让我们操作数据库的时候不要再用sql语句了,跟直接操作模型一样。
请求钩子:
- 在请求开始时,建立数据库连接;
- 在请求开始时,根据需求进行权限校验;
- 在请求结束时,指定数据的交互格式;
@app.before_first_request
@app.before_request
@app.after_request
@app.teardown_request
sqlalchemy与Flask-sqlalchemy的区别:
sqlalchemy:是一个独立的ORM框架,可以独立于Flask存在,也可以在其他项目中使用,比如Django中。
Flask-sqlalchemy:对sqlalchemy的一个封装,能够更适合在flask中使用。
一、安装
1、安装连接数据库的库:pip install pymysql
2、安装: pip install flask-sqlalchemy
二、连接数据库:
基本的配置:
1: 首先先安装两个依赖的包。
2:配置数据库的连接:app.config[‘SQLALCHEMY_DATABASE_URI’] = “mysql://root:mysql@192.168.44.128:3306/test39”
3:关闭数据库的跟踪:app.config[‘SQLALCHEMY_TRACK_MODIFICATIONS’] = False
4:开启输出sql语句:app.config[‘SQLALCHEMY_ECHO’] = True
5:两种处理python2和python3的名字不一致问题。
from flask import Flask
from flask_restful import Api, Resource
from flask_sqlalchemy import SQLAlchemy
"""
python2中数据库客户端: MySqldb
python3中数据库客户端:pymysql
解决方案一:让python2和python3的包进行转换。
import pymysql
pymysql.install_as_MySQLdb()
方案二:表示只使用python3的包,不使用python2的包
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
"""
app = Flask(__name__)
db = SQLAlchemy(app)
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['SQLALCHEMY_ECHO'] = True
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
@app.route('/')
def hello_word():
return "hello, word"
if __name__ == '__main__':
print(app.url_map)
app.run(host='0.0.0.0', port= 8000, debug=True)
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
db = SQLAlchemy(app)
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
验证是否连接成功
@app.route('/')
def hello_word():
engine = db.get_engine()
conn = engine.connect()
conn.close()
return "hello, word"
创建模型并进行数据增删改查
class mmm(db.Model):
__tablename__ = 'mmm'
id = db.Column(db.Integer,primary_key,autoincreament)
title = db.Column(db.string(200),nullable=Flase)
content = db.Column(db.Text,nullable=Flase)
db.create_all()
数据操作——增删改查
1:给模型对象设置数据 可以通过 初始化参数 或者 赋值属性 两种方式
2:session.add(模型对象) 添加单条数据到会话中, session.add_all(列表) 添加多条数据到会话中
3:sqlalchemy 会 自动创建事务, 并将数据操作包含在事务中, 提交会话时就会提交事务,事务提交失败会自动回滚。
@app.route('/mmm")
def mmm_view():
article = mmm(title= "",content="")
db.session.add(article)
db.session.commit()
return "数据操作成功"
artice = mmm.query.filter_by(id=1)[0]
print(artice.title)
return "数据操作成功"
artice = mmm.query.filter_by(id=1)[0]
artice.content = "xxx"
db.session.commit
return "数据操作成功"
mmm.query.filter_by(id=1).delete()
db.session.commit()
return "数据操作成功"
表关系:
表之间的关系存在三种:
一对一,一对多,多对多,而SQLAlchemy中的ORM也可以模拟这三种关系,因为一对一其实在SQLAlchemy中底层是通过一对多的方式模拟的,所以先看一下一对多的关系:
外键:
在mysql中,外键可以让表之间的关系更加紧密,而SQLAlchemy同样也支持外键,通过foreignkey类来实现,并且可以指定表的外键约束。
class user(db.Model):
__tablename__ = 'mmm'
id = db.Column(db.Integer,primary_key,autoincreament)
username = db.Column(db.string(200),nullable=)
class Article(db.Model):
__tablename__ = 'ggg'
id = db.Column(db.Integer,primary_key,autoincreament)
title = db.Column(db.string(200),nullable=Flase)
content = db.Column(db.Text,nullable=Flase)
author_id = db.Column(db.Integer,db.Foreignkey("user.id"))
author = db.relationship("user",backref="articles")
user = db.relationship("User",backref=db.backref("extension",uselist=Flase))
flask——Migrate插件
在实际的开发环境中,经常会发生数据库修改的行为。一般我们修改数据库不会直接手动的去修改,而是去修改ORM对应的模型,然后再把模型映射到数据库中。这时候如果有一个工具能专门做这种事情,就显得非常有用了,而flask-migrate就是做这个事情的。flask-migrate是基于Alembic进行的一个封装,并集成到Flask中,而所有的迁移操作其实都是Alembic做的,他能跟踪模型的变化,并将变化映射到数据库中。
使用Flask-Migrate需要安装,命令如下:
pip install flask-migrate
一、基本用法
要让Flask-Migrate能够管理app中的数据库,需要使用Migrate(app,db)来绑定app和数据库。假如现在有以下app文件:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from constants import DB_URI
from flask_migrate import Migrate
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
db = SQLAlchemy(app)
migrate = Migrate(app,db)
class User(db.Model):
id = db.Column(db.Integer,primary_key=True)
username = db.Column(db.String(20))
addresses = db.relationship('Address',backref='user')
class Address(db.Model):
id = db.Column(db.Integer,primary_key=True)
email_address = db.Column(db.String(50))
user_id = db.Column(db.Integer,db.ForeignKey('user.id'))
db.create_all()
@app.route('/')
def hello_world():
return 'Hello World!'
if __name__ == '__main__':
app.run()
之后,就可以在命令行中映射ORM了。首先需要初始化一个迁移文件夹:
flask db init
然后再把当前的模型添加到迁移文件中:
flask db migrate
最后再把迁移文件中对应的数据库操作,真正的映射到数据库中:
flask db upgrade
二、项目重构:
以下对各个文件的作用进行解释。
- constants.py文件:
常量文件,用来存放数据库配置。
HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = 'xt_flask_migrate'
USERNAME = 'root'
PASSWORD = 'root'
DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
- ext.py文件:
把db变量放到一个单独的文件,而不是放在主app文件。这样做的目的是为了在大型项目中如果db被多个模型文件引用的话,会造成from your_app import db这样的方式,但是往往也在your_app.py中也会引入模型文件定义的类,这就造成了循环引用。所以最好的办法是把它放在不依赖其他模块的独立文件中。
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()
- models.py文件:
模型文件,用来存放所有的模型,并且注意,因为这里使用的是flask-script的方式进行模型和表的映射,因此不需要使用db.create_all()的方式创建数据库。
from ext import db
class User(db.Model):
id = db.Column(db.Integer,primary_key=True)
username = db.Column(db.String(50))
addresses = db.relationship('Address',backref='user')
def __init__(self,username):
self.username = username
class Address(db.Model):
id = db.Column(db.Integer,primary_key=True)
email_address = db.Column(db.String(50))
user_id = db.Column(db.Integer,db.ForeignKey('user.id'))
def __init__(self,email_address):
self.email_address = email_address
- app.py文件:
这个是主app文件,运行文件。并且因为db被放到另外一个文件中,所以使用db.init_app(app)的方式来绑定数据库。
from flask import Flask
from ext import db
app = Flask(__name__)
db.init_app(app)
@app.route('/')
def hello_world():
return 'Hello World!'
if __name__ == '__main__':
app.run()
三、迁移命令:
通过以上项目重构后,后续我们就只要通过以下三个命令即可完成迁移操作了。
在命令行中映射ORM了。首先需要初始化一个迁移文件夹:
flask db init
然后再把当前的模型添加到迁移文件中:
flask db migrate
最后再把迁移文件中对应的数据库操作,真正的映射到数据库中:
flask db upgrade
Original: https://blog.csdn.net/weixin_46549605/article/details/123458430
Author: mr. 刘liu
Title: flask连接数据库——flask-SQLALchemy
原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/744159/
转载文章受原作者版权保护。转载请注明原作者出处!