配置和鏈接
- 安裝
pip install flask-sqlalchemy
- ModuleNotFoundError: No module named 'MySQLdb' :
pip install mysqlclient
建立鏈接
![](http://static.javashuo.com/static/loading.gif)
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
# 設置數據庫的鏈接地址
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test28'
# 設置是否追蹤數據庫變化 通常不會開啓, 影響性能
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
# 設置是否打印底層執行的SQL語句
app.config['SQLALCHEMY_ECHO'] = True
# 建立數據庫鏈接對象
db = SQLAlchemy(app)
# 類->表 類屬性->字段 對象->記錄
class User(db.Model):
__tablename__ = 't_user' # 設置表名, 表名默認爲類名小寫
id = db.Column(db.Integer, primary_key=True) # 主鍵, 默認自增
name = db.Column(db.String(20), unique=True) # 設置惟一
age = db.Column(db.Integer)
@app.route('/')
def index():
"""增長數據"""
# sqlalchemy會自動建立一個隱式事務, 並將sql操做添加到事務中
# 建立模型對象
user1 = User(name='zs', age=20)
# user1.name = 'zs' # 另外一種設置數據的方式
# 將對象添加到會話中 轉換對應的sql語句
db.session.add(user1)
# db.session.add_all([user1, user2, user3]) # 批量添加數據
# 提交會話 就會提交事務, 並且事務失敗會自動回滾
db.session.commit()
return "index"
if __name__ == '__main__':
# 刪除全部繼承自db.Model的表
db.drop_all()
# 建立全部繼承自db.Model的表
db.create_all()
app.run(debug=True)
增長數據
![](http://static.javashuo.com/static/loading.gif)
查詢數據
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
# 設置數據庫鏈接地址
app.config["SQLALCHEMY_DATABASE_URI"] = "mysql://root:mysql@127.0.0.1:3306/test28"
# 設置是否跟蹤數據庫改變
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
app.config["SQLALCHEMY_ECHO"] = True
# 建立數據庫鏈接
db = SQLAlchemy(app)
# 自定義類 繼承db.Model 對應 表
class User(db.Model):
__tablename__ = "users" # 表名 默認使用類名的小寫
# 定義類屬性 記錄字段
id = db.Column(db.Integer, primary_key=True)
name = db.Column(db.String(64))
email = db.Column(db.String(64))
age = db.Column(db.Integer)
def __repr__(self): # 自定義 交互模式 & print() 的對象打印
return "(%s, %s, %s, %s)" % (self.id, self.name, self.email, self.age)
@app.route('/')
def index():
"""
查詢全部用戶數據
User.query.all() 返回列表,裏邊包含的是數據對象
查詢有多少個用戶
User.query.count()
查詢第1個用戶
User.query.first() 返回對象
查詢id爲4的用戶[3種方式]
User.query.get(4) # 根據id查詢 返回對象
BaseQuery類型 容許續接其餘具體的查詢條件 如all/first/count等
User.query.filter_by(id=4).all() # 簡單查詢器 關鍵字實參的方式來匹配字段 返回BaseQuery對象
User.query.filter(User.id==4).first() # 複雜查詢器 恆等式/函數形式來匹配 返回BaseQuery對象
查詢名字結尾字符爲g的全部用戶[開始 / 包含]
User.query.filter(User.name.endswith('g')).all()
User.query.filter(User.name.startswith('w')).all()
User.query.filter(User.name.contains('n')).all()
User.query.filter(User.name.like('w%n%g')).all() # 模擬查詢
查詢名字和郵箱都以li開頭的全部用戶[2種方式]
User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all()
from sqlalchemy import and_
User.query.filter(and_(User.name.startswith('li'), User.email.startswith('li'))).all()
查詢age是25 或者 `email`以`itheima.com`結尾的全部用戶
from sqlalchemy import or_
User.query.filter(or_(User.age==25, User.email.endswith("itheima.com"))).all()
查詢名字不等於wang的全部用戶[2種方式]
from sqlalchemy import not_
User.query.filter(not_(User.name=='wang')).all()
User.query.filter(User.name!='wang').all()
查詢id爲[1, 3, 5, 7, 9]的用戶
User.query.filter(User.id.in_([1, 3, 5, 7, 9])).all()
全部用戶先按年齡從小到大, 再按id從大到小排序, 取前5個
User.query.order_by(User.age, User.id.desc()).limit(5).all()
查詢年齡從小到大第2-5位的數據
User.query.order_by(User.age).offset(1).limit(4).all()
分頁查詢, 每頁3個, 查詢第2頁的數據
pn = User.query.paginate(2, 3)
pn.pages 總頁數 pn.page 當前頁數 pn.items 當前頁的數據
查詢每一個年齡的人數 select age, count(name) from t_user group by age 分組聚合
from sqlalchemy import func
db.session.query(User.age, func.count(User.name)).group_by(User.age).all()
只查詢全部人的姓名和郵箱 優化查詢 默認使用select *
from sqlalchemy.orm import load_only
users = User.query.options(load_only(User.name, User.email)).all() # 返回對象列表
# for user in users:
# print(user.name, user.email)
data = db.session.query(User.name, User.email).all() # 返回元組列表
"""
return 'index'
if __name__ == '__main__':
# 刪除全部表
db.drop_all()
# 建立全部表
db.create_all()
# 添加測試數據
user1 = User(name='wang', email='wang@163.com', age=20)
user2 = User(name='zhang', email='zhang@189.com', age=33)
user3 = User(name='chen', email='chen@126.com', age=23)
user4 = User(name='zhou', email='zhou@163.com', age=29)
user5 = User(name='tang', email='tang@itheima.com', age=25)
user6 = User(name='wu', email='wu@gmail.com', age=25)
user7 = User(name='qian', email='qian@gmail.com', age=23)
user8 = User(name='liu', email='liu@itheima.com', age=30)
user9 = User(name='li', email='li@163.com', age=28)
user10 = User(name='sun', email='sun@163.com', age=26)
# 一次添加多條數據
db.session.add_all([user1, user2, user3, user4, user5, user6, user7, user8, user9, user10])
db.session.commit()
app.run(debug=True)
更新和刪除數據
![](http://static.javashuo.com/static/loading.gif)
@app.route('/')
def index():
"""更新數據"""
# 方式1: 先查詢數據, 再更新數據
# user = User.query.filter_by(name='zs').first()
# user.age = 30
# 提交會話
# db.session.commit()
# 方式2: update子查詢 update t_order set count=count-1 where count > 0;
# User.query.filter_by(name='zs').update({'age': 30})
# 提交會話
# db.session.commit()
"""刪除數據"""
# 方式1: 先查詢數據, 再刪除數據
# user = User.query.filter_by(name='zs').first()
# db.session.delete(user)
# db.session.commit()
# 方式2: delete子查詢
User.query.filter_by(name='zs').delete()
# 提交會話
db.session.commit()
return "index"