Flask之Sqlalchemy

pip instal flask-sqlalchemy

# 两种配置数据库方法
第一种app.config

from flask import Flask
import pymysql
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
# 数据库链接的配置，此项必须，格式为（数据库+驱动://用户名:密码@数据库主机地址:端口/数据库名称）
# app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123@127.0.0.1:3306/test'
# app.config['SQLALCHEMY_DATABASE_URI']='sqlite:///'+'数据库存放位置'
basedir = os.path.abspath(os.path.dirname(__file__))
app.config['SQLALCHEMY_DATABASE_URI'] = 'sqlite:///' + os.path.join(basedir, 'data.db')

# 跟踪对象的修改，在本例中用不到调高运行效率，所以设置为False
app.config['SQLALCHEMY_TRACK_MODIFICATIONS']=Flask 
app.secret_key='ssssseweweq'
db=SQLAlchemy(app)

第二种 写在配置文件config中
import pymysql

class Config(object):
    # 数据库链接的配置，此项必须，格式为（数据库+驱动://用户名:密码@数据库主机地址:端口/数据库名称）
    SQLALCHEMY_DATABASE_URI = 'mysql+pymysql://root:root123456@49.233.175.110:3306/db'
    SQLALCHEMY_TRACK_MODIFICATIONS = True  # 跟踪对象的修改，在本例中用不到调高运行效率，所以设置为False
    SCHEDULER_API_ENABLED = True
设置ext配置文件
from flask_sqlalchemy import SQLAlchemy
db = SQLAlchemy()
在创建models时导入
from HandlingProject.ext import db # 导入HandlingProject.ext文件下的db实例
class Userinfo(db.Model):  # 继承SQLAlchemy.Model对象，一个对象代表了一张表

create database sqlalchemy; # 创建数据库

class Userinfo(db.Model):  # 继承SQLAlchemy.Model对象，一个对象代表了一张表

    id= db.Column(db.Integer, primary_key=True, autoincrement=True, unique=True)  # id 整型，主键，自增，唯一
    username = db.Column(db.String(20))  # 名字 字符串长度为20
    password = db.Column(db.String(20))  # 年龄 整型，默认为20

    __tablename__ = 'userinfo'  # 该参数可选，不设置会默认的设置表名，如果设置会覆盖默认的表名

    def __init__(self, username, password):  # 初始化方法，可以对对象进行创建
        self.username = username
        self.password = password

db.create_all() # 运行models，连接数据库

# db.Column 中其余的参数指定属性的配置选项
primary_key   # 如果设为 True,这列就是表的主键
autoincrement # 如果设为 True,这列就是表的自增
unique        # 如果设为 True,这列不允许出现重复的值
index         # 如果设为 True,为这列创建索引,提升查询效率
nullable      # 如果设为 True,这列允许使用空值;如果设为 False,这列不允许使用空值
default       # 为这列定义默认值

session = Session()   # 实例化了一个会话（或叫事务），之后的所有操作都是基于这个对象的
事务对象，session必然有以下这些方法
session.commit()      # 提交会话（事务） 
session.rollback()    # 回滚会话 
session.close()       # 关闭会话

session = Session()    #创建session对象
frank = Students(name='Frank')    #数据对象得到创建，此时为Transient状态
session.add(frank)    #数据对象被关联到session上，此时为Pending状态
session.commit()    #数据对象被推到数据库中，此时为Persistent状态
session.close()    #关闭session对象
print(frank.name)    #此时会报错DetachedInstanceError，因为此时是Detached状态。

student = Student(Sno='10001', Sname='Frnak', Ssex='M', Sage=22, Sdept='SFS')
session.add(student)
session.commit()  # 不要忘了commit
session.close()

session.add_all(students)
session.commit()
session.close()

session.query(Student).filter(Student.Sname == 'Frank').first()
session.query(Student).filter_by(Sname == 'Frank').first()
# 注意filter与filter_by的区别

target = session.query(Student).filter(Student.Sname == "Kim").first()
target.Sname = "Kimmy"
session.commit()
session.close()
# 修改数据，先要找到目标数据。

target = session.query(Student).get("10001")
session.delete(target)
session.commit()
# 一样，要删除数据，就要先找到目标数据。