flask中的sqlalchemy 相比于sqlalchemy封裝的更加徹底一些 , 在一些方法上更簡單
首先import類庫:
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">from flask import Flask from flask.ext.sqlalchemy import SQLAlchemy</span>
然后,需要加載 數據庫路徑
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">mysqlname='<span style="color: rgb(230, 219, 116); font-family: 'Source Code Pro'; font-size: 13pt; background-color: rgb(39, 40, 34);">mysql://user:passwd@127.0.0.1/student?charset=utf8</span>'</span>
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">app = Flask(__name__) app.config['SQLALCHEMY_DATABASE_URI'] = mysqlname db = SQLAlchemy(app)</span>
通過前面兩步 ,我們已經讓flask和數據庫聯系到了一起
下面我們要把 flask和具體的表聯系在一起、
這樣建立一個model模型
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">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;</span>
上面這個代碼,就讓falsk和具體的表hello聯系在了一起
在這個類中 ,我們首先要指定表,然后把這個表中的列都列出來,最后定義一個 初始化函數 , 讓后面插入數據使用
現在開始具體的數據庫操作:
1、insert
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;"> p = User(........) db.session.add(p) db.session.commit()</span>
通過 類User構造了一條數據
2、find
用主鍵獲取數據:
Code example:
User.query.get(1)<User u'admin'>
通過一個精確參數進行反查:
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()[<User u'admin'>, <User u'guest'>]邏輯非1:
Code example:
peter=User.query.filter(User.username !='peter').first()print(peter.id)
邏輯非2:
Code example:
fromsqlalchemy importnot_peter=User.query.filter(not_(User.username=='peter')).first()print(peter.id)
邏輯與:
Code example:
fromsqlalchemy importand_peter=User.query.filter(and_(User.username=='peter', User.email.endswith('@example.com'))).first()print(peter.id)邏輯或:
Code example:
fromsqlalchemy importor_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上查看代碼片派生到我的代碼片
<span style="font-size:18px;">insert_table.db.engine.execute(' ..... ')</span>
4、delete
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">me = User(........)</span>
在CODE上查看代碼片派生到我的代碼片
<span style="font-size:18px;">db.session.delete(me) db.session.commit()</span>
5、更新數據
Code example: u=User.query.first()u.username='guest' #更新數據和變量賦值那么簡單,但必須是通過查詢返回的對象。db.session.commit()
新聞熱點
疑難解答
圖片精選