Flask框架(SQLAlchemy(python3版本)中添加数据 )
安装SQLAlcemy、配置SQLAlcemy、创建模型类可参考:https://blog.****.net/wei18791957243/article/details/85254130
1. 在Flask-SQLAlchemy中,插入、修改、删除操作,均由数据库会话管理。
会话用db.session表示。
2. 在准备把数据写入数据库前,要先将数据添加到会话中然后调用commit()方法提交会话。
数据库会话是为了保证数据的一致性,避免因部分更新导致数据不一致。
提交操作把会话对象全部写入数据库,如果写入过程发生错误,整个会话都会失效。
3. 添加数据
(1)要创建模型类的对象,创建的时候把数据传进入
(2) 然后session记录对象任务 db.session.add(role1) # role1 是模型类对象
如果有多个模型类对象,则一次性保存多个数据
db.session.add_all([us1,us2,us3,us4]) # 保存多个数据,里面是一个列表,列表中是要添加的模型类
(3)最后要提交任务到数据库中 db.session.commit()
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
class Config(object):
"""配置参数"""
SQLALCHEMY_DATABASE_URI = "mysql+mysqlconnector://root:[email protected]:3306/db_python"
SQLALCHEMY_TRACK_MODIFICATIONS = True
app.config.from_object(Config)
db = SQLAlchemy(app)
class Role(db.Model):
"""用户身份表"""
__tablename__ = "tbl_roles"
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(32), unique=True)
user = db.relationship("User", backref="role") # 从模型类中
class User(db.Model):
"""用户表"""
__tablename__ = "tbl_users" # 指明数据库的表名
id = db.Column(db.Integer, primary_key=True) # 整型的主键,会默认设置为自增主键
name = db.Column(db.String(64), unique=True)
email = db.Column(db.String(128), unique=True)
password = db.Column(db.String(128))
role_id = db.Column(db.Integer, db.ForeignKey("tbl_roles.id")) # 从底层中
if __name__ == '__main__':
'''清除数据库中的所有数据'''
db.drop_all()
'''创建所有表'''
db.create_all()
# 给用户身份表中添加两个数据
'''创建一个对象'''
role1 = Role(name="admin")
'''在Flask-SQLAlchemy中,插入、修改、删除操作,均由数据库会话管理。会话用db.session表示'''
'''session 记录对象任务 '''
db.session.add(role1)
'''提交任务到数据库中'''
db.session.commit()
role2 = Role(name="stuff")
db.session.add(role2)
db.session.commit()
# 给用户表中添加数据
us1 = User(name='wang', email='[email protected]', password='123456', role_id=role1.id)
us2 = User(name='zhang', email='[email protected]', password='452342', role_id=role2.id)
us3 = User(name='chen', email='[email protected]', password='782677', role_id=role2.id)
us4 = User(name='zhou', email='[email protected]', password='858585', role_id=role1.id)
'''一次性添加多条数据'''
db.session.add_all([us1, us2, us3, us4])
db.session.commit()
运行程序之后,打开数据库,就可以看见数据已经添加到数据库了
tbl_roles(用户身份表)
tbl_users(用户信息表)