时间:2021-07-01 10:21:17 帮助过:9人阅读
首先import类库:
在CODE上查看代码片派生到我的代码片
from flask import Flask
from flask.ext.sqlalchemy import SQLAlchemy
然后,需要加载 数据库路径
在CODE上查看代码片派生到我的代码片
mysqlname='mysql://user:passwd@127.0.0.1/student?charset=utf8'
在CODE上查看代码片派生到我的代码片
app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = mysqlname
db = SQLAlchemy(app)
通过前面两步 ,我们已经让flask和数据库联系到了一起
下面我们要把 flask和具体的表联系在一起、
这样建立一个model模型
在CODE上查看代码片派生到我的代码片
class User(db.Model):
"""存储 每种报警类型的数量 , 以 分钟 为单位进行统计
:param source: string ,报警来源
:param network_logic_area: string ,该报警所属的逻辑网络区域
:param start_time: datetime , 报警发生时间
"""
__tablename__ = 'hello'
id = db.Column(db.Integer , primary_key = True)
source = db.Column(db.String(255) )
network_logic_area = db.Column(db.String(255) )
start_time = db.Column(db.DateTime)
count = db.Column(db.Integer)
def __init__(self , source , network_logic_area , start_time , count):
self.source = source
self.network_logic_area = network_logic_area
self.start_time = start_time
self.count = count
def alter(self):
self.count += 1;
上面这个代码,就让falsk和具体的表hello联系在了一起
在这个类中 ,我们首先要指定表,然后把这个表中的列都列出来,最后定义一个 初始化函数 , 让后面插入数据使用
现在开始具体的数据库操作:
1、insert
在CODE上查看代码片派生到我的代码片
p = User(........)
db.session.add(p)
db.session.commit()
通过 类User构造了一条数据
2、find
用主键获取数据:
Code example:
User.query.get(1)
通过一个精确参数进行反查:
Code example:
peter = User.query.filter_by(username='peter').first() #注意:精确查询函数query.filter_by(),是通过传递参数进行查询;其他增强型查询函数是query.filter(),通过传递表达式进行查询。 print(peter.id) #如果数据不存在则返回None
模糊查询:
Code example:
User.query.filter(User.email.endswith('@example.com')).all() [, ]
逻辑非1:
Code example:
peter = User.query.filter(User.username != 'peter').first() print(peter.id)
逻辑非2:
Code example:
from sqlalchemy import not_ peter = User.query.filter(not_(User.username=='peter')).first() print(peter.id)
逻辑与:
Code example:
from sqlalchemy import and_ peter = User.query.filter(and_(User.username=='peter', User.email.endswith('@example.com'))).first() print(peter.id)
逻辑或:
Code example:
from sqlalchemy import or_ peter = User.query.filter(or_(User.username != 'peter', User.email.endswith('@example.com'))).first() print(peter.id)
filter_by:这个里面只能放具体放入条件,不能放一个复杂的计算 ,
filter: 这个里面可以放一些复杂的计算
.first:取第一条数据
.all:取出所有数据
还有一个其他的方法,可以进行排序、计数之类的操作
3、使用sql语句
可以通过 前面构造的 db 直接使用sql的原生语句
在CODE上查看代码片派生到我的代码片
insert_table.db.engine.execute(' ..... ')
4、delete
在CODE上查看代码片派生到我的代码片
me = User(........)
在CODE上查看代码片派生到我的代码片
db.session.delete(me)
db.session.commit()
5、更新数据
Code example: u = User.query.first() u.username = 'guest' #更新数据和变量赋值那么简单,但必须是通过查询返回的对象。 db.session.commit()