SQLAlchemy_基础使用

标签：load   config   demo   直接   alc   文件   虚拟环境   比较   first   

在虚拟环境使用以下命令将当前虚拟环境中的依赖包以版本号生成至文件中：

 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   

原文地址：https://www.cnblogs.com/kin02/p/14694991.html