flask-sqlalchemy使用，flask-migrate使用

flask-sqlalchemy使用，flask-migrate使用

flask-sqlalchemy使用

集成到flask中，我们可以用sqlalchemy来做，就是比较的繁琐
现在有一个第三方的flask-sqlalchemy,可以快速的集成到flask中

# 使用flask-sqlalchemy集成
1.下载flask-sqlalchemy   # pip install flask-sqlalchemy
2.导入flask-sqlalchemy   # from flask-sqlalchemy improt SQLAlchemy
3.实例化得到对象          # db = SQLAlchemy()
4.视图函数中使用session   # 全局的session
5.在py文件中继承Model     # db.Model
6.写入字段                # useranem= db.Column(db.String(80),unique=True,nullable=False)
7.在配置文件中加入         # SQLALCHEMY_DATABASE_URI = create_engine("mysql+pymysql://[email protected]:3306/aaa")
					    # SQLALCHEMY_POOL_SIZE = 5
                          #  SQLALCHEMY_POOL_TIMEOUT = 30
                          #  SQLALCHEMY_POOL_RECYCLE = -1
                          # 追踪对象的修改并且发送信号
                          #  SQLALCHEMY_TRACK_MODIFICATIONS = False

py文件

from flask import Flask
# from flask_sqlalchemy improt SQLAlchemy
from flask_sqlalchemy import SQLAlchemy


app=Flask(__name__)
app.config.from_pyfile('settings.py')
# 实例化得到对象
db = SQLAlchemy()
# 将db注册到app中
db.init_app(app)

@app.route('/')
def index():
    from models import Book
    db.session.add(Book(name='xxxxx'))
    db.session.commit()
    return '增加成功'

if __name__ == '__main__':
    app.run()

settings.py

SQLALCHEMY_DATABASE_URI = "mysql+pymysql://root:[email protected]:3306/ddd"
SQLALCHEMY_POOL_SIZE = 5
SQLALCHEMY_POOL_TIMEOUT = 30
SQLALCHEMY_POOL_RECYCLE = -1
# 追踪对象的修改并且发送信号
SQLALCHEMY_TRACK_MODIFICATIONS = False

model.py

from manage import db
class Book(db.Model):
    __tablename__ = 'books'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(32))

flask-migrate使用

# 表发生变化，都会有记录的，自动同步到数据库中的
原生的sqlalchemy，不支持修改表的
flask-migrate可以实现类似于django的表迁移，将数据同步到数据库中
# django中表迁移
python manage.py makemigrations
python manage.py migrate

# 使用步骤
 flask：2.2.2   flask-script：2.0.3  
1 第一步：安装，依赖于flask-script
    pip3.8 install flask-migrate==2.7.0
2 在app所在的py文件中
    from flask_script import Manager
    from flask_migrate import Migrate, MigrateCommand
    manager = Manager(app)
    Migrate(app, db)
    manager.add_command('db', MigrateCommand) 

    manager.run() # 以后使用python manage.py runserver 启动项目

3 以后第一次执行一下
    python manage.py db init  # 生成一个migrations文件夹，里面以后不要动，记录迁移的编号

4 以后在models.py 写表，加字段，删字段，改参数

5 只需要执行
    python manage.py db migrate  # 记录
    python manage.py db upgrade  # 真正的同步进去

"""
     python3 manage.py db init   只执行一次，初始化的时候使用  会在项目路径下生成migrations文件夹，用来管理表变化
     python3 manage.py db migrate  等同于django的makemigrations,只是做个记录
     python3 manage.py db upgrade  等同于django的migrate把变化同步到数据库中
"""

manage.py

from sansa import create_app
from flask_script import Manager
from flask_migrate import Migrate, MigrateCommand
from sansa import db

app = create_app()
# flask-script的使用
# 第一步：初始化出flask_script的manage
manager = Manager(app)
# 第二步：使用flask_migrate的Migrate  包裹一下app和db（sqlalchemy对象）
Migrate(app, db)

# 第三步：把命令增加到flask-script中去
manager.add_command('db', MigrateCommand)  # 多出三个命令 init  migrate  upgrade
# python manage.py upgrade
if __name__ == '__main__':
    # app.run()
    manager.run()

model.py

from . import db
# 第三步：把db导入，直接继承db.Model

class Users(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(80), unique=True, nullable=False)
    # email = db.Column(db.String(120), unique=True, nullable=False)

    def __repr__(self):
        return '<User %s>' % self.username

setttings.py

class BaseConfig(object):

    SQLALCHEMY_DATABASE_URI = "mysql+pymysql://[email protected]:3306/ddd?charset=utf8"
    SQLALCHEMY_POOL_SIZE = 5
    SQLALCHEMY_POOL_TIMEOUT = 30
    SQLALCHEMY_POOL_RECYCLE = -1
    # 追踪对象的修改并且发送信号
    SQLALCHEMY_TRACK_MODIFICATIONS = False