导包
-*- coding:utf-8 -*-
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import pymysql
pymysql.install_as_MySQLdb()
app = Flask(__name__)
配置数据库地址
# 配置数据库的地址
# mysql://root:123456@127.0.0.1/flask_sql_demo 123456:mysql的密码， 127.0.0.1:ip flask_sql_demo:数据库名称
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@127.0.0.1/flask_sql_demo'
# 跟踪数据库的修改 --> 不建议开启 未来的版本中会移除
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
db = SQLAlchemy(app)
首先要打开mysql 创建数据库flask_sql_demo
其次用脚本创建两张表roles和users
'''
两张表
角色(管理员 / 普通用户)
用户(角色ID)
'''
# 数据库的模型, 需要继承db.Model
class Role(db.Model):
# 定义表名
__tablename__ = 'roles'
# 定义字段
# db.Column表示是一个字段
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
class User(db.Model):
__tablename__ = 'users'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
@app.route('/')
def index():
return 'Hello flask!'
if __name__ == '__main__':
# 先删除表然后创建表为了清空之前的数据，防止报错
# 删除表
db.drop_all()
# 创建表
db.create_all()
app.run(debug=True)
以上完成后用mysql查看会新建两张表roles和users
之后用pycharm的终端进入当前的脚本
# 输入
python
# flask_sql 是命名的py脚本
In [1]: from flask_sql import *
添加数据
In [2]: role = Role(name='admin')
In [3]: db.session.add(role)
In [4]: db.session.commit()
In [5]: user = User(name='heima', role_id=role.id)
In [6]: db.session.add(user)
In [7]: db.session.commit()
修改数据
In [8]: user.name = 'chengxuyuan'
In [9]: db.session.commit()
删除数据
In [10]: db.session.delete(user)
In [11]: db.session.commit()
添加两个表之间的关联关系
'''
两张表
角色(管理员 / 普通用户)
用户(角色ID)
'''
# 数据库的模型, 需要继承db.Model
class Role(db.Model):
# 定义表名
__tablename__ = 'roles'
# 定义字段
# db.Column表示是一个字段
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
# 在一的一方, 写关联
# users = db.relationship('User'): 表示和User模型发生了关联, 增加了一个users属性
# backref='role': 表示role是User要用的属性
users = db.relationship('User', backref='role')
# repr()方法显示一个可读字符串
def __repr__(self):
return '<Role: %s %s>' % (self.name, self.id)
class User(db.Model):
__tablename__ = 'users'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
email = db.Column(db.String(32), unique=True)
password = db.Column(db.String(32))
# db.ForeignKey('roles.id') # 表示是外键. 表名.id
role_id = db.Column(db.Integer, db.ForeignKey('roles.id'))
# User希望有role属性, 但是这个属性的定义, 需要再另一个模型中定义
def __repr__(self):
return '<User: %s %s %s %s>' % (self.name, self.id, self.email, self.password)
@app.route('/')
def index():
return 'Hello flask!'
if __name__ == '__main__':
# 删除表
db.drop_all()
# 创建表
db.create_all()
app.run(debug=True)
## 用pycharm的终端敲命令
In [1]: from flask_sql import *
添加一个角色和两个用户
In [2]: role = Role(name='admin')
In [3]: db.session.add(role)
In [4]: db.session.commit()
In [5]: user1 = User(name='zs', role_id=role.id)
In [6]: user2 = User(name='ls', role_id=role.id)
In [7]: db.session.add_all([user1, user2])
In [8]: db.session.commit()
实现关系引用查询
In [9]: role.users
Out[9]: [<User: zs 1 None None>, <User: ls 2 None None>]
In [10]: user1.role
Out[10]: <Role: admin 1>
In [11]: user2.role.name
Out[11]: u'admin'
完整代码
# -*- coding:utf-8 -*-
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import pymysql
pymysql.install_as_MySQLdb()
app = Flask(__name__)
# 配置数据库的地址
# mysql://root:123456@127.0.0.1/flask_sql_demo 123456:mysql的密码， 127.0.0.1:ip flask_sql_demo:数据库名称
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:123456@127.0.0.1/flask_sql_demo'
# 跟踪数据库的修改 --> 不建议开启 未来的版本中会移除
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
db = SQLAlchemy(app)
'''
两张表
角色(管理员 / 普通用户)
用户(角色ID)
'''
# 数据库的模型, 需要继承db.Model
class Role(db.Model):
# 定义表名
__tablename__ = 'roles'
# 定义字段
# db.Column表示是一个字段
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
# 在一的一方, 写关联
# users = db.relationship('User'): 表示和User模型发生了关联, 增加了一个users属性
# backref='role': 表示role是User要用的属性
users = db.relationship('User', backref='role')
# repr()方法显示一个可读字符串
def __repr__(self):
return '<Role: %s %s>' % (self.name, self.id)
class User(db.Model):
__tablename__ = 'users'
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(16), unique=True)
email = db.Column(db.String(32), unique=True)
password = db.Column(db.String(32))
# db.ForeignKey('roles.id') # 表示是外键. 表名.id
role_id = db.Column(db.Integer, db.ForeignKey('roles.id'))
# User希望有role属性, 但是这个属性的定义, 需要再另一个模型中定义
def __repr__(self):
return '<User: %s %s %s %s>' % (self.name, self.id, self.email, self.password)
@app.route('/')
def index():
return 'Hello flask!'
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='zhang', email='zhang@189.com', password='201512', role_id=ro2.id)
us3 = User(name='chen', email='chen@126.com', password='987654', role_id=ro2.id)
us4 = User(name='zhou', email='zhou@163.com', password='456789', role_id=ro1.id)
us5 = User(name='tang', email='tang@itheima.com', password='158104', role_id=ro2.id)
us6 = User(name='wu', email='wu@gmail.com', password='5623514', role_id=ro2.id)
us7 = User(name='qian', email='qian@gmail.com', password='1543567', role_id=ro1.id)
us8 = User(name='liu', email='liu@itheima.com', password='867322', role_id=ro1.id)
us9 = User(name='li', email='li@163.com', password='4526342', role_id=ro2.id)
us10 = User(name='sun', email='sun@163.com', password='235523', role_id=ro2.id)
db.session.add_all([us1, us2, us3, us4, us5, us6, us7, us8, us9, us10])
db.session.commit()
app.run(debug=True)
'''
## 用pycharm的终端敲命令
In [1]: from Flask_SQLalchemy_demo import *
In [2]: User.query.all()
Out[2]:
[<User: wang 1 wang@163.com 123456>,
<User: zhang 2 zhang@189.com 201512>,
<User: chen 3 chen@126.com 987654>,
<User: zhou 4 zhou@163.com 456789>,
<User: tang 5 tang@itheima.com 158104>,
<User: wu 6 wu@gmail.com 5623514>,
<User: qian 7 qian@gmail.com 1543567>,
<User: liu 8 liu@itheima.com 867322>,
<User: li 9 li@163.com 4526342>,
<User: sun 10 sun@163.com 235523>]
In [3]: User.query.count()
Out[3]: 10L
In [4]: User.query.first()
Out[4]: <User: wang 1 wang@163.com 123456>
In [5]: User.query.get(4)
Out[5]: <User: zhou 4 zhou@163.com 456789>
In [6]: User.query.filter_by(id=4).first()
Out[6]: <User: zhou 4 zhou@163.com 456789>
In [7]: User.query.filter(User.id==4).first()
Out[7]: <User: zhou 4 zhou@163.com 456789>
filter_by: 属性=
filter: 对象.属性==
filter功能更强大, 可以实现更多的一些查询, 支持比较运算符
