Flask 数据库查询

in PythonFlask with 0 comment
# -*- coding: UTF-8 -*-

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

# app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root@localhost/3306/demo6'
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root@localhost:3306/demo6"

app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

db = SQLAlchemy(app)


class Role(db.Model):
    # 定义表名
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    us = db.relationship('User', backref='role')

    def __repr__(self):
        return 'Role %s' % self.name


class User(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True, index=True)
    email = db.Column(db.String(64), unique=True)
    password = db.Column(db.String(64))
    role_id = db.Column(db.Integer, db.ForeignKey('roles.id'))

    def __repr__(self):
        return 'User %s' % self.name


@app.route('/')
def index():
    return 'index'


if __name__ == '__main__':
    db.drop_all()
    db.create_all()

    ro1 = Role(name='admin')
    db.session.add(ro1)
    db.session.commit()
    ro2 = Role(name='user')
    db.session.add(ro2)
    db.session.commit()

    us1 = User(name='wang', email='wang@163.com', password='123456', role_id=ro1.id)
    us2 = User(name='wang1', email='wang1@163.com', password='123456', role_id=ro1.id)
    us3 = User(name='wang2', email='wang2@163.com', password='123456', role_id=ro1.id)
    us4 = User(name='wang3', email='wang3@163.com', password='123456', role_id=ro1.id)
    us5 = User(name='wang4', email='wang4@163.com', password='123456', role_id=ro1.id)
    us6 = User(name='wang5', email='wang5@163.com', password='123456', role_id=ro1.id)
    us7 = User(name='wang6', email='123136@163.com', password='123456', role_id=ro1.id)
    us8 = User(name='wang7', email='wang6@163.com', password='123456', role_id=ro1.id)
    us9 = User(name='wang9', email='wang8@163.com', password='123456', role_id=ro1.id)
    us10 = User(name='wang8', email='wang9@163.com', password='123456', role_id=ro1.id)
    db.session.add_all([us1, us2, us3, us4, us5, us6, us7, us8, us9, us10])
    db.session.commit()

    # 查询所有用户数据
    User.query.all()
    # 查询有多少个用户
    User.query.count()
    # 查询第1个用户
    User.query.first()
    # 查询id为4得用户[3种方式]
    User.query.get(4)
    User.query.filter_by(id=4).first()
    User.query.filter(User.id == 4).first()
    # 查询名字结尾字符为g的所有数据[开始statswish/包含contains]
    User.query.filter(User.name.endswith('g')).all()
    # 查询名字不等于wang的所有数据[2种方式]
    from sqlalchemy import not_

    User.query.filter(not_(User.name == 'wang')).all()
    # 查询名字和邮箱是以li开头的所有数据[2种方式]
    # 第一种方法
    User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all()

    # 第二种方法
    from sqlalchemy import and_

    User.query.filter(and_(User.name.startswith('li'), User.email.startswith('li'))).all()

    # 查询password是'123456或者email以163结尾的
    from sqlalchemy import or_

    User.query.filter(or_(User.password == '123456', User.email.endswith('163.com'))).all()

    # 查询id为[1,3,5,7,9]的用户列表

    User.query.filter(User.id.in_([1, 3, 4, 5, 9])).all()
    # 查询name为liu的数据
    User.query.filter(User.name == 'wang').first().role
    # 查询所有用户数据,并以邮箱排序
    # 正序
    User.query.order_by(User.email.asc()).all()
    # 倒序
    User.query.order_by(User.email.desc()).all()
    # 每页3个,查询第2页的数据
    # 分长重要

    paginate = User.query.paginate(2, 3) # 第一个参数2代表第几页,第二个参数3代表多少个
    paginate.items  # 当前页数据
    paginate.pages  # 总页数
    paginate.page  # 当前页

    app.run(debug=True)
Responses