forked from shibing624/python-tutorial
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy path09.flask_sql.py
More file actions
57 lines (48 loc) · 2.17 KB
/
09.flask_sql.py
File metadata and controls
57 lines (48 loc) · 2.17 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
# -*- coding: utf-8 -*-
"""
@author:XuMing（[email protected])
@description:
"""
from flask_sqlalchemy import SQLAlchemy
from flask import Flask
app = Flask(__name__)
# 此处是配置SQLALCHEMY_DATABASE_URI, 前面的mysql+mysqlconnetor指的是数据库的类型以及驱动类型
# 后面的username,pwd,addr,port,dbname分别代表用户名、密码、地址、端口以及库名
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:@127.0.0.1:3306/demo'
# 创建1个SQLAlichemy实例
db = SQLAlchemy(app)
# 定义1个类(由db.Model继承)，注意这个类是数据库真实存在的，因为我是针对已有数据库做转化
# 我的数据库结构见下图 其中role是数据库的一张表名
class role(db.Model):
# id是主键db.Column是字段名， db.INT是数据类型
id = db.Column(db.INT, primary_key=True)
name = db.Column(db.String(99), unique=False)
name_cn = db.Column(db.String(99), unique=False)
def __init__(self, id, name, name_cn):
self.id = id
self.name = name
self.name_cn = name_cn
def __repr__(self):
return '<User %r>' % self.name
# 初始化role 并插入数据库
test_role1 = role(10, 'supervisol', '超超超超级管理员')
test_role2 = role(11, 'your try', '你试试哦')
db.session.add(test_role1)
db.session.add(test_role2)
db.session.commit()
#查询数据库
a = db.session.query(role).filter_by(id=2).first() # 查询role表中id为2的第一个匹配项目，用".字段名"获取字段值
print(a)
b = db.session.query(role).all() # 得到一个list，返回role表里的所有role实例
print(b)
db.session.query(role).filter(role.id == 2).first() # 结果与第一种一致
# 获取指定字段，返回一个生成器 通过遍历来完成相关操作, 也可以强转为list
d = db.session.query(role).filter_by(id=2).values('id', 'name', 'name_cn')
print(list(d))
# 模糊查询
e = db.session.query(role).filter(role.name_cn.endswith('管理员')).all() # 获取role表中name_cn字段以管理员结尾的所有内容
print(e)
# 修改数据库内容
user = db.session.query(role).filter_by(id=7).first() # 将role表中id为6的name改为change
user.name = 'change'
db.session.commit()