flask数据库练习---原创
图解如下:
注意:增删改都是通过db.session来操作的
查的话是通过User.query.filter().all()
sqlachemy程序以及测试数据如下:
from flask import Flask
from flask_script import Manager
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
app.config['DEBUG']=True
manage = Manager(app)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:[email protected]:3306/flask_test'
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
if name == '__main__':
db.drop_all() db.create_all() # app.run(debug=True) # 创建测试数据 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='[email protected]', password='123456', role_id=ro1.id) us2 = User(name='zhang', email='[email protected]', password='201512', role_id=ro2.id) us3 = User(name='chen', email='[email protected]', password='987654', role_id=ro2.id) us4 = User(name='zhou', email='[email protected]', password='456789', role_id=ro1.id) us5 = User(name='tang', email='[email protected]', password='158104', role_id=ro2.id) us6 = User(name='wu', email='[email protected]', password='5623514', role_id=ro2.id) us7 = User(name='qian', email='[email protected]', password='1543567', role_id=ro1.id) us8 = User(name='liu', email='[email protected]', password='867322', role_id=ro1.id) us9 = User(name='li', email='[email protected]', password='4526342', role_id=ro2.id) us10 = User(name='sun', email='[email protected]', password='235523', role_id=ro2.id) db.session.add_all([us1, us2, us3, us4, us5, us6, us7, us8, us9, us10]) db.session.commit() manage.run(default_command='runserver')
测试指令如下:
注意返回的数据是根据自定义的repr方法返回值显示的。filter模糊查询,filter_by精确查询,两者返回的都是查询集。
查询所有用户数据
User.query.all()
查询有多少个用户
User.query.count()
查询第1个用户
User.query.first()
查询id为4的用户[3种方式]
User.query.get(4)
User.query.filter(User.id==4).all()
User.query.filter_by(id=4).all()
查询名字结尾字符为g的所有数据[开始/包含]
User.query.filter(User.name.endswith('g')).all()
User.query.filter(User.name.contains('g')).all()
查询名字不等于wang的所有数据[2种方式]
User.query.filter(User.name!='wang').all()
from sqlalchemy import not_
User.query.filter(not_(User.name=='wang')).all()
查询名字和邮箱都以 li 开头的所有数据[2种方式
from sqlalchemy import and_
User.query.filter(and_(User.name.startswith('li'),User.email.startswith('li')).all()
User.query.filter(User.name.startswith('li'),User.email.startswith('li')).all()
查询password是 123456 或者 email 以 itheima.com 结尾的所有数据
from sqlalchemy import or_
User.query.filter(or_(User.password=='123456',User.email.endswith('itheima.com'))).all()
查询id为 [1, 3, 5, 7, 9] 的用户列表
User.query.filter(User.id.in_([1,3,5,7,9])).all()
查询name为liu的角色数据
Role.query.filter(Role.id==User.query.filter(User.name=='liu').first().role_id).first()
可以简化为
User.query.filter(User.name=='liu').first().role
查询该角色有哪些用户扮演了
Role.query.get(1).users
查询所有用户数据,并以邮箱排序
User.query.order_by('email').all()
User.query.order_by(User.email.desc()).all()
每页3个,查询第2页的数据
it = User.query.paginate(2,3,False)
it.pages -----总页数
it.page -----当前页
it.items -----当前页的数据
------limit-----
User.query.limit(3).all()