Flask-Migrate

在实际的开发环境中,经常会发生数据库修改的行为。一般我们修改数据库不会直接手动的去修改,而是去修改ORM对应的模型,然后再把模型映射到数据库中。这时候如果有一个工具能专门做这种事情,就显得非常有用了,而flask-migrate就是做这个事情的。flask-migrate是基于Alembic进行的一个封装,并集成到Flask中,而所有的迁移操作其实都是Alembic做的,他能跟踪模型的变化,并将变化映射到数据库中。
使用Flask-Migrate需要安装,命令如下:

  1. pip install flask-migrate

要让Flask-Migrate能够管理app中的数据库,需要使用Migrate(app,db)来绑定app和数据库。假如现在有以下app文件:

  1. from flask import Flask
  2. from flask_sqlalchemy import SQLAlchemy
  3. from constants import DB_URI
  4. from flask_migrate import Migrate
  5. app = Flask(__name__)
  6. app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
  7. app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
  8. db = SQLAlchemy(app)
  9. # 绑定app和数据库
  10. migrate = Migrate(app,db)
  11. class User(db.Model):
  12. id = db.Column(db.Integer,primary_key=True)
  13. username = db.Column(db.String(20))
  14. addresses = db.relationship('Address',backref='user')
  15. class Address(db.Model):
  16. id = db.Column(db.Integer,primary_key=True)
  17. email_address = db.Column(db.String(50))
  18. user_id = db.Column(db.Integer,db.ForeignKey('user.id'))
  19. db.create_all()
  20. @app.route('/')
  21. def hello_world():
  22. return 'Hello World!'
  23. if __name__ == '__main__':
  24. app.run()

之后,就可以在命令行中映射ORM了。要操作当前的flask app,首先需要将当前的app导入到环境变量中:

  1. # windows
  2. $env:FLASK_APP='your_app.py'
  3. #linux/unix
  4. export FLASK_APP='your_app.py'

将当前的app导入到环境变量中后,接下来就是需要初始化一个迁移文件夹:

  1. flask db init

然后再把当前的模型添加到迁移文件中:

  1. flask db migrate

最后再把迁移文件中对应的数据库操作,真正的映射到数据库中:

  1. flask db upgrade

以上是通过加载当前的app到环境变量的做法,这种做法有点麻烦,每次都要设置环境变量。还有一种方法,可以直接通过flask-script的方式进行调用。现在重构之前的项目,设置为以下的目录结构:
第九章:Flask-Migrate - 图1
以下对各个文件的作用进行解释:

constants.py文件:

常量文件,用来存放数据库配置。

  1. # constants.py
  2. HOSTNAME = '127.0.0.1'
  3. PORT = '3306'
  4. DATABASE = 'xt_flask_migrate'
  5. USERNAME = 'root'
  6. PASSWORD = 'root'
  7. DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)

ext.py文件:

db变量放到一个单独的文件,而不是放在主app文件。这样做的目的是为了在大型项目中如果db被多个模型文件引用的话,会造成from your_app import db这样的方式,但是往往也在your_app.py中也会引入模型文件定义的类,这就造成了循环引用。所以最好的办法是把它放在不依赖其他模块的独立文件中。

  1. # ext.py
  2. from flask_sqlalchemy import SQLAlchemy
  3. db = SQLAlchemy()

models.py文件:模型文件,用来存放所有的模型,并且注意,因为这里使用的是flask-script的方式进行模型和表的映射,因此不需要使用db.create_all()的方式创建数据库。

  1. # models.py
  2. from ext import db
  3. class User(db.Model):
  4. id = db.Column(db.Integer,primary_key=True)
  5. username = db.Column(db.String(50))
  6. addresses = db.relationship('Address',backref='user')
  7. def __init__(self,username):
  8. self.username = username
  9. class Address(db.Model):
  10. id = db.Column(db.Integer,primary_key=True)
  11. email_address = db.Column(db.String(50))
  12. user_id = db.Column(db.Integer,db.ForeignKey('user.id'))
  13. def __init__(self,email_address):
  14. self.email_address = email_address

manage.py文件:

这个文件用来存放映射数据库的命令,MigrateCommandflask-migrate集成的一个命令,因此想要添加到脚本命令中,需要采用manager.add_command('db',MigrateCommand)的方式,以后运行python manage.py db xxx的命令,其实就是执行MigrateCommand

  1. # manage.py
  2. from flask_migrate import Migrate,MigrateCommand
  3. from ext import db
  4. from flask_script import Manager
  5. from flask import Flask
  6. from constants import DB_URI
  7. import models
  8. app = Flask(__name__)
  9. app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
  10. app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
  11. db.init_app(app)
  12. migrate = Migrate(app,db)
  13. manager = Manager(app)
  14. manager.add_command('db',MigrateCommand)
  15. if __name__ == '__main__':
  16. manager.run()

flaskmigrate.py文件:

这个是主app文件,运行文件。并且因为db被放到另外一个文件中,所以使用db.init_app(app)的方式来绑定数据库。

  1. # flaskmigrate.py
  2. from flask import Flask
  3. from ext import db
  4. app = Flask(__name__)
  5. db.init_app(app)
  6. @app.route('/')
  7. def hello_world():
  8. return 'Hello World!'
  9. if __name__ == '__main__':
  10. app.run()

之后运行命令来初始化迁移文件:

  1. python manage.py db init

然后运行命令来将模型的映射添加到文件中:

  1. python manage.py db migrate

最后添加将映射文件真正的映射到数据库中:

  1. python manage.py db upgrade