SQLAlchemy_基础使用

 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