Flask数据库——SQLAlchemy

1、Flask-SQLAlchemy初始化

SQLAlchemy作为操作关系型数据库的对象关系映射框架，必需要进行必要的初始化配置后才能使用。在Flask-SQLAlchemy中，插入、修改、删除操作均由数据库会话管理，会话用db.session表示。在准备把数据写入数据库前，要先将数据添加到会话中，然后调用commit（）方法提交会话。在python3中数据库的配置文件如下：

### config.py
USERNAME = 'root'   # 登录账号
PASSWORD = 'root'   # 登录密码
HOST = '127.0.0.1'  # 设置主机地址
PORT = '3306'      # 设置端口号
DATABASE = 'db_demol'  # 设置访问数据库名称
# 创建数据库连接URL
DB_URL = 'MySQL+pyMySQL://{}:{}@{}:/{}?charset=utf8'.format(USERNAME,PASSWORD,HOST,PORT,DATABASE)
SQLALCHEMY_DATABASE_URL = DB_URL
# 动态追踪修改设置，如若未设置会出现警告
SQLALCHEMY_TRACK_MODIFICATIONS = False
# 查询时会显示原始SQL语句
SQLALCHEMY_ECHO = True

### 初始化实例  db_demo1.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个对象
db = SQLAlchemy(app)
db.create_all()   # 创建数据库
@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)

2、Flask-SQLAlchemy 模型与表映射方法

### 使用Flask-SQLArchemy框架创建数据库表  app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
from datetime import datetime   # 导入时间模块
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个数据库连接对象
db = SQLAlchemy(app)
class Book(db.Model):
    __tablename__ == 'book'   # 表名
    id = db.Column(db.Integer, primary_key = True, autoincrement = True) # id号
    title = db.Column(db.String(50), nullable = False) # 书名，不能为空
    price = db.Column(db.String(50), nullable = False) # 价格，不能为空
    publish_office = db.Column(db.String(100),nullable = False) # 出版社，不能为空
    isbn = db.Colume(db.String(50), nullable = False) # isbn号
    storage_time = db.Column(db.Datetime, default = datetime.now) # 入库时间 

db.create_all()   # 创建数据库
@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)

Flask-SQLAlchemy常用数据类型

类型名称 python类型 描述

Integer int 整型，通常为32位，隐射到数据库中为int类型

SmallInteger int 短整型，通常为16位，隐射到数据库中为int类型

BigInteger int或long 长整型，精度不受限制，隐射到数据库中为int类型

Float float 浮点数，映射到数据库中是float类型

Numeric decimal 定点数

String str 可变长度字符串，映射到数据库中是varchar类型

Text str 可变长度字符串，适合大量文本

Unicode unicode 可变长度Unicode字符串

Boolean bool 布尔值，映射到数据库中是tinyint类型

Date datetime.data 日期类型

Time datetime.time 时间类型

Datetime datatime.datetime 日期时间类型

Interval Datetime.datetime 时间间隔类型

Enum str 字符列表

LargeBinary str 二进制

Flask-SQLAlchemy声明可选参数

可选参数 描述

Primary_key 如果为True，该列为表的主键

unique 如果为True，该列不允许有相同的值

index 如果为True，为提高查询效率，为该列创建索引

nullable 如果为True， 该列允许为空

default 定义该列的默认值

3、数据的增、删、改、查

3.1 数据添加

### 使用Flask-SQLArchemy框架创建数据库表  app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
from datetime import datetime   # 导入时间模块
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个数据库连接对象
db = SQLAlchemy(app)
class Book(db.Model):   # 建立表
    __tablename__ == 'book'   # 表名
    id = db.Column(db.Integer, primary_key = True, autoincrement = True) # id号
    title = db.Column(db.String(50), nullable = False) # 书名，不能为空
    publish_office = db.Column(db.String(100),nullable = False) # 出版社，不能为空
    price = db.Column(db.String(50), nullable = False) # 价格，不能为空
    isbn = db.Colume(db.String(50), nullable = False) # isbn号
    storage_time = db.Column(db.Datetime, default = datetime.now) # 入库时间 
db.create_all()   # 创建数据库

### 添加数据
@app.route('/add')
def add():
    book1 = Book（title = 'ppython基础教程', publish_office = '清华大学出版社', price = '68.30', isbn = '9787115466419')  # 定义book1对象
    db.session.add(book1)
    db.session.commit()
    return '添加数据成功'

@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)

3.2 数据查询

### 查询数据
@app.route('/select')
def select():
    result_1 = Book.query.filter(Book.id == '1').first()
    result_2 = Book.query.filter(Book.publish_office == '人民邮电出版社').all()
    print(result_1)
    print(result_2)
    return '查询数据成功'

3.3 数据修改

### 修改数据
@app.route('/select')
def select():
    result = Book.query.filter(Book.id == '1').first()
    result.price = 130
    db.session.commit()
    return '修改数据成功'

3.4 数据删除

### 删除数据
@app.route('/select')
def select():
    result = Book.query.filter(Book.id == '5').first()
    db.session.delete(result)
    db.session.commit()
    return '删除数据成功'

4、使用Flask-SQLAlchemy 创建一对一的关系表

数据库实体之间有3种关联关系：一对一，一对多和多对多。一个学生只有一个身份证号码，构成了一对一关系；一个班级有多个学生，构成了一对多的关系；一个学生可以选修多门课程，一门课程对应多门课程，学生与课程之间就构成了多对多的关系。

### 使用Flask-SQLArchemy创建一对一关系  app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
from datetime import datetime   # 导入时间模块
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个数据库连接对象
db = SQLAlchemy(app)
# 定义用户表
class User(db.Model):  # 定义表
    __tablename__ == 'user'   # 表名
    id = db.Column(db.Integer, primary_key = True, autoincrement = True) # id号
    username = db.Column(db.String(50), nullable = False) # 用户名，不能为空
    password = db.Column(db.String(50), nullable = False) # 密码，不能为空
    phone = db.Column(db.String(11),nullable = False) # 电话号码，不能为空
    email = db.Colume(db.String(30), nullable = False) # 邮箱
    reg_time = db.Column(db.Datetime, default = datetime.now) # 注册时间 

# 定义借书证表
class Lib_card(db.Model):
    __tablename__ == 'lib_card'   # 表名
    id = db.Column(db.Integer, primary_key = True, autoincrement = True) # id号
    card_id = db.Column(db.Integer, nullable = False) # 借书证id，不能为空
    borrow_reg_time = db.Column(db.Datetime, default = datetime.now) # 证件办理时间，不能为空
    user_id = db.Column(db.Integer, db.ForeignKey('user.id')) # 不能为空
    users = db.relationship('User', backref = db.backref('cards'), uselist = False)

db.create_all()   # 创建数据库
### 添加数据
@app.route('/add')
def add():
    # 添加两条用户数据
    user1 = User（username = '张三', password = 'zhangsan', phone = '18788888888', email = '123@qq.com')  # user1对象
    user2 = User（username = '李四', password = 'lisi', phone = '18766666666', email = '456@qq.com')  # user2对象
    db.session.add(user1)
    db.session.add(user2)
    # 添加两条借书证数据
    card1 = Lib_card（card_id = '2180501001', user_id = '1')  # card1对象
    card2 = Lib_card（card_id = '2180501002', user_id = '2')  # card2对象
    db.session.add(card1)
    db.session.add(card2)
    db.session.commit()
    return '添加数据成功'
@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)

5、使用Flask-SQLAlchemy创建一对多的关系表

### 使用Flask-SQLArchemy创建一对多关系  app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
from datetime import datetime   # 导入时间模块
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个数据库连接对象
db = SQLAlchemy(app)
# 定义用户表
# 定义模型类-作者类
class Writer(db.Model):  # 定义表
    __tablename__ == 'writer'   # 表名
    id = db.Column(db.Integer, primary_key = True) # id号
    name = db.Column(db.String(50), nullable = False) # 作者名，不能为空
    # 设置relationship属性方法，建立模型关系，第一个参数为多方模型的类名，添加backref可以实现多对一的反向查询
    books = db.relationship('Book', backref = 'writers')  

# 定义模型类-图书类
class Book(db.Model):
    __tablename__ == 'books'   # 表名
    id = db.Column(db.Integer, primary_key = True) # id号
    title = db.Column(db.String(50), nullable = False) # 书名，不能为空
    publish_office = db.Column(db.String(100),nullable = False) # 出版社，不能为空
    isbn = db.Colume(db.String(50), nullable = False) # isbn号
    writer_id = db.Column(db.Integer, db.ForeignKey('wrieter.id'))
db.create_all()   # 创建表
### 添加数据
@app.route('/add')
def add():
    # 添加两条作者数据
    user1 = Writer（name = '张三')  # writer1对象
    user2 = Writer（name = '李四')  # writer2对象
    db.session.add(user1)
    db.session.add(user2)
    # 添加两条图书数据
    book1 = Lib_card（title = '名师带你学习', publish_office = '清华大学出版社'，isbn = '26567585664', writer_id = '1')  # book1对象
    book2 = Lib_card（title = '我要奋斗', publish_office = '清华大学出版社'，isbn = '45217585361', writer_id = '1')  # book2对象
    book3 = Lib_card（title = '我要努力', publish_office = '人民邮电出版社'，isbn = '36897983261', writer_id = '2')  # book3对象
    db.session.add(book1)
    db.session.add(book2)
    db.session.add(book3)
    db.session.commit()
    return '添加数据成功'
@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)

6、使用Flask-SQLAlchemy创建多对多的关系表

处理多对多表问题时，解决方法是添加第3张表，这个表称为关联表或中间表。数据库中的多对多关联关系一般需要采用中间表的方式处理，将多对多转化为两个一对多。

### 使用Flask-SQLArchemy创建多对多关系  app.py
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config
from datetime import datetime   # 导入时间模块
app = Flask(__name__)
app.config.from_object(config)  # 初始化配置文件
# 初始化一个数据库连接对象
db = SQLAlchemy(app)

# 定义关联表
book_tag = db.Table('book_tag', db.Column('book_id', db.Integer, db.ForeignKey('book.id'),primary_key = True), db.Column('tag_id', db.Integer, db.ForeignKey('shelfing.id'), primary_Key = True))


# 定义模型类-图书类
class Book(db.Model):  # 定义表
    __tablename__ == 'book'   # 表名
    id = db.Column(db.Integer, primary_key = True, autoincrement = True) # id号
    name = db.Column(db.String(50), nullable = False) # 定义书名，不能为空
    # 设置relationship属性方法，建立模型关系，第一个参数为多方模型的类名，secondary代表中间表，添加backref可以实现多对一的反向查询
    tags = db.relationship('Shelfing', secondary = book_tag, backref =db.backref('books'))  

# 定义模型类-图书上架的标签类
class Shelfing(db.Model):
    __tablename__ == 'shelfing'   # 表名
    id = db.Column(db.Integer, primary_key = True, nullable = False) # id号
    tag = db.Column(db.String(50), nullable = False) # 定义tag字段，不能为空

db.create_all()   # 创建表
@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    app.run(debug=True)