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

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

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

ORM: Object Relationship Mapping(模型关系映射)

flask-sqlalchemy是一套ORM框架

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

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

二.Flask-SQLAlchemy 的使用

  1. 初始化和设置数据库配置信息
  • 使用flask_sqlalchemy 中的SQLAlchemy进行初始化:
from flask_sqlalchemy import SQLAlchemy
app = Flask(_name_)
db = SQLAlchemy(app)
  1. 设置配置信息:在"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
#--------------------服务器配置-----------------------
  1. 在app主文件中添加配置文件
  • 在主‘app’文件中,添加配置文件
from flask import Flask
import config
app = Flask(__name__)
app.config.from_object(config)
db = SQLAlchemy(app)
  1. 做测试,看有没有问题
  • 如果没有报错,说明配置没有问题,如果有错误,可以根据错误进行修改
db.create_all()

三.创建模型与表的映射

  1. 模型需要继承db.Model,然后需要映射到表中的属性,必须写成db.Colum的数据类型
  2. 数据类型
  • db.Integer 代表的是整数
  • db.String 代表的是varchar,需要指定最长的长度
  • db.Text 代表的是text
  1. 其他参数
  • primary_key :代表的是将这个字段设置为主键
  • autoincrement:代表这个主键为自增长的
  • nullable:代表的是这个字段是否可以为空,默认是可以为空,将这个值设置成false,在数据库中,这个值就不能为空了
  1. 最后调用“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()
  • 运行后,发现数据库中已出现创建的表

四.数据的增删改查操作

  1. 增 紧接以上实例代码 在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()

删除后再执行 会报错

五.外键及其关系

  1. 外键 两张表
# 用户表
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查看外键关系
  • 结果
  1. 释义 author = db.relationship(‘User’,backref=db.backref(‘articles’))
  • 给Article这个模型添加一个author属性,可以访问这篇文章的作者的数据,像访问普通模型一样
  • backref是定义反向引用,也可以通过user这个模型访问这个模型缩写的所有文章
  1. 多对多
  • 多对多的关系,要通过一个中间表进行关联
  • 中间表,不能通过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的介绍与安装

  1. flask-script的作用是可以通过命令行的形式来操作flask。例如,通过命令跑一个开发版本的服务器、设置数据库,定时任务等
  2. 安装
  3. 如果直接在主manage.py中写命令,那么在终端就只需要’python manage.py command_name’就可以了
  4. 如果把一些命令集中在一个文件中,那么在终端就需要输入一个父命令,比如,python manage.py db init
  5. 例子
  • 主文件中的命令,直接调用即可
  • 有子命令时,需要加上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以及解决循环引用

  1. 分开models的目的:为了让代码更加方便的管理
  2. 如何解决循环引用:把“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的介绍与安装

  1. 介绍:因为采用db.create_all在后期修改字段的时候,不会自动的映射到数据库中,必须删除表,然后重新运行db.create_all才会重新映射,这样不符合我们的要求。因此,flask-migrate就是为了解决这个问题,他可以在每次修改模型后,可以将修改的东西映射到数据库中 * 使用以下语句,将app手工推到服务器的app栈上,这样访问服务器上的app才可以访问的到
with app.app_context():
    db.create_all()
  1. 安装:进入到虚拟环境中,执行命令pip install flask-migrate 进行安装就可以了
  2. 使用‘flask_migrate’必须借助flask_scripts,这个包的MigrateCommand包含了所有和数据库相关的命令
  3. flask_migrate 相关的命令
  • python manage.py db init :初始化一个迁移脚本的环境,只需要执行一次
  • python manage.py db migrate :将模型生成迁移文件,只要模型更改了,就需要执行一遍这个命令
  • python manage.py db upgrade :将这个文件真正的映射到数据库中,灭磁运行migrate命令后,就要机的运行这个命令
  1. 注意点:需要将你想要映射到数据库中的模型,都要导入到manage.py文件中,如果没有导入进去,就不会映射到数据库中
  2. 相关代码
  • 在上例的代码基础上增加,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

相关文章: