Flask数据库的链接和模块

Flask SQLAlchemy操作数据库

1、Flask连接数据库：

（1）安装flask_sqlalchemy模块:

pip install flask_sqlalchemy

（2）设置配置信息：在config.py文件中添加配置信息：

DIALECT = 'mysql' 数据库类型

DRIVER = 'pymysql'  数据库的驱动

USERNAME = 'root'   数据库的用户名

PASSWORD = '123456' 数据库密码

HOST = 'localhost'  

PORT = '3306'   数据库的端口号

DATABASE = 'demo'   连接的数据库名称



SQLALCHEMY_DATABASE_URI = "{}+{}://{}:{}@{}:{}/{}?charset=utf8".format(DIALECT,DRIVER,USERNAME,PASSWORD,HOST,PORT,DATABASE)

注意：最后要将这些数据指向一个变量SQLALCHEMY_DATABASE_URI

python3中数据库的驱动选择pymysql，Python2中选择mysqldb

（3）在主app中初始化和配置数据库的配置信息：

使用flask_sqlalchemy中的SQLALchemy类进行初始化和配置：

• 导入flask_sqlalchemy模块的SQLALchemy类

• 导入config.py中的模块

from flask_sqlalchemy import SQLAlchemy

improt config



app.config.from_object(config)

db = SQLAlchemy(app)

(4）检测Flask是否成功连接数据库：

db.create_all()

没有报错则说明连接数据库成功

2、SQLALchemy模型和表格的映射：

（1）模型的继承：

模型需要继承自db.Model,然后需要映射表中的属性，需要写成db.Column的数据类型

（2）数据类型：

• db.Integer代表的是整型数据；

• db.String代表的是varchar，并且需要指定其最长的长度，例如：db.String(100)

• db.Text代表的是据库中的text类型

（3）其他的数据库参数：

• primary_key:代表的是这个字段是否设置成为主键；

• autoincrement:代表的是这个主键是否为自增长的；

• nullable:代表的是这个字段是否允许为空，默认可以为空，值为False时，为非空

（4）将模型真正地创建到数据库中：

db.create_all()

（5）例如：创建一个article的模型（表）：

class Article(db.Model):

    __tablename__ = 'article'

    id = db.Column(db.Integer,primary_key=True,autoincrement=True)

    title = db.Column(db.String(100),nullable=False)

    content = db.Column(db.Text,nullable=False)



db.create_all()

3、用SQLAlchemy对已存在数据库的操作：

• 实际上，使用SQLAlchemy对已存在的数据库和重新创建的数据库的方法是相同的：

查看表的构造：

desc table_name;

disc_website.png

在Flask工程文件中构造对象模型：

website_class.png

查询表中的数据：

result = Website.query.filter().all()

渲染在网页上：

jinja_web.png

四、创建两个表之间的关系和外键约束：

1、外键约束：

• 定义一个User表的模型：

class User(db.Model):
    __tablename__ = 'user_table'
    id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    username = db.Column(db.String(10),nullable=False)

• 定义一个Article的表的模型：

class Article(db.Model):
    __tablename__ = 'article table'
    id = db.Column(db.Integer,primary_key=True,autoincrement=True)
    title = db.Column(db.String(10),nullable=False)
    content = db.Column(db.Text,nullable=False)
    author_id = db.Column(db.Integer,db.ForeignKey('user_table.id'))

• author_id为User表对Article表的外键约束，Foreignkey方法传入的参数是模型的表名，外键的字段类型必须和外键表中的字段类型保持一致

2、创建两个表中的关系：

• 创建关系：

author = db.relationship('User',backref=db.backref('articles'))

• 给Article模型创建一个author的属性，可以利用这个属性通过article.author来访问到User模型中的作者属性，在通过.username的属性，可以查找到这个作者的作者名

• backref是定义反向引用，可以通过user_pushy.articles.content来查找到这个作者的文章内容

• 例如：查找所有文章的标题为‘aaa’的作者:

    article_aaa = Article.query.filter(Article.title == 'aaa').first()
    print(article_aaa.author.username)

找到用户名为'Pushy'写的文章的内容：

    article_pushy = User.query.filter(User.username =='Pushy').first()
    # 得到的result为列表类型：
    result = article_pushy.articles[0]
    print(result.content)