Flask用Flask

安装

pip3 install Flask-SQLAlchemy

测试环境目录结构

配置

settings.py

1DIALECT = 'mysql'
2    DRIVER = 'pymysql'
3    USERNAME = 'root'
4    PASSWORD = '808069'
5    HOST = '127.0.0.1'
6    PORT = '3306'
7    DATABASE = 'cms'
8
9    SQLALCHEMY_DATABASE_URI = '{}+{}://{}:{}@{}:{}/{}?charset=utf8'.format(
10        DIALECT,DRIVER,USERNAME,PASSWORD,HOST,PORT,DATABASE
11    )
12    SQLALCHEMY_COMMIT_ON_TEARDOWN = True
13    SQLALCHEMY_TRACK_MODIFICATIONS = True

连接

manage.py

1from flask_sqlalchemy import SQLAlchemy
2db = SQLAlchemy(app)

建表

models.py

1from manage import db
2
3class User(db.Model):
4    __tablename__ = 'user'
5    id = db.Column(db.INTEGER,primary_key=True)
6    username = db.Column(db.String(80),unique=True)
7    password = db.Column(db.String(80),nullable=False)
8
9class CodeCountRecord(db.Model):
10    __tablename = 'codecountrecord'
11    id = db.Column(db.INTEGER,primary_key=True)
12    count = db.Column(db.INTEGER)
13    data = db.Column(db.DATE)
14    user = db.Column(db.ForeignKey('user.id'))
15
16
17db.create_all()

然后直接右键运行models.py即可创建表

操作

增

1from cms.models import User
2from manage import db
3
4def create_user():
5    # 创建一个新用户对象
6    user = User()
7    user.username = 'fuyong'
8    user.password = '123'
9
10    # 将新创建的用户添加到数据库会话中
11    db.session.add(user)
12    # 将数据库会话中的变动提交到数据库中, 记住, 如果不 commit, 数据库中是没有变化的.
13    db.session.commit()
14
15create_user()

删

1def delete_user():
2    # 获取用户对象
3    user = User.query.filter_by(id=1).first()
4
5    # 删除用户
6    db.session.delete(user)
7
8    #提交数据库会话
9    db.session.commit()
10
11delete_user()

改

1def update_user():
2    # 获取用户对象
3    user = User.query.filter_by(id=2).first()
4
5    # 修改用户
6    user.password = '123567'
7
8    #提交数据库会话
9    db.session.commit()
10
11update_user()

查

1def select_user():
2    # 查询所有用户
3    users_list = User.query.all()
4
5    # 查询用户名称为 fuyong 的第一个用户, 并返回用户实例, 因为之前定义数据库的时候定义用户名称唯一, 所以数据库中用户名称为 test 的应该只有一个.
6    user = User.query.filter_by(username='fuyong').first()
7    # or
8    user = User.query.filter(User.username == 'fuyong').first()
9
10    # 模糊查询, 查找用户名以abc 结尾的所有用户
11    users_list = User.query.filter(User.username.endsWith('g')).all()
12
13    # 查询用户名不是 fuyong 的第一个用户
14    user = User.query.filter(User.username != 'fuyong').first()

循环导入的问题

如果上面的例子继续写下去的时候，我们或许会在视图views中引入models文件以操作数据，在models文件中引入manage文件中的db以定义类和字段，

然后在manage文件中引入views文件以注册蓝图（register_blueprint），这样就出现了a引入b，b引入c，c引入a的问题，就会报错，

解决办法就是另外创建一个ext.py文件，专门用来创建db，代码如下：

1from flask_sqlalchemy import SQLAlchemy
2
3db = SQLAlchemy()

　　注意：此时先不讲app传入

然后在manage.py文件中，导入db，然后初始化，将app传进去：

db.init_app(app)

这样，在视图中需要用db的之后直接从ext导入，而不再从manage里导入