1. 背景介绍

SQLAlchemy 以 ORM 为核心基础提供可选对象关系映射能力。

(1). ORM 提供一个附加的配置层，允许用户自定义的 Python 类进行对象关系映射，通过 session 会话与数据库进行交互。

(2). ORM 扩展了核心级别的 SQL 表达式语言，允许按照用户定义的对象组合和调用 SQL 查询。

(3). Flask-SQLAlchemy 使用起来非常有趣，对于基本应用十分容易使用，并且对于大型项目易于扩展。

(4). 常见情况下对于只有一个 Flask 应用，所有您需要做的事情就是创建 Flask 应用。

(5). 选择加载配置接着创建 SQLAlchemy 对象时候把 Flask 应用传递给它作为参数。

2. 注意事项

连接 mysql 的 client 如果没有安装成功，需要手动来安装对应 python 版本的 mysqlclient.***.whl 文件。

3. 安装依赖

使用 pip 安装以下依赖模块

python -m pip install flask==1.1.2python -m pip install flask_migrate==2.7.0python -m pip install flask_sqlalchemypython -m pip install flask_script

4. 实战代码

今天的分享将通过简单的增删改查来演示 ORM 的效果。

代码如下：

from flask import Flaskfrom flask_sqlalchemy import SQLAlchemyfrom flask_migrate import MigrateCommandfrom flask_migrate import Migratefrom flask_script import Manager,Server#实例化一个Flask 对象app = Flask(__name__)#设置连接数据库的配置,这是以mysql db 为示例来讲解app.config['SQLALCHEMY_DATABASE_URI']="mysql://root:test@127.0.0.1:3306/dbtest1"#如果设置为True,将跟踪对象的修改并发出信号，默认设置为Noneapp.config['SQLALCHEMY_TRACK_MODIFICATIONS']=False#查询时会显示原始SQL语句app.config['SQLALCHEMY_ECHO']=True#这个对象就包含 sqlalchemy 和 sqlalchemy.orm 中的所有函数和助手db = SQLAlchemy(app)manager = Manager(app)Migrate(app,db)#创建数据库映射命令manager.add_command('db',MigrateCommand)#创建启动命令manager.add_command('start',Server(port=8000,use_debugger=True))class Role(db.Model):#提供一个名为 Model 的类，用于作为声明模型时的 delarative 基类    __tablename__ = 'roles' #给表起名    id = db.Column(db.Integer,primary_key=True)    name = db.Column(db.String(64),unique=True)    us = db.relationship("User",backref="role")    icon = db.Column(db.String(40),default='default.jpg')    def __repr__(self):#用于显示一个可读字符串        return "Role:%s" %self.nameclass User(db.Model):    __tablename__ = 'users' #给表起名    id=db.Column(db.Integer,primary_key=True)    name = db.Column(db.String(64),unique=True,index=True)    email = db.Column(db.String(64),unique=True)    pswd = db.Column(db.String(64))    role_id=db.Column(db.Integer,db.ForeignKey('roles.id'))    def __repr__(self):        return "User:%s"% self.nameif __name__ == '__main__':    # db.drop_all() # db 对象调用 SQLAlchemy.drop_all() 方法来删除表:    # db.create_all() # db 对象调用 SQLAlchemy.create_all() 方法来创建表:    # manager.run()    #创建    role1=Role(name="admin")    role2=Role(name="test")    db.session.add(role1)    db.session.commit()    db.session.add(role2)    db.session.commit() #必须提交会话，但是没有必要在每个请求后删除它(session)，Flask-SQLAlchemy 会帮您完成删除操作    user1=User(name="wang",email="test1@126.com",pswd="1234",role_id=role1.id)    user2=User(name="test",email="test2@126.com",pswd="1234",role_id=role2.id)    db.session.add_all([user1,user2])    db.session.commit()    #查询    user1=User.query.filter_by(name="wang")    roles=Role.query.all()    for role in roles:        print(role.name,role.id)    #删除    user=User.query.first()    db.session.delete(user)    db.session.commit()    print(User.query.all())    print("*")    print(user)    #更新    user=User.query.first()    user.name="test"    db.session.commit()    print(User.query.first())