实现对数据库的基本操作（增删改查）

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from datetime import datetime

1. python3中MySQLdb报错解决方法 
import pymysql
pymysql.install_as_MySQLdb()

实例化一个app对象
app = Flask(__name__)

 2. 数据库的配置与实例化 
 1.对数据库操作(mysql, redis)
2.用于连接数据的数据库
 

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:[email protected]/UserTest'  "UserTest"是新建数据库名
 如果设置成 True (默认情况), Flask-SQLAlchemy 将会追踪对象的修改并且发送信号。这需要额外的内存, 如果不必要的可以禁用它。
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
### 实例化一个db对象
db = SQLAlchemy(app)

 3. 定义数据库模型
user ==== (id, username, password, email)
class User(db.Model):
    # 默认情况下表名为类的名称, 如果想要重新设置表名,  __tablename__=表名
    __tablename__ = "用户信息"
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(30), unique=True, index=True, nullable=False)  
    # unique=True   用户名不能重复
    # nullable=False 用户名不能为空
    password = db.Column(db.String(20), nullable=False)
    email = db.Column(db.String(20), unique=True, index=True)
    # index=True创建索引, 提升查询效率
    # 设置默认值, 为当前用户的创建时间
    add_time = db.Column(db.DateTime, default=datetime.now())

    create_time1 = db.Column(db.DateTime, default=datetime.now)
    create_time2 = db.Column(db.DateTime, default=datetime.now())
    第一个插入的是期望的, 数据的插入时间, 每条数据插入时可自动根据当前时间生成
    第二条是一个固定的时间, 程序部署的时间, 所有的数据都是这个固定时间
    实际上默认值在mysql数据库没有体现, 都是sqlalchemy在插入数据时加的
    
    
if __name__ == '__main__':
    # 删除所有的表(drop)
    db.drop_all()
    # 创建所有的表(create)
    db.create_all()

# 插入数据(insert)
u1 = User(username="粉条", password="westos", email="[email protected]")
u2 = User(username="粉丝", password="westos", email="[email protected]")
db.session.add(u1)
db.session.add(u2)
db.session.commit()

删除数据(delete)

delete_user = User.query.filter_by(username="粉条").first()
db.session.delete(delete_user)
db.session.commit()

更新数据(update)

#过滤出用户名为“粉丝”信息的第一个结果(此处first方法是取他的第一个信息即id号)
update_user = User.query.filter_by(username="粉丝").first() 
print(update_user)
print("正在更新邮箱地址.......") 
update_user.email = '[email protected]' 
db.session.add(update_user) 
db.session.commit() 
#查看数据(select) 
users = User.query.all() 
print(users) 
user = User.query.first() 
print(user.username) 
print(user.password) 
print(user.email) 
print(user.id)

常用的数据列类型

最常用的SQL列属性选项

多个表的建立,修改,删除,增加（关联型数据库）

from datetime import datetime
from flask import Flask, render_template
from flask_sqlalchemy import SQLAlchemy, Pagination
from flask_bootstrap import Bootstrap
import pymysql
pymysql.install_as_MySQLdb()
from sqlalchemy import desc, func
实例化对象
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:[email protected]/UserTest'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
db = SQLAlchemy(app)

用户和角色是什么关系?
# - 一对一
# - 一对多: 角色是一, 用户是多, 外键写在多的一端
# - 多对多
#建立表；
class Role(db.Model):
    __tablename__ = "用户角色"
    # autoincrement=True   设置id号递增
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    name = db.Column(db.String(20)) #设置字符长度为20
    # 反向引用, Role表中有属性users, User类中有role这个属性
    users = db.relationship('User', backref='role')
    # 定义了 __repr()__ 方法, 返回一个具有可读性的字符串表示模型, 可在调试和测试时使用
    def __repr__(self):
        return "<Role %s>" % (self.name)

class User(db.Model):
    __tablename__ = "网站用户"
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(30), unique=True, index=True, nullable=False) 
    password = db.Column(db.String(20), nullable=False)
    email = db.Column(db.String(20), unique=True, index=True)
    # 设置默认值, 位当前用户的创建时间
    add_time = db.Column(db.DateTime, default=datetime.now())
    #### 重要的: 用户角色id不能随便设置, 需要从Role中查询(外键关联)
    # 外健写在多的一端
    role_id = db.Column(db.Integer, db.ForeignKey('用户角色.id'))
    def __repr__(self):
        return "<User %s>" % (self.username)
        
if __name__ == '__main__':
    db.drop_all()
    db.create_all()
    
#1. 添加数据
# 1). 添加角色
role1 = Role(name="普通用户")
role2 = Role(name="会员")
role3 = Role(name="管理员")

db.session.add_all([role1, role2, role3])
db.session.commit()
# 2). 添加用户
user1 = User(username="westos1", password="westos1",
             email="[email protected]", role_id=1)
db.session.add(user1)
db.session.commit()

#2. 查看数据信息
print(User.query.all())
print(Role.query.all())
# 返回的是一个列表, 列表中有多个对象

#批量添加100个普通用户, 50个VIP用户, 10个管理员
for item in range(100):
    user = User(
        username="fentiao%s" % (item),
        password="fentiao",
        email="fentiao%s" % (item),
        role_id=1
    )
    db.session.add(user)

for item in range(50):
    user = User(
        username="vip%s" % (item),
        password="vip",
        email="vip%s" % (item),
        role_id=2
    )
    db.session.add(user)

for item in range(10):
    user = User(
        username="admin%s" % (item),
        password="admin",
        email="admin%s" % (item),
        role_id=3
    )
    db.session.add(user)

# 将批量添加的用户提交到数据库中
db.session.commit()

#获取所有的普通用户
common_users = User.query.filter_by(role_id='1').all()
print(common_users)
# 获取所有的vip用户
vip_users = User.query.filter_by(role_id='2').all()
print(vip_users)

#获取所有的普通用户转化成的sql语句查看
print(User.query.filter_by(role_id='1'))
print('*' * 10)
print(User.query)

#filter过滤器的使用(更偏向于SQL语句)
common_users = User.query.filter(User.role_id == 1).all()
print(common_users)

# limit过滤器, 只显示返回结果的前几条数据
common_users_limit = User.query.filter(User.role_id == 1).limit(5).all()
print(common_users_limit)

# offset过滤器: 偏移显示
common_users_offset = User.query.filter(User.role_id == 1).offset(2).limit(3).all()
print(common_users_offset)

#order_by排序过滤器, 默认是升序的, 如果要降序desc(属性名)
common_users_order = User.query.order_by(User.role_id).all()
print(common_users_order)
# 降序
common_users_desc_order = User.query.order_by(desc(User.role_id)).all()
print(common_users_desc_order)

#group_by, 分组统计
users_analysis = User.query.add_columns(func.count(User.role_id)).group_by(User.role_id).all()
print(users_analysis)

# get方法
print(User.query.get(1))
# print(User.query.get_or_404(1000))

#count
print(User.query.filter_by(role_id=1).count())
print(User.query.filter_by(role_id=2).count())
print(User.query.filter_by(role_id=3).count())

# paginate分页的对象
# page=2: 要显示第2页的数据
# per_page=5: 每页显示数据的条数

usersPageObj = User.query.paginate(page=2, per_page=5)
print("当前页面的记录数:", usersPageObj.items)
print("分页查询的源sql语句:", usersPageObj.query)
print("当前显示的页数:", usersPageObj.page)
print("上一页的页数:", usersPageObj.prev_num)
print("下一页的页数:", usersPageObj.next_num)
print("是否包含上一页:", usersPageObj.has_prev)
print("是否包含下一页:", usersPageObj.has_next)
print("总页数:", usersPageObj.pages)
print("每页记录的数量:", usersPageObj.per_page)
print("记录总数:", usersPageObj.total)
print("页码显示:", list(usersPageObj.iter_pages()))
print("上一页的数据:", usersPageObj.prev().items)
print("下一页的数据:", usersPageObj.next().items)

# Role表反向引用
print("反向引用".center(100, '*'))
admin_role = Role.query.filter_by(name="管理员").first()
print(admin_role.id)
print(admin_role.name)
print(admin_role.users)

# User表中
admin_user = User.query.filter_by(username='admin1').first()
admin_user_id = admin_user.role_id
print(Role.query.filter_by(id=admin_user_id).first().name)
admin_user = User.query.filter_by(username='admin1').first()
print(admin_user.role.name)

分页对象拥有的属性

分页对象拥有的方法