SqlAlchemy使用教程(三) CoreAPI访问与操作数据库详解

在这里插入图片描述

  • SqlAlchemy使用教程(一) 原理与环境搭建
  • SqlAlchemy使用教程(二) 入门示例及编程步骤

三、使用Core API访问与操作数据库

Sqlalchemy 的Core部分集成了DB API, 事务管理，schema描述等功能，ORM构筑于其上。本章介绍创建 Engine对象，使用基本的 Sql Express Language 方法，以及如何实现对数据库的CRUD操作等内容。

1、创建DB engine 对象

1.1创建database engine 对象

Engine 是db连接管理类，
语法:

from sqlalchemy import create_engine
＃创建引擎对象
engine = create_engine("sqlite:///:memory:", echo=True)
＃连接数据库
conn = engine.connect()

Sqlalchemy.create_engine( ) 方法第1个参数是db连接表达式，格式为：

dialect[+driver]://user:password@host/dbname
  • dialect 通常为数据库类型，如sqlite, mysql, mongodb， etc.
  • driver 是python 访问数据库的包。
    如 sqlite+sqlite3, mysql+mysqlconnector

1.2 连接至各类数据库的配置

1.2.1 sqlite 连接

上面示例是sqlite的连接表达式。 Driver是python访问数据库的DBAPI库。

e = create_engine('sqlite:///path/to/database.db')

如果是绝对地址 sqlite:usr/local/myproject/database.db

:memory 表示使用内存数据库，不保存在硬盘。
对于windows 系统，

e = create_engine('sqlite:///C:\\myapp\\db\\main.db')
1.2.2 连接mysql

Mysql 的DBAPI，常用的有PyMysql 与 mysql-connector，其连接表达式分别为：

mysql+pymysql://root:123456@192.168.99.240:3306/testdb
mysql+mysqlconnector://roprot:123456@192.168.99.240:3306/testdb
1.2.3 连接PostgreSQL

通常使用的接口库为 psycopg2

postgresql+psycopg2://user:password@host:port/dbname[?key=value&key=value...]engine = create_engine("postgresql+psycopg2://scott:tiger@localhost/test",isolation_level="SERIALIZABLE",
)

Ssl连接

engine = sa.create_engine("postgresql+psycopg2://scott:tiger@192.168.0.199:5432/test?sslmode=require"
)
1.2.4 连接MongoDB
engine = create_engine("mongodb:///?Server=MyServer&Port=27017&Database=test&User=test&Password=Password")定义1个mapping类
base = declarative_base()
class restaurants(base):
__tablename__ = "restaurants"
borough = Column(String,primary_key=True)
cuisine = Column(String)

查询：

engine=create_engine("mongodb:///?Server=MyServer&Port=27017&Database=test&User=test&Password=Password")
factory = sessionmaker(bind=engine)
session = factory()
for instance in session.query(restaurants).filter_by(Name="Morris Park Bake Shop"):
print("borough: ", instance.borough)
print("cuisine: ", instance.cuisine)
print("---------")

1.3创建connect 对象

语法：

conn = engine.connect()

如

e = create_engine('sqlite:///C:\\myapp\\db\\main.db')
conn = e.connect()

推荐使用context with 语法使用connect对象

from sqlalchemy import create_engine, text
engine = create_engine('sqlite:///C:\\myapp\\db\\main.db')
with engine.connect() as connection:result = connection.execute(text("select username from users"))for row in result:print("username:", row["username"])

如果修改了数据，应调用 conn.commit() 提交transaction

2. SQL Express Language 常用方法

Sqlalchemy 对sql进行了封装，其SQL Express语法比直接使用sql 语句更方便，优势是传参与获取返回值更省事。

2.1 使用 text() 生成SQL Express语句

text()方法是CoreAPI中最基础的方法之一，主要作用，用于封装 sql 语句

from sqlalchemy import textt_sql = text("SELECT * FROM users")
result = connection.execute(t_sql)

传参：

t_sql = text("SELECT * FROM users WHERE id=:user_id")
result = connection.execute(t_sql, { ‘user_id’: 12 } )

如果使用r” “ ，则用 : 来表示:

2.2 bindparams() 方法传参

也可以通过 text(sql_statement).bindparams() 直接构建完整的SQL语句

from sqlalchemy import text, bindparams
stmt = text("SELECT id, name FROM user WHERE name=:name ""AND timestamp=:timestamp")
stmt = stmt.bindparams(name='jack',timestamp=datetime.datetime(2012, 10, 8, 15, 12, 5)
)
result = conn.execute(stmt)
print(result.all())

bindparams()中可添加参数Type检查：

from sqlalchemy import text
stmt = text("SELECT id, name FROM user WHERE name=:name ""AND timestamp=:timestamp")
stmt = stmt.bindparams(bindparam('name', type_=String),bindparam('timestamp', type_=DateTime)
)
stmt = stmt.bindparams(name='jack',timestamp=datetime.datetime(2012, 10, 8, 15, 12, 5))
result = conn.execute(stmt)
print(result.all())

3, 解析查询结果

查询结果类型为 sqlalchemy.engine.Result 类，是1个由 object 组成的列表。可以用多种方法访问：

  • all() ， return all rows in a list
  • columns(‘col_1’, ‘col_2’) 指定返回每row 的字段， iterable
  • fetchall(), fetchone(), fetchmany()
  • first() 返回第1行。
  • keys() 返回row的字段名， 是iterable 类型
  • mappings(), 列表元素为dict类型，
  • result.close() 关闭result对象

说明：

  • 遍历查询结果， all()- , fetchall(), fetchmany(), columns（）， 结果为： list[tuple,…], 或iterable,
  • 对row 字段， 可以用key, index ， row[0], row[‘id’], row[‘name’], 也可以用row.name ， 如
result = conn.execute(text("select x, y from some_table"))
for row in result:print(f"Row: {row.x} {row.y}")
  • result.mapping() 返回结果的row 类型为dict,
result = conn.execute(text("select x, y from some_table"))
for dict_row in result.mappings():x = dict_row["x"]y = dict_row["y"]

4. 使用connect 对象执行CRUD操作

SqlAlchemy可以用connect对象与 session 对象来执行SQL express
connect对象是直接调用DBAPI执行SQL语句，这是使用SqlAlchemy 最简单的方式,同时支持部分Sqlalchemy 的SQL Express 封装语法，但执行的SQL语句依然还要符合各数据库的接口库要求。
Session对象则实现了同1套接口适用于所有数据库。但主要用于ORM API方式。

connect对象操作数据库的好处：可使用text()方法生成SQL语句，利用bindparams() 传值，以及做类型检查。同时支持多线程访问数据库。

创建表的方法，前面已讲过。 下面示例为 insert, update, delete 操作

# insert row 
print("-"*50+"Insert operation")
stmt = text("INSERT INTO some_table VALUES(:x, :y)").bindparams(x=6,y=19)
with engine.connect() as conn:conn.execute(stmt)conn.commit()result = conn.execute( text("select * from some_table") )print(result.all())# update row 
print("-"*50+"update operation")
stmt = text("UPDATE some_table SET y=:y WHERE x=:x").bindparams(y=99,x=5)
with engine.connect() as conn:conn.execute(stmt)conn.commit()result = conn.execute( text("select * from some_table") )print(result.all())# delete row 
print("-"*50+"delete operation")
stmt = text("DELETE FROM some_table WHERE x=:x").bindparams(x=4)
with engine.connect() as conn:conn.execute(stmt)conn.commit()result = conn.execute( text("select * from some_table") )print(result.rowcount)print(result.all())

output:

--------------------------------------------------Insert operation
2023-12-03 15:50:36,978 INFO sqlalchemy.engine.Engine BEGIN (implicit)
2023-12-03 15:50:36,978 INFO sqlalchemy.engine.Engine INSERT INTO some_table VALUES(?, ?)
2023-12-03 15:50:36,978 INFO sqlalchemy.engine.Engine [generated in 0.00085s] (6, 19)
2023-12-03 15:50:36,979 INFO sqlalchemy.engine.Engine COMMIT
2023-12-03 15:50:36,980 INFO sqlalchemy.engine.Engine BEGIN (implicit)
2023-12-03 15:50:36,980 INFO sqlalchemy.engine.Engine select * from some_table
2023-12-03 15:50:36,981 INFO sqlalchemy.engine.Engine [generated in 0.00132s] ()
[(1, 1), (2, 4), (3, 10), (4, 11), (5, 25), (6, 19)]
2023-12-03 15:50:36,982 INFO sqlalchemy.engine.Engine ROLLBACK
--------------------------------------------------update operation[(1, 1), (2, 4), (3, 10), (4, 11), (5, 99), (6, 19)]
2023-12-03 15:50:36,985 INFO sqlalchemy.engine.Engine ROLLBACK
--------------------------------------------------delete operation
[(1, 1), (2, 4), (3, 10), (5, 99), (6, 19)]
2023-12-03 15:50:36,989 INFO sqlalchemy.engine.Engine ROLLBACK

5. 表间关系处理

Sqlalchemy 使用DBAPI处理表间关系语法是依据数据库规定, 但基本均支持标准SQL语法

5.1 创建外键字段的语法：

 CREATE TABLE tracks(……trackartist   INTEGER,     -- 外键字段
FOREIGN KEY(trackartist) REFERENCES artist(artistid)
)

辅表artist.id字段须为主键或unique index。

5.2 各种表间关系的实现方式：

  • One to one: 还是用 foreign key来实现。
  • One to many: 就是外键
  • Many to many： 需要中间表， 用2个foreign key 与两张表分别建立 one to many 关系。

示例 ：

import sqlalchemyfrom sqlalchemy import create_engine
from sqlalchemy import text
from sqlalchemy.orm import sessionmaker  engine = create_engine("sqlite:///order.db")# create table people 
with engine.connect() as conn:conn.execute(text("drop table if exists people;"))stmt = text("""CREATE TABLE people(id  integer PRIMARY KEY,name TEXT, age  INTEGER)""" )conn.execute(stmt)conn.execute(text("INSERT INTO people (id,name, age) VALUES (:id,:name, :age)"),[ {'id': 1, "name": 'Jack','age':30 }, {'id': 2, "name": 'Smith','age':28 }, {'id': 3, "name": 'Wang','age':35 }, ])conn.commit()result = conn.execute( text("select * from people") )print(result.rowcount)print(result.all())# create table order
# 创建会话（Session）  
with engine.connect() as conn: conn.execute(text("drop table if exists teams"))stmt_1 = text("""create table teams(id  integer PRIMARY KEY,team_name  TEXT, pid  integer,foreign key (pid) REFERENCES people(id))""")conn.execute(stmt_1)conn.commit()conn.execute(text("INSERT INTO teams (id, team_name, pid) VALUES (:id, :team_name, :pid)"),[ {'id': 101, "team_name": 'TV product','pid':1 }, {'id': 102, "team_name": 'Software development','pid':2 }, {'id': 103, "team_name": 'Electric development','pid':2 }, ])
conn.commit()# 跨表查询result = conn.execute( text("select a.id, a.team_name, b.name from teams as a left join people as b on a.pid=b.id") )print(result.rowcount)for row in result.mappings():print(row['id'], row['team_name'], row['name'])

6. 通过多线程访问Database

sqlalchemy的engine可做为全局变量， 将connect对象,或 session对象传入线程，实现多线程访问：

示例：

def thread_db(conn,name):try:  result = conn.execute( text("select * from people") )print(result.rowcount)print(f"thread {{ name }} result: ")print(result.all())except Exception as e:print("can't open connection object")finally: conn.close()from threading import Threadt1 = Thread(target=thread_db, args=(engine.connect(),"thread_a"))
t2 = Thread(target=thread_db, args=(engine.connect(),"thread_b"))
t1.start()
t2.start()
t1.join()
t2.join()
print("main thread is ended")
output: 
thread { name } result:
thread { name } result:
[(1, 'Jack', 30), (2, 'Smith', 28), (3, 'Wang', 35)]
[(1, 'Jack', 30), (2, 'Smith', 28), (3, 'Wang', 35)]
main thread is ended

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

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

相关文章

使用lodash原地起飞，总结了几个常用的lodash方法

使用lodash原地起飞，总结了几个常用的lodash方法

前言 📫 大家好，我是南木元元，热爱技术和分享，欢迎大家交流，一起学习进步！ 🍅 个人主页：南木元元 目录 什么是lodash lodash的按需引入 数组操作 求交集 求合集 求差集 求总和…
阅读更多...
如何使用C++编程使得在Windows和Linux输入密码的时候保密 linux：tcgetattr tcsetattr

如何使用C++编程使得在Windows和Linux输入密码的时候保密 linux：tcgetattr tcsetattr

在C编程中，在执行一些操作的时候，终端需要接收用户名和密码，那么在终端输入密码的时候，如何不让别人看见自己的密码，是一个较为关注的问题； 1、问题分析 定义一个登录函数Login //用户登录主循环bool Lo…
阅读更多...
Android蓝牙协议栈fluoride(十一) - 音乐播放(4)

Android蓝牙协议栈fluoride(十一) - 音乐播放(4)

上一篇介绍了蓝牙音频的播放通路和编解码器，接下来介绍Source和Sink如何选择编解码器以及编解码流程。 编解码器选择 连接蓝牙后想要播放音乐，需要协商使用哪种编码器，还需要协商编码器使用什么配置，前面介绍了如何协商编码器的…
阅读更多...
Redis分布式锁--java实现

Redis分布式锁--java实现

文章目录 Redis分布式锁方案：SETNX EXPIRE基本原理比较好的实现会产生四个问题 几种解决原子性的方案方案：SETNX value值是（系统时间过期时间）方案：使用Lua脚本(包含SETNX EXPIRE两条指令)方案：SET的扩展…
阅读更多...
低代码开发平台

低代码开发平台

低代码开发平台（LCDP）本身也是一种软件，它为开发者提供了一个创建应用软件的开发环境。看到“开发环境”几个字是不是很亲切？对于程序员而言，低代码开发平台的性质与IDEA、VS等代码IDE（集成开发环境&#x…
阅读更多...
蓝桥杯练习题（九）

蓝桥杯练习题（九）

📑前言 本文主要是【算法】——蓝桥杯练习题（九）的文章，如果有什么需要改进的地方还请大佬指出⛺️ 🎬作者简介：大家好，我是听风与他🥇 ☁️博客首页：CSDN主页听风与他 …
阅读更多...
Tomcat解压打包文件和并部署

Tomcat解压打包文件和并部署

一、文件压缩和上传解压 1.本地打包好dist.tar.gz文件 2.通过xftp拖拽上传到知道文件夹下，或者通过命令： cp dist.tar.gz /path/to/destination/folder注：将dist.tar.gz复制到 /path/to/destination/folder文件夹下，该文件夹只是举个例子怎么复制和解压！ 3.进入/path/…
阅读更多...
51-13 多模态论文串讲—BEiT v3 论文精读

51-13 多模态论文串讲—BEiT v3 论文精读

BEiT-3的核心思想是将图像建模为一种语言，这样我们就可以对图像、文本以及图像-文本对进行统一的mask modeling。Multi-way transformer模型可以有效地完成不同的视觉和视觉语言任务，使其成为通用建模的一个有效选择。 同时，本文也对多模态大…
阅读更多...
K8s-Pod资源（一）Pod介绍、创建Pod、Pod简单资源配额

K8s-Pod资源（一）Pod介绍、创建Pod、Pod简单资源配额

Pod概述 Kubernetes Pod | Kubernetes Pod是Kubernetes中的最小调度单元，k8s都是以pod的方式运行服务的 一个pod可以指定镜像，封装一个或多个容器 pod需要调度到工作节点运行，节点的选择由scheduler调度器实现 pod定义时，会…
阅读更多...
Android Studio 如何设置中文

Android Studio 如何设置中文

Android Studio 是一个为 Adndroid 平台开发程序的集成开发环境（IDE）。 如何安装中文插件 在 Jetbrains 家族的插件市场上，是能够搜到语言包插件的，正常情况下安装之后只需要重启即可享受中文界面，可AndroidStudio 中…
阅读更多...
视频剪辑软件Camtasia2024最新版本快捷键大全

视频剪辑软件Camtasia2024最新版本快捷键大全

Camtasia Studio是一款专门录制屏幕动作的工具，它能在任何颜色模式下轻松地记录 屏幕动作，包括影像、音效、鼠标移动轨迹、解说声音等等。 今天来给大家介绍一下Camtasia快捷键的相关内容，Camtasia也是一个十分好用的电脑屏幕录制与视频剪辑…
阅读更多...
Linux系统——远程访问及控制

Linux系统——远程访问及控制

目录 一、OpenSSH服务器 1.SSH（Secure Shell）协议 2.OpenSSH 2.SSH原理 2.1公钥传输原理 2.2加密原理 （1）对称加密 （2）非对称加密 2.3远程登录 2.3.1延伸 2.3.2登录用户 3.SSH格式及选项 3.1延…
阅读更多...
Pod调度

Pod调度

在默认情况下，一个Pod在哪个Node节点上运行，是由Scheduler组件采用相应的算法计算出来的，这个过程是不受人工控制的。但是在实际使用中，这并不满足的需求，因为很多情况下，我们想控制某些Pod到达某些节点上&…
阅读更多...
高斯Hack算法

高斯Hack算法

背景 刷leetcode时，碰到一题需要求解n个bit中选择m个bit的所有组合集，我只想到了递归求解，没啥问题，但是在官方题解中看到了牛逼的方法(Gospers Hack)，故记录一下。 4bit中2个1的情况 0011b0101b0110b1001b1010b1100b…
阅读更多...
基于协同过滤的零食推荐系统

基于协同过滤的零食推荐系统

介绍 协同过滤算法：协同过滤是推荐系统中比较常用的算法之一，其核心思想是寻找用户之间的相似性，通过发现用户之间的共性，向用户推荐可能喜欢的商品或服务。Python Django Vue：Django 是一个基于 Python 的 Web 开发框…
阅读更多...
模型的权值平均的原理和Pytorch的实现

模型的权值平均的原理和Pytorch的实现

一、前言 模型权值平均是一种用于改善深度神经网络泛化性能的技术。通过对训练过程中不同时间步的模型权值进行平均，可以得到更宽的极值点（optima）并提高模型的泛化能力。 在PyTorch中，官方提供了实现模型权值平均的方法。 这里…
阅读更多...
PYTHON通过跳板机巡检CENTOS的简单实现

PYTHON通过跳板机巡检CENTOS的简单实现

实现的细节和引用的文件和以前博客记录的基本一致 https://shaka.blog.csdn.net/article/details/106927633 差别在于,这次是通过跳板机登陆获取的主机信息,只记录差异的部份 1.需要在跳板机相应的路径放置PYTHON的脚本resc.py resc.py这个脚本中有引用的文件(pm.sh,diskpn…
阅读更多...
查询速度提升15倍！银联商务基于 Apache Doris 的数据平台升级实践

查询速度提升15倍！银联商务基于 Apache Doris 的数据平台升级实践

本文导读： 在长期服务广大规模商户的过程中，银联商务已沉淀了庞大、真实、优质的数据资产数据，这些数据不仅是银联商务开启新增长曲线的基础，更是进一步服务好商户的关键支撑。为更好提供数据服务，银联商务实现了从 H…
阅读更多...
EI级 | Matlab实现VMD-TCN-LSTM变分模态分解结合时间卷积长短期记忆神经网络多变量光伏功率时间序列预测

EI级 | Matlab实现VMD-TCN-LSTM变分模态分解结合时间卷积长短期记忆神经网络多变量光伏功率时间序列预测

EI级 | Matlab实现VMD-TCN-LSTM变分模态分解结合时间卷积长短期记忆神经网络多变量光伏功率时间序列预测 目录 EI级 | Matlab实现VMD-TCN-LSTM变分模态分解结合时间卷积长短期记忆神经网络多变量光伏功率时间序列预测预测效果基本介绍程序设计参考资料 预测效果 基本介绍 1.【E…
阅读更多...
Springboot3新特性：开发第一个 GraalVM 本机应用程序(完整教程)

Springboot3新特性：开发第一个 GraalVM 本机应用程序(完整教程)

在讲述之前，各位先自行在网上下载并安装Visual Studio 2022，安装的时候别忘了勾选msvc 概述：GraalVM 本机应用程序（Native Image）是使用 GraalVM 的一个特性，允许将 Java 应用程序编译成本机二进制文件&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023