当前位置：首页>后端>正文

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程

后端2024-04-28 18:50:29

Flask-SQLAlchemy数据库操作指南一.Flask-SQLAlchemy的介绍与安装

ORM: Object Relationship Mapping（模型关系映射）

flask-sqlalchemy是一套ORM框架

ORM的好处：可以让我们操作数据库跟操作对象是一样的，非常方便；一个表就抽象成一个类，一条数据就抽象成该类的一个对象

安装‘flask-sqlalchemy’:‘sudo pip instal flask-sqlalchemy’

二.Flask-SQLAlchemy 的使用

初始化和设置数据库配置信息

使用flask_sqlalchemy 中的SQLAlchemy进行初始化：

from flask_sqlalchemy import SQLAlchemy
app = Flask(_name_)
db = SQLAlchemy(app)

设置配置信息：在"config.py"文件中添加配置信息：

mysql数据库连接代码

#--------------------服mysql务器配置-----------------------
#连接服务器
DIALECT = 'mysql'
DRIVER ='mysqldb'
HOSTNAME = '127.0.0.1'
PORT     = '3306'
DATABASE = 'pi_db'
USERNAME = 'root'
PASSWORD = '123456'

#python3中的formate格式，构建连接字符串
DB_URI = '{}+{}://{}:{}@{}:{}/{}?charset=utf8'.format(DIALECT,DRIVER,USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
SQLALCHEMY_DATABASE_URI = DB_URI

#取消警告
SQLALCHEMY_TRACK_MODIFICATIONS = False
# #--------------------服务器配置-----------------------

mssql数据库连接代码(不能使用字典)

import pymssql
#--------------------mssql服务器配置-----------------------
# 连接数据库
conn = pymssql.connect(server='.', user='sa', password='xc1234', database='asData')

# 打开游标
cur = conn.cursor()

if not cur:
    raise Exception('数据库连接失败！')

# 执行sql获取数据，获取as_user用户表所有数据
sSQL = 'select * from [dbo].[as_user]'
cur.execute(sSQL)

# 将所有数据保存在result列表中，并打印
result = cur.fetchall()
print(result)

cur.close()
conn.close()

# 关闭警告，否则会有警告提示
SQLALCHEMY_DATABASE_URI = False
SQLALCHEMY_TRACK_MODIFICATIONS = False
#--------------------服务器配置-----------------------

在app主文件中添加配置文件

在主‘app’文件中，添加配置文件

from flask import Flask
import config
app = Flask(__name__)
app.config.from_object(config)
db = SQLAlchemy(app)

做测试，看有没有问题

如果没有报错，说明配置没有问题,如果有错误，可以根据错误进行修改

db.create_all()

三.创建模型与表的映射

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

db.Integer 代表的是整数
db.String 代表的是varchar，需要指定最长的长度
db.Text 代表的是text

其他参数

primary_key ：代表的是将这个字段设置为主键
autoincrement：代表这个主键为自增长的
nullable：代表的是这个字段是否可以为空，默认是可以为空，将这个值设置成false，在数据库中，这个值就不能为空了

最后调用“db.create_all”来将模型真正的创建到数据库中

config配置文件中代码

#--------------------服mysql务器配置-----------------------
#连接服务器
DIALECT = 'mysql'
DRIVER ='mysqldb'
HOSTNAME = '127.0.0.1'
PORT     = '3306'
DATABASE = 'dbdemo2'
USERNAME = 'root'
PASSWORD = '123456'

#python3中的formate格式，构建连接字符串
DB_URI = '{}+{}://{}:{}@{}:{}/{}?charset=utf8'.format(DIALECT,DRIVER,USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
SQLALCHEMY_DATABASE_URI = DB_URI

#取消警告
SQLALCHEMY_TRACK_MODIFICATIONS = False
# #--------------------服务器配置-----------------------

主app文件代码

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config


app = Flask(__name__)
app.config.from_object(config)

db =SQLAlchemy(app)

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()
@app.route('/')
def hello_world():
    return 'Hello World!'


if __name__ == '__main__':
    app.run()

运行后，发现数据库中已出现创建的表

四.数据的增删改查操作

增紧接以上实例代码在hello world视图函数下编写启动服务后，运行一次该视图函数就会运行增加命令一次

#增加
        article1= Article(title='ming',content='good')
        db.session.add(article1)
        #事务
        db.session.commit()

运行前数据库中没有数据，运行后结果，出现刚才编写的数据

#查（.first()是符合条件的第一条数据,所有数据是.all()）
		#select * from article where article.title='aaa';
        article1=Article.query.filter(Article.title=='ming').first()
        print('title:%s'%article1.title)
        print('content:%s'%article1.content)

依然接着上面示例代码，运行一次视图文件，就执行一次查询操作

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import config


app = Flask(__name__)
app.config.from_object(config)

db =SQLAlchemy(app)

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()
@app.route('/')
def hello_world():

    #查询
    # select * from article where article.title='aaa';
    article1 = Article.query.filter(Article.title == 'aaa').first()
    print('title:%s' % article1.title)
    print('content:%s' % article1.content)
    return 'Hello World!'


if __name__ == '__main__':
    app.run()

结果如下图所示

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_User,第1张

可以将查询的结果返回给前台主app中

from flask import Flask,render_template
from flask_sqlalchemy import SQLAlchemy
import config


app = Flask(__name__)
app.config.from_object(config)

db =SQLAlchemy(app)

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()
@app.route('/')
def hello_world():

    #增加
    # article1= Article(title='aaa',content='xxxxxxx')
    # db.session.add(article1)
    # db.session.commit()

    #查询
    # select * from article where article.title='aaa';
    article1 = Article.query.filter(Article.title == 'aaa' ).first()
    # print('title:%s' % article1.title)
    # print('content:%s' % article1.content)
    return render_template('index.html',article1=article1)


if __name__ == '__main__':
    app.run()

前台接受代码

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
    <p>{{ article1.title }}</p>
    <hr>
    <p>{{ article1.content }}</p>
</body>
</html>

结果

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_数据库_02,第2张

3. 改

#修改
        #1.把需要修改的数据查询出来
        article1=Article.query.filter(Article.title == 'ming').first()
        #2.把这条数据，你想要修改的地方修改
        article1.title='new title'
        #3.做事务的提交
        db.session.commit()

主app中代码

from flask import Flask,render_template
from flask_sqlalchemy import SQLAlchemy
import config


app = Flask(__name__)
app.config.from_object(config)

db =SQLAlchemy(app)

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()
@app.route('/')
def hello_world():

    #增加
    # article1= Article(title='aaa',content='xxxxxxx')
    # db.session.add(article1)
    # db.session.commit()

    #查询
    # select * from article where article.title='aaa';
    article1 = Article.query.filter(Article.title == 'bbb' ).first()
    #修改
    article1.title = 'sunshine'
    db.session.commit()
    return render_template('index.html',article1=article1)

if __name__ == '__main__':
    app.run()

前端代码index.html结果,查询要修改的数据，修改完成后，显示出新的数据

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_flask_03,第3张

数据库

#删除
        #1.把需要删除的数据查询出来
        article1=Article.query.filter(Article.title == 'ming').first()
        #2.把这条数据删除
        db.session.delete(article1)
        #3.做事务的提交
        db.session.commit()

删除后再执行会报错

五.外键及其关系

外键两张表

# 用户表
class User(db.Model):
    _tablename_ = 'user'
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    title = db.Column(db.String(100), nullable=False)
# 文章表
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)
    author_id =db.Column(db.Integer,db.foreignKey('User.id'))
    author = db.relationship('User',backref=db.backref('articles'))

主app代码

from flask import Flask, render_template
from flask_sqlalchemy import SQLAlchemy
import config

app = Flask(__name__)
app.config.from_object(config)

db = SQLAlchemy(app)


# 用户表
class User(db.Model):
    _tablename_ = 'user'
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    username = db.Column(db.String(100), nullable=False)


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)
    author_id = db.Column(db.Integer,db.ForeignKey('user.id'))
    author = db.relationship('User', backref=db.backref('articles'))


db.create_all()


@app.route('/')
def hello_world():
    # 增加一个用户
    # user3=User(username='孙悟空')
    # article2=Article(title='大话西游',content='最好看的书xxoo',author_id='1')
    # db.session.add(user3)
    # db.session.add(article2)
    # db.session.commit()
    # 找到大话西游这篇文章的作者~方法一
    article1 =Article.query.filter(Article.title=='大话西游').first()
    author_id1 =article1.author_id
    user1 =User.query.filter(User.id==author_id1).first()
    print('username:%s'%user1.username)
    # 找到大话西游这篇文章的作者~方法二
    article = Article.query.filter(Article.title=='大话西游').first()
    print('username:%s'%article.author.username)

    #找到孙悟空写的所有文章
    user = User.query.filter(User.username== '孙悟空').first()
    result = user.articles
    for article in result:
        print(article.title)
    return render_template('index.html')

if __name__ == '__main__':
    app.run()

注意事项
对已经创建过的表，无法进行外键创建，即,db.creat_all()只能作用一次，通过此方法，无法给已经存在的表增加外键链接
新标创建成功后，可通过navicate查看外键关系
结果

释义 author = db.relationship(‘User’,backref=db.backref(‘articles’))

给Article这个模型添加一个author属性，可以访问这篇文章的作者的数据，像访问普通模型一样
backref是定义反向引用，也可以通过user这个模型访问这个模型缩写的所有文章

多对多

多对多的关系，要通过一个中间表进行关联
中间表，不能通过class的方式实现，只能通过db.Table的方式实现
设置关联：‘tags = db.relationship(‘Tag’,secondary=artic_tag,backref(‘articles’))’ 需要使用一个中间字参数**secondary=**中间表’进行关联
访问和数据库添加可以通过以下方式进行操作
添加数据
常规sql语句

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_flask_04,第4张

主app中代码，首先建立两张表，并构建中间表，然后往三张表里添加数据及多对多关系，最后实现应用

from flask import Flask, render_template
from flask_sqlalchemy import SQLAlchemy
import config

app = Flask(__name__)
app.config.from_object(config)

db = SQLAlchemy(app)

# 中间表
article_tag = db.Table(
    'article_tag',
    db.Column('article_id', db.Integer, db.ForeignKey('article.id'), primary_key=True),
    db.Column('tag_id', db.Integer, db.ForeignKey('tag.id'), primary_key=True)
)


# 文章表
class Article(db.Model):
    __tablename__ = 'article'
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    title = db.Column(db.String(100), nullable=False)

    tags = db.relationship('Tag', secondary=article_tag, backref=db.backref('articles'))


# 标签表
class Tag(db.Model):
    __tablename__ = 'tag'
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    name = db.Column(db.String(100), nullable=False)


db.create_all()


@app.route('/')
def hello_world():
    #分别添加article和tag表中添加数据，并在中间表中添加关系
    # article1 = Article(title='aaa')
    # article2 = Article(title='bbb')
    #
    # tag1 = Tag(name='111')
    # tag2 = Tag(name='222')
    #
    # article1.tags.append(tag1)
    # article1.tags.append(tag2)
    #
    # article2.tags.append(tag1)
    # article2.tags.append(tag2)
    #
    # db.session.add(article1)
    # db.session.add(article2)
    # db.session.add(tag1)
    # db.session.add(tag2)

    # db.session.commit()

    #数据应用
    article1=Article.query.filter(Article.title=='aaa').first()
    tags =article1.tags
    for tag in tags:
        print(tag.name)

    return 'Hello World!'


if __name__ == '__main__':
    app.run()

访问数据结果

六.flask-script的介绍与安装

flask-script的作用是可以通过命令行的形式来操作flask。例如，通过命令跑一个开发版本的服务器、设置数据库，定时任务等
安装
如果直接在主manage.py中写命令，那么在终端就只需要’python manage.py command_name’就可以了
如果把一些命令集中在一个文件中，那么在终端就需要输入一个父命令，比如，python manage.py db init
例子

主文件中的命令，直接调用即可
有子命令时，需要加上db
例子
主manage.py中

# manage.py
from flask_script import Manager
from app import app
from db_scripts import DBmanager

manager = Manager(app)


# 和数据库相关的所有操作，我都放在一起，新建一个文件db_scripts
# 第一步：新建db_scripts文件
# 第二步：新文件中，从flask_scripts导入Mannager
# 第三步：编写dbmanager文件
# 第四步：将dbmanager引入到主manage文件
@manager.command
def runserver():
    print('服务器跑起来了')


manager.add_command('db', DBmanager)

if __name__ == '__main__':
    manager.run()

子manage文件db_scripts.py中代码

from flask_script import Manager

DBmanager = Manager()

@DBmanager.command
def init():
    print('数据初始化完成')

@DBmanager.command
def migrate():
    print('数据迁移成功')

使用方法：windows下默认打开是在c盘，输入 cd …,返回c盘根目录，然后输入E:,cd到项目根目录下；输入命令即可
如图所示

七.分开models以及解决循环引用

分开models的目的：为了让代码更加方便的管理
如何解决循环引用：把“db”放在一个单独的文件中，切断循环引用的线条就可以了

三个文件分别是

主app文件app.py
模型文件models.py
拓展文件exts.py

主app文件代码

from flask import Flask,render_template
from exts import db
import config
from models import Article

app = Flask(__name__)
app.config.from_object(config)
db.init_app(app)
# db.create_all()

@app.route('/')
def hello_world():

    # # 增加
    # article1 = Article(title='ming',content='xxoo')
    # db.session.add(article1)
    # # 事务
    # db.session.commit()

    #查询
    article1 = Article.query.filter(Article.title == 'ming').first()

    return render_template('index.html',article1=article1)


if __name__ == '__main__':
    app.run()

模型文件models代码

from exts import db

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.String(100), nullable=False)

拓展文件代码

from flask_sqlalchemy import SQLAlchemy

#第三方拓展库
db = SQLAlchemy()

关系图

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_数据库_05,第5张

八.flask-migrate的介绍与安装

介绍：因为采用db.create_all在后期修改字段的时候，不会自动的映射到数据库中，必须删除表，然后重新运行db.create_all才会重新映射，这样不符合我们的要求。因此，flask-migrate就是为了解决这个问题，他可以在每次修改模型后，可以将修改的东西映射到数据库中 * 使用以下语句，将app手工推到服务器的app栈上，这样访问服务器上的app才可以访问的到

with app.app_context():
    db.create_all()

安装：进入到虚拟环境中，执行命令pip install flask-migrate 进行安装就可以了
使用‘flask_migrate’必须借助flask_scripts,这个包的MigrateCommand包含了所有和数据库相关的命令
flask_migrate 相关的命令

python manage.py db init :初始化一个迁移脚本的环境，只需要执行一次
python manage.py db migrate :将模型生成迁移文件，只要模型更改了，就需要执行一遍这个命令
python manage.py db upgrade :将这个文件真正的映射到数据库中，灭磁运行migrate命令后，就要机的运行这个命令

注意点：需要将你想要映射到数据库中的模型，都要导入到manage.py文件中，如果没有导入进去，就不会映射到数据库中
相关代码

在上例的代码基础上增加，manage.py 代码如下：

from flask_script import Manager
from app import app
from flask_migrate import  Migrate,MigrateCommand
from exts import db
from models import Article

#init
#migrate
#upgrade
#模型~迁移文件~表
manager =Manager(app)
#第一步：要使用flask_migrate,必须绑定app和db
migrate =Migrate(app,db)
#第二步：把migrateCommand命令添加到manager中
manager.add_command('db',MigrateCommand)

if __name__=='__main__':
    manager.run()

windows下cmd进入虚拟环境，并找到对应项目manage.py路径执行以下三步命令 * 1. python manage.py db init * 2. python manage.py db migrate

* 3. python manage.py db upgrade

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_User_06,第6张

执行完第一步后，项目中出现migrations迁移文件

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_flask_07,第7张

执行完第二步后，映射文件中versions中将会出现记录文件
执行完第三步后，数据库中将出现迁移版本记录表

Flask sqlalchemy 实现增改删查 flask sqlalchemy教程,Flask sqlalchemy 实现增改删查 flask sqlalchemy教程_User_08,第8张

以后如果该模型增加字段，有更新需要映射到数据库中，则只执行第二、三步即可

查看全文

https://www.xamrdz.com/backend/3re1937471.html