@app.before_first_request
#只有第一次請(qǐng)求之前調(diào)用，可以在此方法內(nèi)部做一些初始化操作


@app.before_request
#每次請(qǐng)求之前都會(huì)觸發(fā)
#在每一次請(qǐng)求之前調(diào)用，這時(shí)候已經(jīng)有請(qǐng)求了，可能在這個(gè)方法里面做請(qǐng)求的校驗(yàn)
#如果請(qǐng)求的校驗(yàn)不成功，可以直接在此方法中進(jìn)行響應(yīng)，直接return之后那么就不會(huì)執(zhí)行視圖函數(shù)

@app.after_request
#在每次執(zhí)行完視圖函數(shù)之后會(huì)調(diào)用，要傳入函數(shù)響應(yīng)
#在執(zhí)行完視圖函數(shù)之后會(huì)調(diào)用，并且會(huì)把視圖函數(shù)所生成的響應(yīng)傳入，可以在此方法中對(duì)應(yīng)響應(yīng)做最后一步統(tǒng)一的處理

@app.teardown_request
#每一次請(qǐng)求之后都會(huì)調(diào)用，會(huì)接受一個(gè)參數(shù)，參數(shù)是服務(wù)器出現(xiàn)的錯(cuò)誤信息

from flask import Flask
from flask_restful import Api, Resource
from flask_sqlalchemy import SQLAlchemy

#import pymysql
#pymysql.install_as_MySQLdb()

"""
python2中數(shù)據(jù)庫(kù)客戶端： MySqldb
python3中數(shù)據(jù)庫(kù)客戶端：pymysql
解決方案一：讓python2和python3的包進(jìn)行轉(zhuǎn)換。
import pymysql
pymysql.install_as_MySQLdb()

方案二：表示只使用python3的包，不使用python2的包
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
"""

app = Flask(__name__)
db = SQLAlchemy(app) #創(chuàng)建一個(gè)對(duì)象，設(shè)置名為db

# app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://賬號(hào):密碼@數(shù)據(jù)庫(kù)ip地址:端口號(hào)/數(shù)據(jù)庫(kù)名"
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
# app.config['SQLALCHEMY_BINDS'] = {}

# 關(guān)閉數(shù)據(jù)庫(kù)修改跟蹤操作[提高性能]，可以設(shè)置為True，這樣可以跟蹤操作：
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

# 開啟輸出底層執(zhí)行的sql語(yǔ)句
app.config['SQLALCHEMY_ECHO'] = True

# 開啟數(shù)據(jù)庫(kù)的自動(dòng)提交功能[一般不使用]
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True

@app.route('/')
def hello_word():
    return "hello, word"

if __name__ == '__main__':
    print(app.url_map)
    app.run(host='0.0.0.0', port= 8000, debug=True)

from flask import Flask
from flask_sqlalchemy import SQLAlchemy

app = Flask(__name__)
db = SQLAlchemy(app) #創(chuàng)建一個(gè)對(duì)象，設(shè)置名為db


#建立數(shù)據(jù)庫(kù)連接
#app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://賬號(hào):密碼@數(shù)據(jù)庫(kù)ip地址:端口號(hào)/數(shù)據(jù)庫(kù)名"
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"



驗(yàn)證是否連接成功
@app.route('/')
def hello_word():

	engine = db.get_engine()
	conn = engine.connect()
	conn.close() #跟open函數(shù)一樣，可以用with語(yǔ)句
	#with engine.connect() as conn:
	#	result = conn.execute('select 1')  #這兩步打開數(shù)據(jù)庫(kù)并且創(chuàng)建表
	#	print (result.fetchone()) #打印一條數(shù)據(jù)
    return "hello, word"



創(chuàng)建模型并進(jìn)行數(shù)據(jù)增刪改查
#創(chuàng)建orm模型---
class mmm(db.Model):
	__tablename__ = 'mmm'  # 設(shè)置表名
	id = db.Column(db.Integer,primary_key,autoincreament)
	title = db.Column(db.string(200),nullable=Flase)
	content = db.Column(db.Text,nullable=Flase)

db.create_all()

    # 刪除所有繼承自db.Model的表
   	# db.drop_all()
    # 創(chuàng)建所有繼承自db.Model的表
    #db.create_all()


數(shù)據(jù)操作——增刪改查
1：給模型對(duì)象設(shè)置數(shù)據(jù) 可以通過(guò) 初始化參數(shù) 或者 賦值屬性 兩種方式
2：session.add(模型對(duì)象) 添加單條數(shù)據(jù)到會(huì)話中, session.add_all(列表) 添加多條數(shù)據(jù)到會(huì)話中
3：sqlalchemy 會(huì) 自動(dòng)創(chuàng)建事務(wù), 并將數(shù)據(jù)操作包含在事務(wù)中, 提交會(huì)話時(shí)就會(huì)提交事務(wù)，事務(wù)提交失敗會(huì)自動(dòng)回滾。

@app.route('/mmm")
def mmm_view():
	#1. 添加數(shù)據(jù)
	# sql語(yǔ)句為 insert table mmm value （xxx），這里不用
	#之前創(chuàng)建了mmm類對(duì)象，所以直接調(diào)用即可
	article = mmm（title= "",content=""）
	
	#數(shù)據(jù)添加
	db.session.add(article)  
	#數(shù)據(jù)提交
	db.session.commit()
	#最后進(jìn)行返回操作
	return "數(shù)據(jù)操作成功"
	
	#2.查詢數(shù)據(jù)
	# filter_by() 返回一個(gè)類列表的對(duì)象
	artice = mmm.query.filter_by(id=1)[0] #進(jìn)行查詢，根據(jù)誰(shuí)進(jìn)行查詢,必須用 []將值取出來(lái)
	print（artice.title） #將id為1的title取出來(lái)
	return	"數(shù)據(jù)操作成功"


	#3.修改數(shù)據(jù)
	artice = mmm.query.filter_by(id=1)[0] 
	artice.content = "xxx"  #將id為一的content的數(shù)據(jù)改成xxx
	#修改數(shù)據(jù)的進(jìn)行數(shù)據(jù)提交
	db.session.commit
	return "數(shù)據(jù)操作成功"


	#4.刪除數(shù)據(jù)
	mmm.query.filter_by(id=1).delete()
	db.session.commit()
	return "數(shù)據(jù)操作成功"

class user(db.Model):
	__tablename__ = 'mmm'  # 設(shè)置表名
	id = db.Column(db.Integer,primary_key,autoincreament)
	username = db.Column(db.string(200),nullable=)



class Article(db.Model):
	__tablename__ = 'ggg'  # 設(shè)置表名
	id = db.Column(db.Integer,primary_key,autoincreament)
	title = db.Column(db.string(200),nullable=Flase)
	content = db.Column(db.Text,nullable=Flase)
	

	#外鍵
	#1.外鍵的數(shù)據(jù)類型一定要看所引用的字段類型，要一樣
	#2. db.Foreignkey("表名. 字段名")
	#3.外鍵是屬于數(shù)據(jù)庫(kù)層面的，不推薦直接在ORM直接使用
	author_id = db.Column(db.Integer,db.Foreignkey("user.id"))


	#relationship
	#1.第一個(gè)參數(shù)是模型的名字，必須要和模型的名字一致
	#2.backref（bsck reference）：代表反向引用，代表對(duì)方訪問(wèn)我的時(shí)候的字段名稱
	author = db.relationship("user",backref="articles")


	#一對(duì)一：
	# db.backref
	#1. 在反向引用的時(shí)候，如果需要傳遞一些其他的參數(shù)，那么就需要用到這個(gè)函數(shù)，否則不需要使用，只要在relationship的backref參數(shù)上，設(shè)置反向引用的名稱就可以了。
	#2. uselist=Flase ：代表反向引用的名稱就可以了
	user = db.relationship("User",backref=db.backref("extension",uselist=Flase))

pip install flask-migrate

要讓Flask-Migrate能夠管理app中的數(shù)據(jù)庫(kù)，需要使用Migrate(app,db)來(lái)綁定app和數(shù)據(jù)庫(kù)。假如現(xiàn)在有以下app文件：
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from constants import DB_URI
from flask_migrate import Migrate

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = DB_URI
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
db = SQLAlchemy(app)
# 綁定app和數(shù)據(jù)庫(kù)
migrate = Migrate(app,db)

class User(db.Model):
    id = db.Column(db.Integer,primary_key=True)
    username = db.Column(db.String(20))

    addresses = db.relationship('Address',backref='user')

class Address(db.Model):
    id = db.Column(db.Integer,primary_key=True)
    email_address = db.Column(db.String(50))
    user_id = db.Column(db.Integer,db.ForeignKey('user.id'))

db.create_all()

@app.route('/')
def hello_world():
    return 'Hello World!'

if __name__ == '__main__':
    app.run()

flask db init

flask db migrate

flask db upgrade

# constants.py
HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = 'xt_flask_migrate'
USERNAME = 'root'
PASSWORD = 'root'
DB_URI = 'mysql+mysqldb://{}:{}@{}:{}/{}'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)

# ext.py
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()

# models.py
from ext import db
class User(db.Model): 
    id = db.Column(db.Integer,primary_key=True) 
    username = db.Column(db.String(50)) 
    addresses = db.relationship('Address',backref='user') 

    def __init__(self,username): 
        self.username = username

class Address(db.Model): 
    id = db.Column(db.Integer,primary_key=True) 
    email_address = db.Column(db.String(50)) 
    user_id = db.Column(db.Integer,db.ForeignKey('user.id')) 

    def __init__(self,email_address): 
        self.email_address = email_address

# app.py
from flask import Flask
from ext import db

app = Flask(__name__)
db.init_app(app)

@app.route('/')
def hello_world():
    return 'Hello World!'

if __name__ == '__main__':
    app.run()

flask db init

flask db migrate

flask db upgrade