Flask-SQLAlchemy 使用

安装

pip install flask-sqlalchemy
pip install MySQL-python

需要先安装mysql开发库的。

使用

创建SQLALchemy 对象， 然后再 绑定Flask文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

from flask_sqlalchemy import SQLALchemy
from flask import Flask
app = Flask(__name__)
db = SQLALchemy()
db.init_app(app)

指定SQLALchemy URI文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname>"

定义模型

使用 ORM 就肯定要定义对象的文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

class Users(db.Model):
    __tablename__ = 'users'

    id = db.Column(db.Integer, primary_key=True)
    email = db.Column(db.String, unique=True)
    username = db.Column(db.String, unique = True)
    passwd = db.Column(db.String)
    date = db.Column(db.DateTime)


class Users_detail(db.Model):
    __tablename__ = 'users_detail'

    id = db.Column(db.Integer, primary_key=True)
    uid = db.Column(db.Integer,unique=True)
    age = db.Column(db.Integer)
    sex = db.Column(db.SmallInteger)
    location = db.Column(db.String)
    intro = db.Column(db.Text)
    todo = db.Column(db.Text)
    modifytime = db.Column(db.DateTime)
    inserttime = db.Column(db.DateTime)

从这两个例子可以看到，定义一列是需要使用 db.Column 的，然后需要指定数据类型，还有列的选项，常用的数据类型有：文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

而一些常用的 SQLAlchemy文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

数据库操作

数据库的操作不外乎就是增删改查，所以这里就介绍一下增删改查怎么做，和其他 ORM（例如 MongoEngine） 不一样，SQLAlchemy使用之前需要先创建表和数据库才能操作数据。 所以第一步是创建表：文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

$ python app.py shell
    >>> from app import db
    >>> db.create_all()

插入数据文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

from app import db, Users, Users_detail
from datetime import datetime
user = User(email='ttlsa@ttlsa.com',username='ttlsa',passwd='ttlsa',date=datetime.now())
user_detail = Users_detail(XXXXX)  #自己补齐去吧

# 下面这个很重要
db.session.add(user)
db.session.add(user_detail)
db.session.commit()

这里需要提一下的就是 db.session，这个 session 是数据库中 事务的含义，因此我们可以提交修改数据，也可以回滚取消修改。文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

修改数据文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

users = Users(username="ttlsa2")
db.session.add(user)
db.session.commit()

修改只需要修改属性并提交就行了。文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

删除数据文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

db.session.delete()
db.session.commit()

删除数据直接调用 delete 方法即可，记得 commit。文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

查询数据文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

查询数据稍微复杂一下文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

• 获得查询对象
• 添加过滤条件
• 如果还有其他分组之类的，继续添加

Users.query.all()
Users.query.filter_by(id=1)

这里的 filter_by 叫做过滤器，常用的过滤器有文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

如果后面不加.all()，那么其实是不会真正到数据库执行的，类似 all 的执行器还有很多，常用的有：文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/

获取更多可以查看 《SQLAlchemy QueryAPI》文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/ 文章源自运维生存时间-https://www.ttlsa.com/python/flask-sqlalchemy-using/