flask_sqlalchemy简单增删查改操作

使用sqlalchemy连接mysql

sqlalchemy是python中著名的orm框架，通过这个框架我们可以不用关心sql语句，就能操作数据库。大大的提高开发效率。当然通过orm来操作数据库会执行很多的数据库冗余操作，降低程序的运行效率。不过既然选择使用python来编写程序，那么这么这点开销和开发效率相比就显得不值一提了。

先安装sqlalchemy和pymysql，安装之后就是连接数据库(使用mysql）：

mysql路径：“mysql+pymysql：//username+password@host:prot/database”

pymysql:通过sqlalchemy连接数据库必须要通过相应的数据库驱动来连接，这里pymysql为mysql的驱动

username:数据库的用户名

password:数据库的用户密码

host：连接的数据库的域名，如果你是默认状态下启动的那么你的ip名就是127.0.0.1，如果你更改了默认的ip，那么就是你更改后的ip

port：端口号，数据库连接的默认状态下端口通常为3306

database:连接的数据库名

注意：如果是用mysql数据库来操作的话，要记得下载pymysql的驱动

下面是 Flask-SQLAlchemy 中存在的配置值。

SQLALCHEMY_DATABASE_URI	用于连接数据的数据库。例如：· sqlite:////tmp/test.db· mysql://username:password@server/db
SQLALCHEMY_BINDS	一个映射绑定 (bind) 键到 SQLAlchemy 连接 URIs 的字典。更多的信息请参阅绑定多个数据库。
SQLALCHEMY_ECHO	如果设置成 True，SQLAlchemy 将会记录所有发到标准输出(stderr)的语句，这对调试很有帮助。
SQLALCHEMY_RECORD_QUERIES	可以用于显式地禁用或者启用查询记录。查询记录在调试或者测试模式下自动启用。更多信息请参阅 **get_debug_queries()**。
SQLALCHEMY_NATIVE_UNICODE	可以用于显式地禁用支持原生的 unicode。这是某些数据库适配器必须的（像在 Ubuntu 某些版本上的 PostgreSQL），当使用不合适的指定无编码的数据库默认值时。
SQLALCHEMY_POOL_SIZE	数据库连接池的大小。默认是数据库引擎的默认值（通常是 5）。
SQLALCHEMY_POOL_TIMEOUT	指定数据库连接池的超时时间。默认是 10。
SQLALCHEMY_POOL_RECYCLE	自动回收连接的秒数。这对 MySQL 是必须的，默认情况下 MySQL 会自动移除闲置 8 小时或者以上的连接。需要注意地是如果使用 MySQL 的话， Flask-SQLAlchemy 会自动地设置这个值为 2 小时。
SQLALCHEMY_MAX_OVERFLOW	控制在连接池达到最大值后可以创建的连接数。当这些额外的连接回收到连接池后将会被断开和抛弃。
SQLALCHEMY_TRACK_MODIFICATIONS	如果设置成 True (默认情况)，Flask-SQLAlchemy 将会追踪对象的修改并且发送信号。这需要额外的内存，如果不必要的可以禁用它。

sqlalchemy配置操作数据库创建表

init.py

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
#实例化flask 应用对象
app = Flask(__name__)
#在flask项目中，Session, Cookies以及一些第三方扩展都会用到SECRET_KEY值，这是一个比较重要的配置值。
app.config['SECRET_KEY'] = '123456'
# SQLALCHEMY_TRACK_MODIFICATIONS = True
#可以在请求结束时自动提交数据库数据,不用手动提交,
SQLALCHEMY_COMMIT_TEARDOWN = True
#用于连接的数据库 URI
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:root@localhost:3306/myweb?charset=utf8'
# 每次请求结束后都会自动提交数据库中的变动
app.config['SQLALCHEMY_COMMIT_ON_TEARDOWN'] = True
#查询时会显示原始SQL语句
app.config['SQLALCHEMY_ECHO'] = True
#实例化db对象
db = SQLAlchemy(app)

app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:root@localhost:3306/myweb?charset=utf8mb4'

注意：charset=utf8mb4运行时可能会报错，提示"#1115 - Unknown character set: 'utf8mb4'"

原因：可能是数据库版本的问题导致的，MYSQL5.5版本开始采用的是utf8mb4，如果数据库版本低于5.5的话是老的，要使用utf8。

models.py

数据库连接和sqlalchemy连接数据库代码一样，定义好数据库连接后，我们就可以定义模型了（注意：模型继承的类是db.Model，而不是Base,数据类型及列属性不用从sqlalchemy导入，直接从db导入即可），代码如下：

from Interface_Login_Test.web import db
class User(db.Model):
    #定义表名
    __tablename__ = 'user'
    # 防止表存在时重复生成表
    __table_args__ = {"useexisting": True}
    #开始添加表中需要的字段
    id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    username = db.Column(db.String(100),nullable=False,unique=True)
    password = db.Column(db.String(80),nullable=False)
    email = db.Column(db.String(120),nullable=False,unique=True)
    phone = db.Column(db.String(120), nullable=False,unique=True)
    img=db.Column(db.String(120), nullable=False)
    def __repr__(self):
        return '<User %r>' % self.username

创建模型后，我们让它映射到数据库中，db.create_all()
flag设置为0，就可以进行创建表，运行后查看数据库，就成功创建表了
其代码如下：

from  Interface_Login_Test.web.model import User
from Interface_Login_Test.web import db
if __name__=="__main__":
    flag=0
    #定义一个flag来进行开关，是创建表、情况表 还是要插入数据
    if flag==0:
        # db.drop_all() ##清空表
        db.create_all()#创建所有表，所有的db.Model
    if flag==1:
        tag0=User(username='aa',password='aaa',email="24456821@qq.com",phone='8001820',img='')
        tag1 = User(username='bb',password='bbb',email="822596810@qq.com",phone='13896520240',img='')
        db.session.add(tag0)
        db.session.add(tag1)
        db.session.commit()