SQLAlchemy快速入门

安装依赖

pip install sqlalchemy
pip install pymysql

创建数据库和表

# 创建数据库
drop database if exists sqlalchemy_demo;
create database sqlalchemy_demo character set utf8mb4;
use sqlalchemy_demo;# 创建表
drop table if exists user;
create table user
(id   int primary key auto_increment,name varchar(36)
) engine = innodbcharacter set utf8mb4;

新增用户

新增用户的核心代码是session.add(new_user),需要注意的是,在执行了增加以后,一定要紧接着执行session.commit()提交事务,否则新增将不会生效。

示例代码:

from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker, declarative_base# 创建对象的基类:
Base = declarative_base()# 定义User对象:
class User(Base):# 表的名字:__tablename__ = 'user'# 表的结构:id = Column(String(20), primary_key=True)name = Column(String(20))# 创建引擎
engine = create_engine("mysql+pymysql://root:zhangdapeng520@localhost:3306/sqlalchemy_demo?charset=utf8mb4")# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)# 创建session对象:
session = DBSession()# 创建新User对象:
new_user = User(id='1', name='张三')# 添加到session:
session.add(new_user)# 提交即保存到数据库:
session.commit()# 关闭session:
session.close()

根据ID查询用户

查询单个用户的核心代码是session.query(User).filter(User.id == '1').one(),通过这种方式,我们能够查询出指定ID的用户。

示例代码:

from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker, declarative_base# 创建对象的基类:
Base = declarative_base()# 定义User对象:
class User(Base):# 表的名字:__tablename__ = 'user'# 表的结构:id = Column(String(20), primary_key=True)name = Column(String(20))# 创建引擎
engine = create_engine("mysql+pymysql://root:zhangdapeng520@localhost:3306/sqlalchemy_demo?charset=utf8mb4")# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)# 创建session对象:
session = DBSession()# 创建Query查询,filter是where条件,最后调用one()返回唯一行,如果调用all()则返回所有行:
user = session.query(User).filter(User.id == '1').one()# 打印类型和对象的name属性:
print('type:', type(user))
print('name:', user.name)# 关闭Session:
session.close()

查询所有用户

查询所有用户的核心代码是session.query(User).all(),通过这种方式,我们能够得到一个用户数组,这个数组中包含所有的用户信息。

示例代码:

from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker, declarative_base# 创建对象的基类:
Base = declarative_base()# 定义User对象:
class User(Base):# 表的名字:__tablename__ = 'user'# 表的结构:id = Column(String(20), primary_key=True)name = Column(String(20))# 创建引擎
engine = create_engine("mysql+pymysql://root:zhangdapeng520@localhost:3306/sqlalchemy_demo?charset=utf8mb4")# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)# 创建session对象:
session = DBSession()# 查询所有用户
users = session.query(User).all()
print(users)
for u in users:print(u.id, u.name)# 关闭Session:
session.close()

根据id删除用户

根据id删除用户的核心代码是session.query(User).filter(User.id == "1").delete(),需要注意的是,一定要在执行删除以后,继续执行session.commit()提交事务,否则删除操作将不会生效。

示例代码:

from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker, declarative_base# 创建对象的基类:
Base = declarative_base()# 定义User对象:
class User(Base):# 表的名字:__tablename__ = 'user'# 表的结构:id = Column(String(20), primary_key=True)name = Column(String(20))# 创建引擎
engine = create_engine("mysql+pymysql://root:zhangdapeng520@localhost:3306/sqlalchemy_demo?charset=utf8mb4")# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)# 创建session对象:
session = DBSession()# 根据ID删除用户
session.query(User).filter(User.id == "1").delete()
session.commit()  # 一定要记得commit,否则不生效# 关闭Session:
session.close()

根据ID更新用户

使用with DBSession() as s格式的with代码块,with会自动帮我们调用close关闭方法,这样我们就不需要关系session的关闭了,能够节省一些代码和逻辑。不过commit方法还是需要我们自己手动进行调用。

更新用户的核心代码是s.query(User).filter(User.id == "1").update({"name": "张三333"}),需要注意的是,update方法跟的是一个字典,在字典中指定需要更新的键值对。

示例代码:

from sqlalchemy import Column, String, create_engine
from sqlalchemy.orm import sessionmaker, declarative_base# 创建对象的基类:
Base = declarative_base()# 定义User对象:
class User(Base):# 表的名字:__tablename__ = 'user'# 表的结构:id = Column(String(20), primary_key=True)name = Column(String(20))# 创建引擎
engine = create_engine("mysql+pymysql://root:zhangdapeng520@localhost:3306/sqlalchemy_demo?charset=utf8mb4")# 创建DBSession类型:
DBSession = sessionmaker(bind=engine)# 先增加用户
# 使用with的好处是,with代码块会自动帮我们调用close方法
# 注意:commit方法需要我们自己手动调用
with DBSession() as s:s.add(User(id="1", name="张三"))s.commit()# 根据ID更新用户
with DBSession() as s:s.query(User).filter(User.id == "1").update({"name": "张三333"})s.commit()# 根据ID查询用户
with DBSession() as s:user = s.query(User).filter(User.id == "1").one()print(user.id, user.name)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/599804.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

ClickHouse基础介绍

目录 前言 1、什么是clickhouse 2、OLAP场景的关键特征 3、列式存储更适合于OLAP场景的原因 4、clickhouse的独特功能 5、clickhouse的缺点 6、性能 6.1、单个大查询的吞吐量 6.2、处理短查询的延迟时间 6.3、处理大量短查询的吞吐量 6.4、数据的写入性能 前言 11月…

Keras实现seq2seq

概述 Seq2Seq是一种深度学习模型,主要用于处理序列到序列的转换问题,如机器翻译、对话生成等。该模型主要由两个循环神经网络(RNN)组成,一个是编码器(Encoder),另一个是解码器…

C++——list容器放入赋值,交换与大小操作

1. list 赋值和交换 功能描述: 给list容器进行赋值,以及交换list容器 函数原型: 1.assign(beg, end); //将[beg, end)区间中的数据拷贝赋值给本身 2.assign(n, elem); //将n个elem拷贝赋值给本身 3.list& operator(const list &lst);//重载等…

Dart调用JS对10000条定位数据滤波

使用Dart调用JS,还是为了练习跨语言调用; 一、编写对应的JS代码 平时在开发时不推荐将算法放在JS里,我这里是简单的做一下数据过滤; 首先生成一些随机定位数据,在实际开发中可以使用真实数据; // 随机定…

git 常用命令 提交commit

提交一个commit git status test.txt 查看 指定文件test.txt 的状态 git add test.txt 添加 指定文件test.txt 到暂存区 git commit test.txt -m "commit msg" 提交 指定文件test.txtgit status …

汽车信息安全--芯片厂、OEM安全启动汇总(1)

目录 1.芯驰E3安全启动 2.STM32 X-CUBE-SBSFU 3.小米澎湃OS安全启动 4.小结 我在前篇文章里详细记录了车规MCU信息安全设计过程关于网络安全架构的思考过程,从芯片原厂、供应商、OEM等角度思考如何建立起完备的信任链; 不过这思考过程仅仅只是一家之言,因此我又对比了国…

vmware虚拟机安装esxi7.0步骤

一、安装准备 1、下载镜像文件 下载链接:https://pan.baidu.com/s/12XmWBCI1zgbpN4lewqYw6g 提取码:mdtx 2、vmware新建一个虚拟机 2.1 选择自定义 2.2 选择ESXi对应版本 2.3 选择稍后安装操作系统 2.4 默认选择 2.5 自定义虚拟机名称及存储位置 2…

forEach方法跳出循环

在for循环中,跳出循环有两种模式: break、continue;但是在forEach中,使用break或者continue都会报错;使用return在forEach不起作用,循环会继续执行,貌似充当了continue的角色。 forEach方法的机…

MyBatis学习二:Mapper代理开发、配置文件完成增删改查、注解开发

前言 公司要求没办法,前端也要了解一下后端知识,这里记录一下自己的学习 学习教程:黑马mybatis教程全套视频教程,2天Mybatis框架从入门到精通 文档: https://mybatis.net.cn/index.html Mapper代理开发 目的 解决…

Jenkins分布式实现: 构建弹性和可扩展的CI/CD环境!

Jenkins是一个流行的开源持续集成(Continuous Integration,CI)和持续交付(Continuous Delivery,CD)工具,它通过自动化构建、测试和部署过程,帮助开发团队更高效地交付软件。Jenkins的…

element ui弹窗在别的弹窗下方,优先级不高的问题

在弹窗的标签中加入append-to-body即可解决该问题&#xff1b; <el-dialog:title"title":visible.sync"dialogVisible"width"60%":before-close"handleClose":close-on-click-modal"false"append-to-body > </el-…

Oracle sid和service_name(服务名)地址写法不同

文章目录 场景总结 场景 项目需要切换数据库&#xff0c;批量改完配置文件后发现怎么有的地址前有//&#xff0c;有的没有 &#xff0c;是不是哪里改错了 。 后来确认了下。 带// 的是使用service_name连接的方式&#xff0c;是没有错的。 1.使用service_name,配置方式&#…

a标签锚点链接 + 遇到的问题

目录 需求背景实现思路遇到的问题问题解决关于锚点链接其他问题 需求背景 页面左侧是一级、二级标题&#xff0c;页面右侧是一级、二级标题对应的内容点击左侧标题&#xff0c;锚点链接&#xff0c;右侧内容跳转到左侧标题对应的内容区域 实现思路 通过 a 标签 id 的方法实现…

嵌入式Linux之Ubuntu学习笔记(Makefile规则格式)

Makefile里面是由一系列的规则组成的&#xff0c;这些规则格式如下&#xff1a; 目标&#xff1a;依赖文件集合 命令1 命令2 …… 列&#xff1a; main&#xff1a;main.o input.o calcu.o gcc -o main main.o input.o calcu.o 命令列表中的每条命令必须以TAB键开始&am…

Mac——VsCode使用格式化工具进行整理和格式化

1. 打开VSCode编辑器。 2. 点击左下角⚙️图标&#xff0c;打开设置 3. 进入设置后&#xff0c;你会看到一个搜索框&#xff0c;在搜索框中输入 format on save 来查找相关设置项。 4. 在设置列表中找到 Editor: Format On Save 选项&#xff0c;勾选它以启用在保存文件时自动格…

LeetCode206链表反转

//我来理解一下运用递归求解 class Solution { public:ListNode* reverseList(ListNode* head) {//首先判断是否为最后一个元素if(head null|| head.next null){return head;//返回末尾元素}ListNode* receive;//此时进入循环的每一层都实现了temp接收head.next的结点进行…

详解bookkeeper AutoRecovery机制

引言小故事 张三在一家小型互联网公司上班&#xff0c;由于公司实行的996&#xff0c;因此经常有同事“不辞而别”&#xff0c;为了工作的正常推进&#xff0c;团队内达成了某种默契&#xff0c;这种默契就是通过某个规则来选出一个同事&#xff0c;这个同事除了工作之余还有额…

让人头痛事务问题到底要如何解决?

前言 正好前段时间我在公司处理过这个问题&#xff0c;我们当时由于项目初期时间比较紧张&#xff0c;为了快速完成业务功能&#xff0c;忽略了系统部分性能问题。项目顺利上线后&#xff0c;专门抽了一个迭代的时间去解决大事务问题&#xff0c;目前已经优化完成&#xff0c;并…

【2024最新版】Win11基础配置操作(磁盘分区、修改各种默认存储位置、安装软件操作)【释放C盘空间】

文章目录 一、硬盘分区0. 磁盘管理1. 压缩卷2. 新建简单卷向导 二、修改默认存储位置1. 保持新内容的地方a. 位置b. 操作 2. 快速访问六件套a. 位置b. 操作 三、安装软件0. 应用商店设置a. 设置中心b. 修改下载设置 1. 微信电脑版设置a. 下载b. 安装c. 聊天记录迁移与备份d. 存…

Charles的基础使用教程【Mac】

目录 1.安装 2.抓取https请求的前置操作 2.1安装证书&#xff1a; 2.2、SSL代理设置 3.Charles初识 1.安装 官网Charles下载安装即可&#xff0c;没有什么需要注意的地方 2.抓取https请求的前置操作 2.1安装证书&#xff1a; 未安装证书是这样的&#xff1a; 上述我们可…