web應用框架——Flask中的SQLAlchemy數(shù)據(jù)庫

一、數(shù)據(jù)庫

1.安裝數(shù)據(jù)庫

安裝sqlalchemy
pip install sqlalchemy
安裝mysqlclient
pip install mysqlclient

  • 安裝這個mysqlclient的時候出了一些問題：



  • 解決這個問題：
    https://www.lfd.uci.edu/~gohlke/pythonlibs/#
    進入這個網(wǎng)站，下載mysqlclient安裝包
    為了大家方便我已經(jīng)下好放入百度云中：

mysqlclient各個版本安裝包鏈接：https://pan.baidu.com/s/1Te8AowKKCSDmWyWSpWUVog
提取碼：lfxl

  • 下載安裝包
pip install F:\Pycharm\pycharm-2019.3.3\pycharm\mysqlclient-1.3.13-cp35-cp35m-win_amd64.whl
  • 下載mysqlclient
pip install mysqlclient

安裝完成

安裝pymysql
pip install pymysql
安裝flask_sqlalchemy
pip install flask_sqlalchemy
查看所有安裝目錄
pip list

二、創(chuàng)建數(shù)據(jù)庫

方式一：

  • 新建一個db_demo.html文件
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
# 設置數(shù)據(jù)庫連接
app.config['SQLALCHEMY_DATABASE_URI'] ='mysql://root:root@127.0.0.1:3306/test11'
# 動態(tài)追蹤設置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 顯示原始sql
app.config['SQLALCHEMY_ECHO'] = True


# 數(shù)據(jù)庫要和 app關聯(lián)
db = SQLAlchemy(app)

class Role(db.Model):
    # 定義表名
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)




@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 刪除表
    db.drop_all()
    # 創(chuàng)建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, ro2])
    db.session.commit()
    app.run()

  • 打開PHPstudy


  • 打開MySQL數(shù)據(jù)庫，新建數(shù)據(jù)庫


  • 運行程序



    會顯示創(chuàng)建表的過程

  • 刷新數(shù)據(jù)庫


方式二：

  • 新建一個db_demo2.html文件
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

host = 'localhost'
port = 3306
username = 'root'
password = 'root'
db = 'flask2'
connect_str = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(username,password,host,port,db)
# 設置數(shù)據(jù)庫連接
app.config['SQLALCHEMY_DATABASE_URI'] = connect_str
# 設置每次請求結(jié)束后自動提交數(shù)據(jù)庫的改動
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
# 動態(tài)追蹤設置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 顯示原始sql
app.config['SQLALCHEMY_ECHO'] = True
# 數(shù)據(jù)庫要和 app關聯(lián)
db = SQLAlchemy(app)

class Role(db.Model):
    # 定義表名
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)

@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 刪除表
    db.drop_all()
    # 創(chuàng)建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, ro2])
    db.session.commit()
    app.run()

  • 打開MySQL數(shù)據(jù)庫新建一個數(shù)據(jù)庫flask2


  • 運行程序


  • 刷新數(shù)據(jù)庫


三、插入數(shù)據(jù)

  • 創(chuàng)建表名：
class Role(db.Model):
    # 定義表名，角色表
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    db.relationship('User',backref='role')
    def __repr__(self):
        return 'Role:{}'.format(self.name)

class User(db.Model):
    # 定義表名，用戶表
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    email = db.Column(db.String(64), unique=True)
    password = db.Column(db.String(64))
    role_id = db.Column(db.Integer,db.ForeignKey('roles.id'))
    def __repr__(self):
        return 'User:{}'.format(self.name)
  • 添加數(shù)據(jù)：
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@neuedu.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@neuedu.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()
  • 完整代碼：
from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)

host = 'localhost'
port = 3306
username = 'root'
password = 'root'
db = 'flask2'
connect_str = 'mysql+pymysql://{}:{}@{}:{}/{}'.format(username,password,host,port,db)
# 設置數(shù)據(jù)庫連接
app.config['SQLALCHEMY_DATABASE_URI'] = connect_str
# 設置每次請求結(jié)束后自動提交數(shù)據(jù)庫的改動
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
# 動態(tài)追蹤設置
app.config['SQLALCHEMY_TRACK_MODUFICATIONS'] = True
# 顯示原始sql
app.config['SQLALCHEMY_ECHO'] = True
# 數(shù)據(jù)庫要和 app關聯(lián)
db = SQLAlchemy(app)

class Role(db.Model):
    # 定義表名，角色表
    __tablename__ = 'roles'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    db.relationship('User',backref='role')
    def __repr__(self):
        return 'Role:{}'.format(self.name)

class User(db.Model):
    # 定義表名，用戶表
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    name = db.Column(db.String(64), unique=True)
    email = db.Column(db.String(64), unique=True)
    password = db.Column(db.String(64))
    role_id = db.Column(db.Integer,db.ForeignKey('roles.id'))
    def __repr__(self):
        return 'User:{}'.format(self.name)


@app.route('/')
def index():
    return 'index'
if __name__ == '__main__':
    # 刪除表
    db.drop_all()
    # 創(chuàng)建表
    db.create_all()
    ro1 = Role(name='admin')
    ro2 = Role(name='user')
    db.session.add_all([ro1, 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@neuedu.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@neuedu.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()

  • 運行程序


  • 刷新數(shù)據(jù)庫


四、查找數(shù)據(jù)

  • 進入flask shell界面
flask shell
  • 導入user表
from db_demo2 import User





條件查詢

@app.route('/')
def index():
    # 1、返回名字等于wang 的所有人
    print(User.query.filter_by(name='wang').all())
    # 2返回查詢的第一個對象
    print(User.query.first())
    # 3. 返回所有查詢對象
    print(User.query.all())
    # 4. 返回名字結(jié)尾字符為g的所有數(shù)據(jù)
    print(User.query.filter(User.name.endswith('g')).all())
    # 5. 返回user中id = 1的數(shù)據(jù)
    print(User.query.get(1))
    # 6. 返回名字不等于wang的所有數(shù)據(jù)
    print(User.query.filter(User.name != 'wang').all())
    # 7 返回名字不等于 wang 且 郵箱 以 163.com結(jié)尾的所有
    print(User.query.filter(and_(User.name != 'wang',User.email.endswith('163.com'))).all())
    # 8 返回名字不等于 wang 或 郵箱 以 163.com結(jié)尾的所有
    print(User.query.filter(or_(User.name != 'wang', User.email.endswith('163.com'))).all())

    # 刪除數(shù)據(jù)
    # 刪除user中的第一條
    # user = User.query.first()
    # db.session.delete(user)
    # print("刪除user中的第一條")
    # print(User.query.all())

    # 更新數(shù)據(jù)
    #user = User.query.first()
    #user.name = 'eric'
    #db.session.commit()
    #print("更新數(shù)據(jù)user中的第一條")
    #print(User.query.first())

    # 查詢所有用戶數(shù)據(jù)
    print(User.query.all())
    # 查詢有多少個用戶
    print(User.query.count())
    # 查詢第1個用戶
    print(User.query.first())
    print(User.query.get(1))
    # 查詢id為4的用戶[3種方式]
    print(User.query.get(4))
    print(User.query.filter_by(id=4).all())
    print(User.query.filter(User.id == 4).all())
    # 查詢名字結(jié)尾字符為g的所有數(shù)據(jù)[開始/包含]
    print(User.query.filter(User.name.endswith('g')).all())
    # 查詢名字不等于wang的所有數(shù)據(jù)[2種方式]
    print(User.query.filter(User.name != 'wang').all())
    print(User.query.filter(or_(User.name == 'wang')).all())
    # 查詢名字和郵箱都以 li 開頭的所有數(shù)據(jù)[2種方式]
    print(User.query.filter(and_(User.name == 'li', User.email.startswith('li'))).all())
    print(User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all())
    # 查詢password是 `123456` 或者 `email` 以 `neuedu.com` 結(jié)尾的所有數(shù)據(jù)
    print(User.query.filter(or_(User.password == '123456', User.email.endswith('neuedu.com'))).all())
    # 查詢id為 [1, 3, 5, 7, 9] 的用戶列表
    print(User.query.filter(User.id.in_([1,3,4,7,9])).all())
    # 查詢name為liu的角色數(shù)據(jù)
    print(User.query.filter(User.name == 'liu').all())
    # 查詢所有用戶數(shù)據(jù)，并以郵箱排序
    print(User.query.order_by(User.email).all())
    # 每頁3個，查詢第2頁的數(shù)據(jù)
    pn=User.query.paginate(2,3)
    print(pn)
    return 'index'





（此文章僅作為個人學習筆記使用，如有錯誤歡迎指正~）

?著作權歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

友情鏈接更多精彩內(nèi)容