pip freeze > requirements. txt
pip install - r requirements. txt
## SQLAlchemy
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
?
app = Flask( __name__)
?
# 配置数据库的地址 :数据库类型://数据库用户名:数据库密码@数据库地址:数据库端口/数据库名字
app. config[ ‘SQLALCHEMY_DATABASE_URI‘] = ‘mysql+pymysql://root:123456@127.0.0.1/flask_sql‘
# 跟踪数据库的修改 --> 不建议开启 未来的版本中会移除
app. config[ ‘SQLALCHEMY_TRACK_MODIFICATIONS‘] = True
# 查询是会显示原始SQL语句
# app.config[‘SQLALCHEMY_ECHO‘] = True
?
?
# 读取配置
# app.config.from_object(Config)
# 创建数据库sqlalchemy工具对象
db = SQLAlchemy( app)
?
# 数据库的模型，需要继承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)
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‘))
?
?
@app. route( ‘/‘)
def hello_world():
return ‘Hello World!‘
?
?
if __name__ == ‘__main__‘:
# 删除表：防止反复运行造成数据的冗余
db. drop_all()
print( "aaaa")
# 创建表
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)
激活虚拟环境： activate
退出虚拟环境： deactivate
安装 ipython:
D: \ JAVA \ PyCharm \ wenjian \ SQLAlchemy_demo > pip install ipython
启动 ipython：
( venv) D: \ JAVA \ PyCharm \ wenjian \ SQLAlchemy_demo > ipython
或
D: \ JAVA \ PyCharm \ wenjian \ SQLAlchemy_demo > ipython
在ipython中操作数据库
In [ 1]: from Flask_SQLalchemy_demo 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()
?
?
?
In [ 1]: from Flask_SQLalchemy_demo 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‘
?
?
‘‘‘
1. 查询所有用户数据
2. 查询有多少个用户
3. 查询第1个用户
4. 查询id为4的用户[3种方式]
‘‘‘
?
In [ 1]: from Flask_SQLalchemy_demo import *
1. 查询所有用户数据
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 >]
?
2. 查询有多少个用户
In [ 3]: User. query. count()
Out[ 3]: 10L
?
3. 查询第1个用户
In [ 4]: User. query. first()
Out[ 4]: < User: wang 1 wang @ 163. com 123456 >
?
4. 查询id为4的用户[ 3 种方式]
# filter_by直接用属性名，比较用=, filter用类名.属性名，比较用==
# filter_by用于查询简单的列名，不支持比较运算符
# filter比filter_by的功能更强大，支持比较运算符，支持or_、in_等语法。
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 功能更强大, 可以实现更多的一些查询, 支持比较运算符
增删改查
增：
# 为 Role 表添加数据.(注：Role 是表对应的class出的名字)
# 单条数据
ro1 = Role( name= ‘admin‘)
db. session. add( ro1)
db. session. commit()
# 多条数据
ro3 = Role( name= "long")
ro4 = Role( name= ‘aaa‘)
db. session. add_all([ ro3, ro4])
db. session. commit()
删：
# 删除 ‘Role‘ 表中id为 ‘4‘ 的字段.(注：Role 是表对应的class出的名字)
res1 = Role. query. filter( Role. id == "4"). first()
db. session. delete( res1)
db. session. commit()
改：
# 将 ‘Role‘ 表 ‘id=1‘ 的字段 name 值改为 "chu".(注：Role 是表对应的class出的名字)
res = Role.query.filter(Role.id == ‘1‘).first()
res.name = "chu"
db.session.commit()
查：
1. 查询所有用户数据 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>] 2. 查询有多少个用户 In [3]: User.query.count() Out[3]: 10L 3. 查询第1个用户 In [4]: User.query.first() Out[4]: <User: wang 1 wang@163.com 123456> 4. 查询id为4的用户[3种方式] # filter_by直接用属性名，比较用=, filter用类名.属性名，比较用== # filter_by用于查询简单的列名，不支持比较运算符 # filter比filter_by的功能更强大，支持比较运算符，支持or_、in_等语法。 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功能更强大, 可以实现更多的一些查询, 支持比较运算符
SQLAlchemy_基础使用
标签：load config demo 直接 alc 文件 虚拟环境 比较 first
声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://www.haodehen.cn/did117301