快速入门

Flask-SQLAlchemy 使用起来非常有趣,对于基本应用十分容易使用,并且对于大型项目易于扩展。有关完整的指南,请参阅 SQLAlchemy 的 API 文档。

一个最小应用

常见情况下对于只有一个 Flask 应用,所有您需要做的事情就是创建 Flask 应用,选择加载配置接着创建 SQLAlchemy 对象时候把 Flask 应用传递给它作为参数。

一旦创建,这个对象就包含 sqlalchemysqlalchemy.orm 中的所有函数和助手。此外它还提供一个名为 Model 的类,用于作为声明模型时的 delarative 基类:

  1. from flask import Flask
  2. from flask.ext.sqlalchemy import SQLAlchemy
  3. app = Flask(__name__)
  4. app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:////tmp/test.db'
  5. db = SQLAlchemy(app)
  6. class User(db.Model):
  7. id = db.Column(db.Integer, primary_key=True)
  8. username = db.Column(db.String(80), unique=True)
  9. email = db.Column(db.String(120), unique=True)
  10. def __init__(self, username, email):
  11. self.username = username
  12. self.email = email
  13. def __repr__(self):
  14. return '<User %r>' % self.username

为了创建初始数据库,只需要从交互式 Python shell 中导入 db 对象并且调用 SQLAlchemy.create_all() 方法来创建表和数据库:

  1. >>> from yourapplication import db
  2. >>> db.create_all()

Boom, 您的数据库已经生成。现在来创建一些用户:

  1. >>> from yourapplication import User
  2. >>> admin = User('admin', '[email protected]')
  3. >>> guest = User('guest', '[email protected]')

但是它们还没有真正地写入到数据库中,因此让我们来确保它们已经写入到数据库中:

  1. >>> db.session.add(admin)
  2. >>> db.session.add(guest)
  3. >>> db.session.commit()

访问数据库中的数据也是十分简单的:

  1. >>> users = User.query.all()
  2. [<User u'admin'>, <User u'guest'>]
  3. >>> admin = User.query.filter_by(username='admin').first()
  4. <User u'admin'>

简单的关系

SQLAlchemy 连接到关系型数据库,关系型数据最擅长的东西就是关系。因此,我们将创建一个使用两张相互关联的表的应用作为例子:

  1. from datetime import datetime
  2. class Post(db.Model):
  3. id = db.Column(db.Integer, primary_key=True)
  4. title = db.Column(db.String(80))
  5. body = db.Column(db.Text)
  6. pub_date = db.Column(db.DateTime)
  7. category_id = db.Column(db.Integer, db.ForeignKey('category.id'))
  8. category = db.relationship('Category',
  9. backref=db.backref('posts', lazy='dynamic'))
  10. def __init__(self, title, body, category, pub_date=None):
  11. self.title = title
  12. self.body = body
  13. if pub_date is None:
  14. pub_date = datetime.utcnow()
  15. self.pub_date = pub_date
  16. self.category = category
  17. def __repr__(self):
  18. return '<Post %r>' % self.title
  19. class Category(db.Model):
  20. id = db.Column(db.Integer, primary_key=True)
  21. name = db.Column(db.String(50))
  22. def __init__(self, name):
  23. self.name = name
  24. def __repr__(self):
  25. return '<Category %r>' % self.name

首先让我们创建一些对象:

  1. >>> py = Category('Python')
  2. >>> p = Post('Hello Python!', 'Python is pretty cool', py)
  3. >>> db.session.add(py)
  4. >>> db.session.add(p)

现在因为我们在 backref 中声明了 posts 作为动态关系,查询显示为:

  1. >>> py.posts
  2. <sqlalchemy.orm.dynamic.AppenderBaseQuery object at 0x1027d37d0>

它的行为像一个普通的查询对象,因此我们可以查询与我们测试的 “Python” 分类相关的所有文章(posts):

  1. >>> py.posts.all()
  2. [<Post 'Hello Python!'>]

启蒙之路

您仅需要知道与普通的 SQLAlchemy 不同之处:

  1. SQLAlchemy 允许您访问下面的东西:
  2. Model 声明基类行为类似一个常规的 Python 类,不过有个 query 属性,可以用来查询模型 (ModelBaseQuery)
  3. 您必须提交会话,但是没有必要在每个请求后删除它(session),Flask-SQLAlchemy 会帮您完成删除操作。