flask-SQLALchemy连接数据库的实现示例

@app.before_first_request
#只有第一次请求之前调用，可以在此方法内部做一些初始化操作


@app.before_request
#每次请求之前都会触发
#在每一次请求之前调用，这时候已经有请求了，可能在这个方法里面做请求的校验
#如果请求的校验不成功，可以直接在此方法中进行响应，直接return之后那么就不会执行视图函数

@app.after_request
#在每次执行完视图函数之后会调用，要传入函数响应
#在执行完视图函数之后会调用，并且会把视图函数所生成的响应传入，可以在此方法中对应响应做最后一步统一的处理

@app.teardown_request
#每一次请求之后都会调用，会接受一个参数，参数是服务器出现的错误信息

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

#import pymysql
#pymysql.install_as_MySQLdb()

"""
Python2中数据库客户端： MySqldb
python3中数据库客户端：pymysql
解决方案一：让python2和python3的包进行转换。
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) #创建一个对象，设置名为db

# app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://账号:密码@数据库ip地址:端口号/数据库名"
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"
# app.config['SQLALCHEMY_BINDS'] = {}

# 关闭数据库修改跟踪操作[提高性能]，可以设置为True，这样可以跟踪操作：
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False

# 开启输出底层执行的sql语句
app.config['SQLALCHEMY_ECHO'] = True

# 开启数据库的自动提交功能[一般不使用]
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) #创建一个对象，设置名为db


#建立数据库连接
#app.config['SQLALCHEMY_DATABASE_URI'] = "mysql://账号:密码@数据库ip地址:端口号/数据库名"
app.config['SQLALCHEMY_DATABASE_URI'] = "mysql+pymysql://root:mysql@192.168.44.128:3306/test39"



验证是否连接成功
@app.route('/')
def hello_word():

	engine = db.get_engine()
	conn = engine.connect()
	conn.close() #跟open函数一样，可以用with语句
	#with engine.connect() as conn:
	#	result = conn.execute('select 1')  #这两步打开数据库并且创建表
	#	print (result.fetchone()) #打印一条数据
    return "hello, word"



创建模型并进行数据增删改查
#创建orm模型---
class mmm(db.Model):
	__tablename__ = 'mmm'  # 设置表名
	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()
    # 创建所有继承自db.Model的表
    #db.create_all()


数据操作——增删改查
1：给模型对象设置数据 可以通过 初始化参数 或者 赋值属性 两种方式
2：session.add(模型对象) 添加单条数据到会话中, session.add_all(列表) 添加多条数据到会话中
3：sqlalchemy 会 自动创建事务, 并将数据操作包含在事务中, 提交会话时就会提交事务，事务提交失败会自动回滚。

@app.route('/mmm")
def mmm_view():
	#1. 添加数据
	# sql语句为 insert table mmm value （xxx），这里不用
	#之前创建了mmm类对象，所以直接调用即可
	article = mmm（title= "",content=""）
	
	#数据添加
	db.session.add(article)  
	#数据提交
	db.session.commit()
	#最后进行返回操作
	return "数据操作成功"
	
	#2.查询数据
	# filter_by() 返回一个类列表的对象
	artice = mmm.query.filter_by(id=1)[0] #进行查询，根据谁进行查询,必须用 []将值取出来
	print（artice.title） #将id为1的title取出来
	return	"数据操作成功"


	#3.修改数据
	artice = mmm.query.filter_by(id=1)[0] 
	artice.content = "xxx"  #将id为一的content的数据改成xxx
	#修改数据的进行数据提交
	db.session.commit
	return "数据操作成功"


	#4.删除数据
	mmm.query.filter_by(id=1).delete()
	db.session.commit()
	return "数据操作成功"

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



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

	#外键
	#1.外键的数据类型一定要看所引用的字段类型，要一样
	#2. db.Foreignkey("表名. 字段名")
	#3.外键是属于数据库层面的，不推荐直接在ORM直接使用
	author_id = db.Column(db.Integer,db.Foreignkey("user.id"))


	#relationship
	#1.第一个参数是模型的名字，必须要和模型的名字一致
	#2.backref（bsck reference）：代表反向引用，代表对方访问我的时候的字段名称
	author = db.relationship("user",backref="articles")


	#一对一：
	# db.backref
	#1. 在反向引用的时候，如果需要传递一些其他的参数，那么就需要用到这个函数，否则不需要使用，只要在relationship的backref参数上，设置反向引用的名称就可以了。
	#2. uselist=Flase ：代表反向引用的名称就可以了
	user = db.relationship("User",backref=db.backref("extension",uselist=Flase))

pip install flask-migrate

要让Flask-Migrate能够管理app中的数据库，需要使用Migrate(app,db)来绑定app和数据库。假如现在有以下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和数据库
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