当前位置: 首页 > news >正文

flask数据库mysql增删查改_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)

注意: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 '' % 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()

flask_sqlalchemy简单增删查改操作

添加数据,对于上面新增的User我们可以使用db.session.add进行添加数据(User不是表名,是模型类)

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()

查询数据,

相关文章:

  • java基础语法的意义_关于java基础语法的学习笔记
  • java中容器试题_Java最常见208道面试题_容器
  • java 开启线程扫描程序_当多个线程在Java中使用System.in上的扫描仪...
  • java中结构体实现_JAVA中如何实现C中的结构体数组的功能?
  • java nio close_wait_Java NIO 操作总结
  • java zmq订阅_java zmq消息队列
  • java按键数据库添加_详解Java MyBatis 插入数据库返回主键
  • java ee jdbc_JavaEE JDBC 补充注意点
  • java 返回前台excel_Java后台读取excel表格返回至Web前端
  • eclipse for java web_【Javaweb】Eclipse for JavaEE新建的Web工程自动生成web.xml
  • gopython 获取python 全局线程锁失败_python线程互斥锁递归锁死锁
  • java collections 复制_Java公开课|Java Collections类查复制操作是你学习Java的超车途径,还不来看看就晚了...
  • java 线程的移动问题_Spring Boot中的多线程问题和ThreadLocal
  • Java 经常用到access_用Java连接到Microsoft Access 2007数据库的正确方法是什么?
  • java1.8 interface_JDK1.8新特性——FunctionInterface
  • 2017前端实习生面试总结
  • 4. 路由到控制器 - Laravel从零开始教程
  • Debian下无root权限使用Python访问Oracle
  • es6
  • Intervention/image 图片处理扩展包的安装和使用
  • JAVA并发编程--1.基础概念
  • Otto开发初探——微服务依赖管理新利器
  • React-flux杂记
  • REST架构的思考
  • Unix命令
  • 你不可错过的前端面试题(一)
  • 如何在 Tornado 中实现 Middleware
  • 阿里云移动端播放器高级功能介绍
  • #stm32整理(一)flash读写
  • $.ajax()
  • (06)Hive——正则表达式
  • (delphi11最新学习资料) Object Pascal 学习笔记---第8章第5节(封闭类和Final方法)
  • (论文阅读32/100)Flowing convnets for human pose estimation in videos
  • (篇九)MySQL常用内置函数
  • (十)c52学习之旅-定时器实验
  • (学习日记)2024.01.19
  • (转载)VS2010/MFC编程入门之三十四(菜单:VS2010菜单资源详解)
  • ./indexer: error while loading shared libraries: libmysqlclient.so.18: cannot open shared object fil
  • .NET CORE 第一节 创建基本的 asp.net core
  • .NET Framework杂记
  • .NET NPOI导出Excel详解
  • .Net Remoting(分离服务程序实现) - Part.3
  • .NET 常见的偏门问题
  • .Net(C#)常用转换byte转uint32、byte转float等
  • .NET/C# 编译期能确定的字符串会在字符串暂存池中不会被 GC 垃圾回收掉
  • .Net通用分页类(存储过程分页版,可以选择页码的显示样式,且有中英选择)
  • .NET微信公众号开发-2.0创建自定义菜单
  • @Query中countQuery的介绍
  • [100天算法】-x 的平方根(day 61)
  • [ajaxupload] - 上传文件同时附件参数值
  • [ARC066F]Contest with Drinks Hard
  • [C++] 统计程序耗时
  • [CC-FNCS]Chef and Churu
  • [CSS3备忘] transform animation 等
  • [flink总结]什么是flink背压 ,有什么危害? 如何解决flink背压?flink如何保证端到端一致性?