首页 注册 登录
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
CicadaMan
V2EX  ›  Flask

flask 系列教程（ 3）—SQLAlchemy 数据库

  •   
  •   CicadaMan · 2017-07-20 19:46:35 +08:00 · 6033 次点击
    这是一个创建于 2681 天前的主题，其中的信息可能已经有所发展或是发生改变。

    数据库是一个网站的基础，在Flask中可以自由的使用MySQL、PostgreSQL、SQLite、Redis、MongoDB来写原生的语句实现功能，也可以使用更高级别的数据库抽象方式，如SQLAlchemy或MongoEngine这样的OR(D)M。本教程以MySQL+SQLAlchemy的组合来进行讲解。

    在讲解Flask中的数据库操作之前，先确保你已经安装了以下软件：

    • mysql：如果是在windows上，到官网下载。如果是ubuntu，通过命令sudo apt-get install mysql-server libmysqlclient-dev -yq进行下载安装。
    • MySQLdb：MySQLdb是用Python来操作mysql的包，因此通过pip来安装，命令如下：pip install mysql-python。
    • SQLAlchemy：SQLAlchemy是一个数据库的 ORM 框架，我们在后面会用到。安装命令为：pip install SQLAlchemy。
    通过SQLAlchemy连接数据库：

    首先来看一段代码：

    from sqlalchemy import create_engine

# 数据库的配置变量
HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = 'xt_flask'
USERNAME = 'root'
PASSWORD = 'root'
DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)

# 创建数据库引擎
engine = create_engine(DB_URI)

#创建连接
with engine.connect() as con:
  rs = con.execute('SELECT 1')
  print rs.fetchone()

    首先从sqlalchemy中导入create_engine，用这个函数来创建引擎，然后用engine.connect()来连接数据库。其中一个比较重要的一点是，通过create_engine函数的时候，需要传递一个满足某种格式的字符串，对这个字符串的格式来进行解释：

    dialect+driver://username:password@host:port/database

    dialect是数据库的实现，比如MySQL、PostgreSQL、SQLite，并且转换成小写。driver是Python对应的驱动，如果不指定，会选择默认的驱动，比如 MySQL 的默认驱动是MySQLdb。username是连接数据库的用户名，password是连接数据库的密码，host是连接数据库的域名，port是数据库监听的端口号，database是连接哪个数据库的名字。

    如果以上输出了1，说明SQLAlchemy能成功连接到数据库。

    用 SQLAlchemy 执行原生 SQL：

    我们将上一个例子中的数据库配置选项单独放在一个constants.py的文件中，看以下例子：

    from sqlalchemy import create_engine
from constants import DB_URI

#连接数据库
engine = create_engine(DB_URI,echo=True)

# 使用 with 语句连接数据库，如果发生异常会被捕获
with engine.connect() as con:
  # 先删除 users 表
  con.execute('drop table if exists users')
  # 创建一个 users 表，有自增长的 id 和 name
  con.execute('create table users(id int primary key auto_increment,'
  'name varchar(25))')
  # 插入两条数据到表中
  con.execute('insert into users(name) values("xiaoming")')
  con.execute('insert into users(name) values("xiaotuo")')
  # 执行查询操作
  rs = con.execute('select * from users')
  # 从查找的结果中遍历
  for row in rs:
    print row
    使用 ORM：

    随着项目越来越大，采用写原生 SQL 的方式在代码中会出现大量的 SQL 语句，那么问题就出现了：

    1. SQL 语句重复利用率不高，越复杂的 SQL 语句条件越多，代码越长。会出现很多相近的 SQL 语句。
    2. 很多 SQL 语句是在业务逻辑中拼出来的，如果有数据库需要更改，就要去修改这些逻辑，这会很容易漏掉对某些 SQL 语句的修改。
    3. 写 SQL 时容易忽略 web 安全问题，给未来造成隐患。

    ORM，全称Object Relational Mapping，中文叫做对象关系映射，通过ORM我们可以通过类的方式去操作数据库，而不用再写原生的 SQL 语句。通过把表映射成类，把行作为示例，把字段作为属性，ORM在执行对象操作的时候最终还是会把对应的操作转换为数据库原生语句。使用ORM有许多优点：

    1. 易用性：使用ORM做数据库的开发可以有效的减少重复 SQL 语句的概率，写出来的模型也更加直观、清晰。
    2. 性能损耗小：ORM转换成底层数据库操作指令确实会有一些开销。但从实际的情况来看，这种性能损耗很少（不足 5%），只要不是对性能有严苛的要求，综合考虑开发效率、代码的阅读性，带来的好处要远远大于性能损耗，而且项目越大作用越明显。
    3. 设计灵活：可以轻松的写出复杂的查询。
    4. 可移植性：SQLAlchemy封装了底层的数据库实现，支持多个关系数据库引擎，包括流行的MySQL、PostgreSQL和SQLite。可以非常轻松的切换数据库。

    使用 SQLAlchemy：要使用ORM来操作数据库，首先需要创建一个类来与对应的表进行映射。现在以User 表来做为例子，它有自增长的 id、name、fullname、password这些字段，那么对应的类为：

    from sqlalchemy import Column,Integer,String
from constants import DB_URI
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base

engine = create_engine(DB_URI,echo=True)

# 所有的类都要继承自`declarative_base`这个函数生成的基类
Base = declarative_base(engine)
class User(Base):
  # 定义表名为 users
  __tablename__ = 'users'

  # 将 id 设置为主键，并且默认是自增长的
  id = Column(Integer,primary_key=True)
  # name 字段，字符类型，最大的长度是 50 个字符
  name = Column(String(50))
  fullname = Column(String(50))
  password = Column(String(100))

  # 让打印出来的数据更好看，可选的
  def __repr__(self):
    return "<User(id='%s',name='%s',fullname='%s',password='%s')>" % (self.id,self.name,self.fullname,self.password)

    SQLAlchemy会自动的设置第一个Integer的主键并且没有被标记为外键的字段添加自增长的属性。因此以上例子中id自动的变成自增长的。以上创建完和表映射的类后，还没有真正的映射到数据库当中，执行以下代码将类映射到数据库中：

    Base.metadata.create_all()

    在创建完数据表，并且做完和数据库的映射后，接下来让我们添加数据进去：

    ed_user = User(name='ed',fullname='Ed Jones',password='edspassword')
# 打印名字
print ed_user.name
> ed
# 打印密码
print ed_user.password
> edspassword
# 打印 id
print ed_user.id
> None

    可以看到，name 和 password 都能正常的打印，唯独id为None，这是因为id是一个自增长的主键，还未插入到数据库中，id是不存在的。接下来让我们把创建的数据插入到数据库中。和数据库打交道的，是一个叫做Session的对象：

    from sqlalchemy.orm import sessionmaker
Session = sessionmaker(bind=engine)
# 或者
# Session = sessionmaker()
# Session.configure(bind=engine)
session = Session()
ed_user = User(name='ed',fullname='Ed Jones',password='edspassword')
session.add(ed_user)

    现在只是把数据添加到session中，但是并没有真正的把数据存储到数据库中。如果需要把数据存储到数据库中，还要做一次commit操作：

    session.commit()
# 打印 ed_user 的 id
print ed_user.id
> 1

    这时候，ed_user就已经有 id。 说明已经插入到数据库中了。有人肯定有疑问了，为什么添加到session中后还要做一次commit操作呢，这是因为，在SQLAlchemy的ORM实现中，在做commit操作之前，所有的操作都是在事务中进行的，因此如果你要将事务中的操作真正的映射到数据库中，还需要做commit操作。既然用到了事务，这里就并不能避免的提到一个回滚操作了，那么看以下代码展示了如何使用回滚（接着以上示例代码）：

    # 修改 ed_user 的用户名
ed_user.name = 'Edwardo'
# 创建一个新的用户
fake_user = User(name='fakeuser',fullname='Invalid',password='12345')
# 将新创建的 fake_user 添加到 session 中
session.add(fake_user)
# 判断`fake_user`是否在`session`中存在
print fake_user in session
> True
# 从数据库中查找 name=Edwardo 的用户
tmp_user = session.query(User).filter_by(name='Edwardo')
# 打印 tmp_user 的 name
print tmp_user
# 打印出查找到的 tmp_user 对象，注意这个对象的 name 属性已经在事务中被修改为 Edwardo 了。
> <User(name='Edwardo', fullname='Ed Jones', password='edspassword')>
# 刚刚所有的操作都是在事务中进行的，现在来做回滚操作
session.rollback()
# 再打印 tmp_user
print tmp_user
> <User(name='ed', fullname='Ed Jones', password='edspassword')>
# 再看 fake_user 是否还在 session 中
print fake_user in session
> False

    接下来看下如何进行查找操作，查找操作是通过session.query()方法实现的，这个方法会返回一个Query对象，Query对象相当于一个数组，装载了查找出来的数据，并且可以进行迭代。具体里面装的什么数据，就要看向session.query()方法传的什么参数了，如果只是传一个ORM的类名作为参数，那么提取出来的数据就是都是这个类的实例，比如：

    for instance in session.query(User).order_by(User.id):
print instance
# 输出所有的 user 实例
> <User (id=2,name='ed',fullname='Ed Json',password='12345')>
> <User (id=3,name='be',fullname='Be Engine',password='123456')>

    如果传递了两个及其两个以上的对象，或者是传递的是ORM类的属性，那么查找出来的就是元组，例如：

    for instance in session.query(User.name):
  print instance
# 输出所有的查找结果
> ('ed',)
> ('be',)

    以及：

    for instance in session.query(User.name,User.fullname):
  print instance
# 输出所有的查找结果
> ('ed', 'Ed Json')
> ('be', 'Be Engine')

    或者是：

    for instance in session.query(User,User.name).all():
  print instance
# 输出所有的查找结果
> (<User (id=2,name='ed',fullname='Ed Json',password='12345')>, 'Ed Json')
> (<User (id=3,name='be',fullname='Be Engine',password='123456')>, 'Be Engine')

    另外，还可以对查找的结果（Query）做切片操作：

    for instance in session.query(User).order_by(User.id)[1:3]
  instance

    如果想对结果进行过滤，可以使用filter_by和filter两个方法，这两个方法都是用来做过滤的，区别在于，filter_by是传入关键字参数，filter是传入条件判断，并且filter能够传入的条件更多更灵活，请看以下例子：

    # 第一种：使用 filter_by 过滤：
for name in session.query(User.name).filter_by(fullname='Ed Jones'):
  print name
# 输出结果：
> ('ed',)

# 第二种：使用 filter 过滤：
for name in session.query(User.name).filter(User.fullname=='Ed Jones'):
  print name
# 输出结果：
> ('ed',)

    Column 常用参数：

    • default：默认值。
    • nullable：是否可空。
    • primary_key：是否为主键。
    • unique：是否唯一。
    • autoincrement：是否自动增长。
    • name：该属性在数据库中的字段映射。

    sqlalchemy 常用数据类型：

    • Integer：整形。
    • Boolean：传递True/False进去。
    • Date：传递datetime.date()进去。
    • DateTime：传递datetime.datetime()进去。
    • Float：浮点类型。
    • String：字符类型，使用时需要指定长度，区别于Text类型。
    • Text：文本类型。
    • Time：传递datetime.time()进去。

    过滤条件：过滤是数据提取的一个很重要的功能，以下对一些常用的过滤条件进行解释，并且这些过滤条件都是只能通过filter方法实现的：

    • equals：
    query.filter(User.name == 'ed')
    • not equals:
    query.filter(User.name != 'ed')
    • like：
    query.filter(User.name.like('%ed%'))
    • in：
    query.filter(User.name.in_(['ed','wendy','jack']))
# 同时，in 也可以作用于一个 Query
query.filter(User.name.in_(session.query(User.name).filter(User.name.like('%ed%'))))
    • not in：
    query.filter(~User.name.in_(['ed','wendy','jack']))
    • is null：
    query.filter(User.name==None)
# 或者是
query.filter(User.name.is_(None))
    • is not null:
    query.filter(User.name != None)
# 或者是
query.filter(User.name.isnot(None))
    • and：
    from sqlalchemy import and_
query.filter(and_(User.name=='ed',User.fullname=='Ed Jones'))
# 或者是传递多个参数
query.filter(User.name=='ed',User.fullname=='Ed Jones')
# 或者是通过多次 filter 操作
query.filter(User.name=='ed').filter(User.fullname=='Ed Jones')
    • or：
    from sqlalchemy import or_ query.filter(or_(User.name=='ed',User.name=='wendy'))

    查找方法：介绍完过滤条件后，有一些经常用到的查找数据的方法也需要解释一下：

    • all()：返回一个Python列表（list）：
    query = session.query(User).filter(User.name.like('%ed%').order_by(User.id)
# 输出 query 的类型
print type(query)
> <type 'list'>
# 调用 all 方法
query = query.all()
# 输出 query 的类型
print type(query)
> <class 'sqlalchemy.orm.query.Query'>
    • first()：返回Query中的第一个值：
    user = session.query(User).first()
print user
> <User(name='ed', fullname='Ed Jones', password='f8s7ccs')>
    • one()：查找所有行作为一个结果集，如果结果集中只有一条数据，则会把这条数据提取出来，如果这个结果集少于或者多于一条数据，则会抛出异常。总结一句话：有且只有一条数据的时候才会正常的返回，否则抛出异常：
    # 多于一条数据
user = query.one()
> Traceback (most recent call last):
> ...
> MultipleResultsFound: Multiple rows were found for one()
# 少于一条数据
user = query.filter(User.id == 99).one()
> Traceback (most recent call last):
> ...
> NoResultFound: No row was found for one()
# 只有一条数据
> query(User).filter_by(name='ed').one()

    • one_or_none()：跟one()方法类似，但是在结果集中没有数据的时候也不会抛出异常。

    • scalar()：底层调用one()方法，并且如果one()方法没有抛出异常，会返回查询到的第一列的数据：

    session.query(User.name,User.fullname).filter_by(name='ed').scalar()

    文本 SQL：SQLAlchemy还提供了使用文本 SQL的方式来进行查询，这种方式更加的灵活。而文本 SQL 要装在一个text()方法中，看以下例子：

    from sqlalchemy import text
for user in session.query(User).filter(text("id<244")).order_by(text("id")).all():
  print user.name

    如果过滤条件比如上例中的 244 存储在变量中，这时候就可以通过传递参数的形式进行构造：

    session.query(User).filter(text("id<:value and name=:name")).params(value=224,name='ed').order_by(User.id)

    在文本 SQL 中的变量前面使用了:来区分，然后使用params方法，指定需要传入进去的参数。另外，使用from_statement方法可以把过滤的函数和条件函数都给去掉，使用纯文本的 SQL:

    sesseion.query(User).from_statement(text("select * from users where name=:name")).params(name='ed').all()

    使用from_statement方法一定要注意，from_statement返回的是一个text里面的查询语句，一定要记得调用all()方法来获取所有的值。

    计数（ Count ）：Query对象有一个非常方便的方法来计算里面装了多少数据：

    session.query(User).filter(User.name.like('%ed%')).count()

    当然，有时候你想明确的计数，比如要统计users表中有多少个不同的姓名，那么简单粗暴的采用以上count是不行的，因为姓名有可能会重复，但是处于两条不同的数据上，如果在原生数据库中，可以使用distinct关键字，那么在SQLAlchemy中，可以通过func.count()方法来实现：

    from sqlalchemy import func
session.query(func.count(User.name),User.name).group_by(User.name).all()
# 输出的结果
> [(1, u'ed'), (1, u'fred'), (1, u'mary'), (1, u'wendy')]

    另外，如果想实现select count(*) from users，可以通过以下方式来实现：

    session.query(func.count(*)).select_from(User).scalar()

    当然，如果指定了要查找的表的字段，可以省略select_from()方法：

    session.query(func.count(User.id)).scalar()

    表关系：表之间的关系存在三种：一对一、一对多、多对多。而SQLAlchemy中的ORM也可以模拟这三种关系。因为一对一其实在SQLAlchemy中底层是通过一对多的方式模拟的，所以先来看下一对多的关系：

    • 一对多：拿之前的User表为例，假如现在要添加一个功能，要保存用户的邮箱帐号，并且邮箱帐号可以有多个，这时候就必须创建一个新的表，用来存储用户的邮箱，然后通过user.id来作为外键进行引用，先来看下邮箱表的实现：
    from sqlalchemy import ForeignKey
from sqlalchemy.orm import relationship

class Address(Base):
__tablename__ = 'address'
id = Column(Integer,primary_key=True)
email_address = Column(String,nullable=False)
# User 表的外键，指定外键的时候，是使用的是数据库表的名称，而不是类名
user_id = Column(Integer,ForeignKey('users.id'))
# 在 ORM 层面绑定两者之间的关系，第一个参数是绑定的表的类名，
# 第二个参数 back_populates 是通过 User 反向访问时的字段名称
user = relationship('User',back_populates="addresses")

def __repr__(self):
return "<Address(email_address='%s')>" % self.email_address

# 重新修改 User 表，添加了 addresses 字段，引用了 Address 表的主键
class User(Base):
  __tablename__ = 'users'
  id = Column(Integer,primary_key=True)
  name = Column(String(50))
  fullname = Column(String(50))
  password = Column(String(100))
  # 在 ORM 层面绑定和`Address`表的关系
  addresses = relationship("Address",order_by=Address.id,back_populates="user")

    其中，在User表中添加的addresses字段，可以通过User.addresses来访问和这个 user 相关的所有 address。在Address表中的user字段，可以通过Address.use来访问这个 user。达到了双向绑定。表关系已经建立好以后，接下来就应该对其进行操作，先看以下代码：

    jack = User(name='jack',fullname='Jack Bean',password='gjffdd')
jack.addresses = [Address(email_address='[email protected]'),
Address(email_address='[email protected]')]
session.add(jack)
session.commit()

    首先，创建一个用户，然后对这个jack用户添加两个邮箱，最后再提交到数据库当中，可以看到这里操作Address并没有直接进行保存，而是先添加到用户里面，再保存。

    • 一对一：一对一其实就是一对多的特殊情况，从以上的一对多例子中不难发现，一对应的是User表，而多对应的是Address，也就是说一个User对象有多个Address。因此要将一对多转换成一对一，只要设置一个User对象对应一个Address对象即可，看以下示例：
    class User(Base):
  __tablename__ = 'users'
  id = Column(Integer,primary_key=True)
  name = Column(String(50))
  fullname = Column(String(50))
  password = Column(String(100))
  # 设置 uselist 关键字参数为 False
  addresses = relationship("Address",back_populates='addresses',uselist=False)
class Address(Base):
  __tablename__ = 'addresses'
  id = Column(Integer,primary_key=True)
  email_address = Column(String(50))
  user_id = Column(Integer,ForeignKey('users.id')
  user = relationship('Address',back_populates='user')

    从以上例子可以看到，只要在User表中的addresses字段上添加uselist=False就可以达到一对一的效果。设置了一对一的效果后，就不能添加多个邮箱到user.addresses字段了，只能添加一个：

    user.addresses = Address(email_address='[email protected]')
    • 多对多：多对多需要一个中间表来作为连接，同理在sqlalchemy中的orm也需要一个中间表。假如现在有一个Teacher和一个Classes表，即老师和班级，一个老师可以教多个班级，一个班级有多个老师，是一种典型的多对多的关系，那么通过sqlalchemy的ORM的实现方式如下：
    association_table = Table('teacher_classes',Base.metadata,
Column('teacher_id',Integer,ForeignKey('teacher.id')),
Column('classes_id',Integer,ForeignKey('classes.id'))
)
class Teacher(Base):
  __tablename__ = 'teacher'
  id = Column(Integer,primary_key=True)
  tno = Column(String(10))
  name = Column(String(50))
  age = Column(Integer)
  classes = relationship('Classes',secondary=association_table,back_populates='teachers')
class Classes(Base):
  __tablename__ = 'classes'
  id = Column(Integer,primary_key=True)
  cno = Column(String(10))
  name = Column(String(50))
  teachers = relationship('Teacher',secondary=association_table,back_populates='classes')

    要创建一个多对多的关系表，首先需要一个中间表，通过Table来创建一个中间表。上例中第一个参数teacher_classes代表的是中间表的表名，第二个参数是Base的元类，第三个和第四个参数就是要连接的两个表，其中Column第一个参数是表示的是连接表的外键名，第二个参数表示这个外键的类型，第三个参数表示要外键的表名和字段。 创建完中间表以后，还需要在两个表中进行绑定，比如在Teacher中有一个classes属性，来绑定Classes表，并且通过secondary参数来连接中间表。同理，Classes表连接Teacher表也是如此。定义完类后，之后就是添加数据，请看以下示例：

    teacher1 = Teacher(tno='t1111',name='xiaotuo',age=10)
teacher2 = Teacher(tno='t2222',name='datuo',age=10)
classes1 = Classes(cno='c1111',name='english')
classes2 = Classes(cno='c2222',name='math')
teacher1.classes = [classes1,classes2]
teacher2.classes = [classes1,classes2]
classes1.teachers = [teacher1,teacher2]
classes2.teachers = [teacher1,teacher2]
session.add(teacher1)
session.add(teacher2)
session.add(classes1)
session.add(classes2)

    查询高级：

    • join：join查询分为两种，一种是inner join，另一种是ouoter join。默认的是inner join，如果指定left join或者是right join则为outer join。如果想要查询User及其对应的Address，则可以通过以下方式来实现：
    for u,a in session.query(User,Address).filter(User.id==Address.user_id).all():
  print u
  print a
# 输出结果：
> <User (id=1,name='ed',fullname='Ed Jason',password='123456')>
> <Address id=4,[email protected],user_id=1>

    这是通过普通方式的实现，也可以通过join的方式实现，更加简单：

    for u,a in session.query(User,Address).join(Address).all():
  print u
  print a
# 输出结果：
> <User (id=1,name='ed',fullname='Ed Jason',password='123456')>
> <Address id=4,[email protected],user_id=1>

    当然，如果采用outerjoin，可以获取所有user，而不用在乎这个user是否有address对象，并且outerjoin默认为左外查询：

    for instance in session.query(User,Address).outerjoin(Address).all():
  print instance
# 输出结果：
(<User (id=1,name='ed',fullname='Ed Jason',password='123456')>, <Address id=4,[email protected],user_id=1>)
(<User (id=2,name='xt',fullname='xiaotuo',password='123')>, None)
    • 别名：当多表查询的时候，有时候同一个表要用到多次，这时候用别名就可以方便的解决命名冲突的问题了：
    from sqlalchemy.orm import aliased
adalias1 = aliased(Address)
adalias2 = aliased(Address)
for username,email1,email2 in         session.query(User.name,adalias1.email_address,adalias2.email_address).join(adalias1).join(adalias2).all():
  print username,email1,email2
    • 子查询：sqlalchemy也支持子查询，比如现在要查找一个用户的用户名以及该用户的邮箱地址数量。要满足这个需求，可以在子查询中找到所有用户的邮箱数（通过 group by 合并同一用户），然后再将结果放在父查询中进行使用：
    from sqlalchemy.sql import func
# 构造子查询
stmt = session.query(Address.user_id.label('user_id'),func.count(*).label('address_count')).group_by(Address.user_id).subquery()
# 将子查询放到父查询中
for u,count in session.query(User,stmt.c.address_count).outerjoin(stmt,User.id==stmt.c.user_id).order_by(User.id):
  print u,count

    从上面我们可以看到，一个查询如果想要变为子查询，则是通过subquery()方法实现，变成子查询后，通过子查询.c属性来访问查询出来的列。以上方式只能查询某个对象的具体字段，如果要查找整个实体，则需要通过aliased方法，示例如下：

    stmt = session.query(Address)
adalias = aliased(Address,stmt)
for user,address in session.query(User,stmt).join(stmt,User.addresses):
  print user,address

    删除数据： 删除数据有两种情况，一种是不指定cascade，另一种是指定cascade。如果不指定cascade，那么在删除父数据的时候会保留子数据，还是拿User表和Address两个表来做示例：

    ed_user = session.query(User).filter(User.name=='ed').first()
session.delete(ed_user)
session.commit()

    以上这种方式把user数据删除后，如果address表中还对应了一些邮箱，那么将会保留，并且将user_id设置为NULL。另外一种情况，可以指定cascade为all，只要user这个对象删除了，子数据也会依次被删除掉：

    xt_user = session.query(User).filter(User.name=='xt').first()
session.delete(xt_user)
    使用 Flask-SQLAlchemy：

    另外一个框架，叫做Flask-SQLAlchemy对SQLAlchemy进行了一个简单的封装，使得我们在flask中使用sqlalchemy更加的简单。可以通过pip install flask-sqlalchemy。使用Flask-SQLAlchemy的流程如下：

    • 数据库初始化：数据库初始化不再是通过create_engine，请看以下示例：
    from flask import Flask
from flask_sqlalchemyu import SQLAlchemy
from constants import DB_URI
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
db = SQLAlchemy(app)
    • ORM类：之前都是通过Base = declarative_base()来初始化一个基类，然后再继承，在Flask-SQLAlchemy中更加简单了（代码依赖以上示例）：
    class User(db.Model):
  id = db.Column(db.Integer,primary_key=True)
  username = db.Column(db.String(80),unique=True)
  email = db.Column(db.String(120),unique=True)
  def __init__(self,username,email):
    self.username = username
    self.email = email
  def __repr__(self):
    return '<User %s>' % self.username
    • 映射模型到数据库表：使用Flask-SQLAlchemy所有的类都是继承自db.Model，并且所有的Column和数据类型也都成为db的一个属性。但是有个好处是不用写表名了，Flask-SQLAlchemy会自动将类名小写化，然后映射成表名。 写完类模型后，要将模型映射到数据库的表中，使用以下代码创建所有的表：
    db.create_all()
    • 添加数据：这时候就可以在数据库中看到已经生成了一个user表了。接下来添加数据到表中：
    admin = User('admin','[email protected]')
guest = User('guest','[email protected]')
db.session.add(admin)
db.session.add(guest)
db.session.commit()

    添加数据和之前的没有区别，只是session成为了一个db的属性。

    • 查询数据：查询数据不再是之前的session.query了，而是将query属性放在了db.Model上，所以查询就是通过Model.query的方式进行查询了：
    users = User.query.all()
# 再如：
admin = User.query.filter_by(username='admin').first()
# 或者：
admin = User.query.filter(User.username='admin').first()
    • 删除数据：删除数据跟添加数据类似，只不过session是db的一个属性而已：
    db.session.delete(admin)
db.session.commit()

    对 Flask 和 Python 感兴趣的，可以加群：482869582。一起讨论和学习哦~~

    目前尚无回复
    userPythonqueryname
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   3293 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 30ms · UTC 12:00 · PVG 20:00 · LAX 04:00 · JFK 07:00
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.