SQLALchemy資料庫

SQLALchemy是一個關係型資料庫框架，它提供了高層的ORM和底層的原生資料庫的操作。 flask-sqlalchemy是一個簡化了SQLALchemy操作的flask擴充套件。

flask使用SQLALchemy操作資料庫

在flask的虛擬環境中先安裝：flask_sqlalchemy ，pymysql

pip install flask_sqlalchemy
pip install pymysql

在init.py中配置資料庫

import os
from flask import Flask
from flask_sqlalchemy import
 
 SQLALchemy

from Stu.views import stu

def create_app():
    BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
    template_dir = os.path.join(BASE_DIR,'templates')
    static_dir = os.path.join(BASE_DIR,'static')
    app=Flask(__name__,template_floder=template_dir,static_floder=static_dir)
    # 配置資料庫
 

    app.config['SQLALCHEMY_DATABASE_URI']= 'mysql+pymysql://root:[email protected]:3306/flask3'
    app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = Falseie
    # 註冊藍圖
    app.register_blueprint(blueprint=stu,url_prefix='/stu')
    #初始化app
    SQLALchemy(app=app)
    return app

在model.py 建立模型

from
 
 flask_sqlalchemy import SQLALchemy

db = SQLALchemy()


class Student(db.model):
    s_id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    s_name = db.Column(db.String(20),unique =True)
    s_age = db.Column(db.Integer,default=18)

    __tablename__ = 'student'

建立表和增刪改查

在views.py中：

import random
from flask import Blueprint, render_template, request, redirect, url_for, make_response

from Stu.models import db, Student

stu = Blueprint('stu', __name__)


@stu.route('/')
def index():
    return render_template('index.html')


@stu.route('/score/')
def score():
    score_list = [21, 34, 33, 45, 67, 78]
    content_h2 = '<h2>少男<h2>'
    content_h3 = '  <h3>速度快解散<h3>'
    return render_template('score.html', score=score_list,
                           content_h2=content_h2,
                           content_h3=content_h3)


# 建立表
@stu.route('/createtable/')
def create_db():
    db.create_all()
    return '建立成功'


# 刪除表
@stu.route('/droptable/')
def drop_db():
    db.drop_all()
    return '刪除成功'


# 在資料庫建立單個學生
@stu.route('/createstu/')
def create_stu():
    stu = Student()
    stu.s_name = '小帥%d' % random.randrange(1000)
    stu.s_age = '%d' % random.randrange(20)
    db.session.add(stu)
    try:
        db.session.commit()
    except:
        db.session.rollback()
    return '建立學生成功'


# 一次建立多個學生  關鍵字：db.session.add_all(列表)
@stu.route('/createmoneystu/')
def create_money_stu():
    stu_list = []
    stu1 = Student(username1,age1)
    stu2 = Student(username2,age2)
    stu_list.append(stu1)
    stu_list.append(stu2)
    db.session.add_all(stu_list)
    db.session.commit
    return '建立多個學生成功'





# 查詢所有方法
@stu.route('/stulist/')
def stu_all():
    # 第一種查詢所有
    stus = Student.query.all()
    return render_template('studentlist.html', stus=stus)


# 查詢一個學生方法
@stu.route('/studentail/')
def stu_detail():
    # 原生的SQL語句查詢
    # sql = 'select * from student where s_name="小帥790";'
    # stus = db.session.execute(sql)

    # 使用filter
    # stus = Student.query.filter(Student.s_name == '小帥790')

    # 使用filter_by
    stus = Student.query.filter_by(s_name='小帥399')
    print(stus.first())
    return render_template('studentlist.html', stus=stus)


# 更新方法
@stu.route('/updatestu/')
def update_stu():
    # 第一種方式
    # stu = Student.query.filter_by(s_id=5).first()
    # stu.s_name = '李二狗'
    # 第二種方法
    Student.query.filter_by(s_id=5).update({'s_name': '王大錘'})

    db.session.commit()
    return redirect(url_for('stu.stu_all'))


# 刪除方法
@stu.route('/deletestu/')
def delete_stu():
    stu = Student.query.filter(Student.s_id == 5).first()
    db.session.delete(stu)
    db.session.commit()
    return redirect(url_for('stu.stu_all'))