Python中数据库连接的管理
在现代应用程序中,数据库是一个至关重要的组件。无论是小型应用还是大型分布式系统,良好的数据库连接管理都是确保系统高效、可靠运行的关键。本文将详细介绍在Python中管理数据库连接的最佳实践和技术,包括连接池、ORM(对象关系映射)以及如何确保数据库操作的安全性和性能。
一、数据库连接的基本概念
在讨论数据库连接管理之前,先了解一些基本概念:
- 数据库连接:指应用程序与数据库之间的通信通道。每次应用程序需要访问数据库时,都会建立一个连接。
- 连接池:为了减少建立和关闭数据库连接的开销,连接池预先创建一定数量的数据库连接,应用程序可以复用这些连接,从而提高性能。
- ORM(对象关系映射):是一种编程技术,用于将数据库中的数据与编程语言中的对象相对应,简化数据库操作。
二、直接使用数据库连接
在Python中,可以直接使用数据库驱动程序进行数据库连接,如sqlite3
、mysql-connector-python
、psycopg2
等。
2.1 使用sqlite3
进行SQLite连接
import sqlite3 def get_sqlite_connection(db_path='example.db'): """获取SQLite数据库连接""" conn = sqlite3.connect(db_path) return conn def close_connection(conn): """关闭数据库连接""" if conn: conn.close() # 示例使用 conn = get_sqlite_connection() cursor = conn.cursor() cursor.execute("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)") conn.commit() close_connection(conn)
2.2 使用mysql-connector-python
进行MySQL连接
import mysql.connector def get_mysql_connection(): """获取MySQL数据库连接""" conn = mysql.connector.connect( host='localhost', user='yourusername', password='yourpassword', database='yourdatabase' ) return conn def close_connection(conn): """关闭数据库连接""" if conn: conn.close() # 示例使用 conn = get_mysql_connection() cursor = conn.cursor() cursor.execute("CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)") conn.commit() close_connection(conn)
2.3 使用psycopg2
进行PostgreSQL连接
import psycopg2 def get_postgres_connection(): """获取PostgreSQL数据库连接""" conn = psycopg2.connect( host='localhost', user='yourusername', password='yourpassword', dbname='yourdatabase' ) return conn def close_connection(conn): """关闭数据库连接""" if conn: conn.close() # 示例使用 conn = get_postgres_connection() cursor = conn.cursor() cursor.execute("CREATE TABLE IF NOT EXISTS users (id SERIAL PRIMARY KEY, name VARCHAR(255), age INT)") conn.commit() close_connection(conn)
三、使用连接池
为了提高数据库操作的性能和资源利用效率,建议使用连接池。连接池通过复用数据库连接,减少了频繁打开和关闭连接的开销。
3.1 使用sqlalchemy
连接池
SQLAlchemy内置了连接池管理功能,且支持多种数据库。下面以MySQL为例:
from sqlalchemy import create_engine def get_engine(): """获取SQLAlchemy引擎""" engine = create_engine('mysql+mysqlconnector://yourusername:yourpassword@localhost/yourdatabase', pool_size=10, max_overflow=20) return engine def get_connection(engine): """获取数据库连接""" conn = engine.connect() return conn def close_connection(conn): """关闭数据库连接""" if conn: conn.close() # 示例使用 engine = get_engine() conn = get_connection(engine) conn.execute("CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)") close_connection(conn)
3.2 使用pymysql
连接池
import pymysql from DBUtils.PooledDB import PooledDB def get_pymysql_pool(): """获取pymysql连接池""" pool = PooledDB( creator=pymysql, maxconnections=10, mincached=2, maxcached=5, blocking=True, host='localhost', user='yourusername', password='yourpassword', database='yourdatabase' ) return pool def get_connection(pool): """获取数据库连接""" conn = pool.connection() return conn def close_connection(conn): """关闭数据库连接""" if conn: conn.close() # 示例使用 pool = get_pymysql_pool() conn = get_connection(pool) cursor = conn.cursor() cursor.execute("CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)") conn.commit() close_connection(conn)
四、使用ORM(对象关系映射)
ORM使得数据库操作更加直观,能够直接对对象进行增删改查操作。SQLAlchemy是Python中最流行的ORM库之一。
4.1 安装SQLAlchemy
pip install sqlalchemy
4.2 使用SQLAlchemy ORM
使用SQLAlchemy ORM可以简化数据库操作。下面以SQLite为例:
from sqlalchemy import create_engine, Column, Integer, String, Sequence from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.orm import sessionmaker # 创建数据库引擎 engine = create_engine('sqlite:///example.db', echo=True) # 创建基类 Base = declarative_base() # 定义模型类 class User(Base): __tablename__ = 'users' id = Column(Integer, Sequence('user_id_seq'), primary_key=True) name = Column(String(50)) age = Column(Integer) # 创建表 Base.metadata.create_all(engine) # 创建会话 Session = sessionmaker(bind=engine) session = Session() # 插入数据 new_user = User(name='Alice', age=25) session.add(new_user) session.commit() # 查询数据 users = session.query(User).all() for user in users: print(user) # 更新数据 user = session.query(User).filter_by(name='Alice').first() user.age = 26 session.commit() # 删除数据 user = session.query(User).filter_by(name='Alice').first() session.delete(user) session.commit()
五、数据库操作的最佳实践
5.1 使用上下文管理器
使用上下文管理器可以确保数据库连接在使用完后被正确关闭,避免资源泄漏。
import sqlite3 from contextlib import contextmanager @contextmanager def get_sqlite_connection(db_path='example.db'): conn = sqlite3.connect(db_path) try: yield conn finally: conn.close() # 示例使用 with get_sqlite_connection() as conn: cursor = conn.cursor() cursor.execute("CREATE TABLE IF NOT EXISTS users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)") conn.commit()
5.2 使用事务
确保数据库操作的原子性和一致性,使用事务进行批量操作,确保要么全部成功,要么全部失败。
def insert_users(users): with get_sqlite_connection() as conn: cursor = conn.cursor() try: for user in users: cursor.execute("INSERT INTO users (name, age) VALUES (?, ?)", (user['name'], user['age'])) conn.commit() except Exception as e: conn.rollback() raise e # 示例使用 users = [{'name': 'Alice', 'age': 25}, {'name': 'Bob', 'age': 30}] insert_users(users)
5.3 使用参数化查询
避免SQL注入攻击,使用参数化查询来执行数据库操作。
def get_user_by_name(name): with get_sqlite_connection() as conn: cursor = conn.cursor() cursor.execute("SELECT * FROM users WHERE name = ?", (name,)) return cursor.fetchone() # 示例使用 user = get_user_by_name('Alice') print(user)
六、数据库连接池的高级配置
6.1 SQLAlchemy连接池高级配置
SQLAlchemy提供了丰富的连接池配置选项,可以根据需求进行调整。
from sqlalchemy.pool import QueuePool # 自定义连接池 engine = create_engine( 'mysql+mysqlconnector://yourusername:yourpassword@localhost/yourdatabase', poolclass=QueuePool, pool_size=10, max_overflow=20, pool_timeout=30, pool_recycle=3600 ) # 示例使用 conn = engine.connect() conn.execute("CREATE TABLE IF NOT EXISTS users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)") conn.close()
6.2 使用Redis作为连接池
可以使用Redis作为连接池管理数据库连接,提高连接管理的灵活性和扩展性。
import redis from redis.connection import BlockingConnectionPool # 创建Redis连接池 pool = BlockingConnectionPool(host='localhost', port=6379, db=0, max_connections=10) def
相关文章:
Python中数据库连接的管理
在现代应用程序中,数据库是一个至关重要的组件。无论是小型应用还是大型分布式系统,良好的数据库连接管理都是确保系统高效、可靠运行的关键。本文将详细介绍在Python中管理数据库连接的最佳实践和技术,包括连接池、ORM(对象关系映…...
【JAVA技术】mybatis 数据库敏感字段加解密方案
引言:自从有公司项目前2年做了三级等保,每年一度例行公事,昨天继续配合做等保测试。这2天比较忙,这里整理之前写的一篇等保技术文章。 正文: 现在公司项目基本用mybatis实现,但由于项目跨度年份比较久&…...

Collections工具类及其案例
package exercise;public class Demo1 {public static void main(String[] args) {//可变参数//方法形参的个数是可以发生变化的//格式:属性类型...名字//int...argsint sum getSum(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);System.out.println(sum);}//底层:可…...

Duck Bro的第512天创作纪念日
Tips:发布的文章将会展示至 里程碑专区 ,也可以在 专区 内查看其他创作者的纪念日文章 我的创作纪念日第512天 文章目录 我的创作纪念日第512天一、与CSDN平台的相遇1. 为什么在CSDN这个平台进行创作?2. 创作这些文章是为了赚钱吗?…...

【机器学习】GPT-4中的机器学习如何塑造人类与AI的新对话
🚀时空传送门 🔍引言📕GPT-4概述🌹机器学习在GPT-4中的应用🚆文本生成与摘要🎈文献综述与知识图谱构建🚲情感分析与文本分类🚀搜索引擎优化💴智能客服与虚拟助手…...

晨控CK-UR12-E01与欧姆龙NX/NJ系列EtherNet/IP通讯手册
晨控CK-UR12-E01与欧姆龙NX/NJ系列EtherNet/IP通讯手册 晨控CK-UR12-E01 是天线一体式超高频读写器头,工作频率默认为902MHz~928MHz,符合EPC Global Class l Gen 2/IS0-18000-6C 标准,最大输出功率 33dBm。读卡器同时…...

模板显式、隐式实例化和(偏)特化、具体化的详细分析
最近看了<The C Programing Language>看到了模板的特化,突然想起来<C Primer>上说的显式具体化、隐式具体化、特化、偏特化、具体化等概念弄得头晕脑胀,我在网上了找了好多帖子,才把概念给理清楚。 看着这么多叫法,其…...
软件设计师笔记-计算机系统基础知识
CPU的功能 CPU(中央处理器)是计算机的核心部件,负责执行计算机的指令和处理数据。它的功能主要可以分为程序控制、操作控制、时间控制和数据处理四个方面: 程序控制:CPU的首要任务是执行存储在内存中的程序。程序控制功能确保CPU能够按照程序的指令序列,一条一条地执行。…...
flink 作业动态维护更新,不重启flink,不提交作业
Flink任务实时获取并更新规则_flink任务流实时变更-CSDN博客 一种动态更新flink任务配置的方法_flink 数据源 动态更新-CSDN博客 Flink CEP在实时风控场景的落地与优化 最佳实践 - 在SQL任务中使用Flink CEP - 《实时计算用户手册-v4.5.0》 Flink SQL CEP详解-CSDN博客 如…...
为何数据仓库需要“分层次”?
在数据驱动的商业世界中,数据仓库是企业决策的心脏。然而,一个高效、可扩展且易于管理的数据仓库,需要精心设计和构建。分层是构建数据仓库的关键策略之一。本文将探讨数据仓库分层的重要性以及它如何帮助企业更好地管理数据。 数据仓库分层…...

小熊家务帮day15-day18 预约下单模块(预约下单,熔断降级,支付功能,退款功能)
目录 1 预约下单1.1 需求分析1.1.1 业务流程1.1.2 订单状态 1.2 系统设计1.2.1 订单表设计1.2.2 表结构的设置 1.3 开发远程调用接口1.3.0 复习下远程调用的开发1.3.1 查询地址簿远程接口jzo2o-api工程定义接口Customer服务实现接口 1.3.2 查询服务&服务项远程接口jzo2o-ap…...

[word] word悬挂缩进怎么设置? #经验分享#职场发展#经验分享
word悬挂缩进怎么设置? 在编辑Word的时候上方会有个Word标尺,相信很多伙伴都没使用过。其实它隐藏着很多好用的功能,今天就给大家分享下利用这个word标尺的悬挂缩进怎么设置,一起来看看吧! 1、悬挂缩进 选中全文&…...

6-Maven的使用
6-Maven的使用 常用maven命令 //常用maven命令 mvn -v //查看版本 mvn archetype:create //创建 Maven 项目 mvn compile //编译源代码 mvn test-compile //编译测试代码 mvn test //运行应用程序中的单元测试 mvn site //生成项目相关信息的网站 mvn package //依据项目生成 …...

WPF真入门教程32--WPF数字大屏项目实干
1、项目背景 WPF (Windows Presentation Foundation) 是微软的一个框架,用于构建桌面客户端应用程序,它支持富互联网应用程序(RIA)的开发。在数字大屏应用中,WPF可以用来构建复杂的用户界面,展示庞大的数据…...

数据可视化Python实现超详解【数据分析】
各位大佬好 ,这里是阿川的博客,祝您变得更强 个人主页:在线OJ的阿川 大佬的支持和鼓励,将是我成长路上最大的动力 阿川水平有限,如有错误,欢迎大佬指正 Python 初阶 Python–语言基础与由来介绍 Python–…...

Maxkb玩转大语言模型
Maxkb玩转大语言模型 随着国外大语言模型llama3的发布,搭建本地个人免费“人工智能”变得越来越简单,今天博主分享使用Max搭建本地的个人聊天式对话及个人本地知识域的搭建。 1.安装Maxkb开源应用 github docker快速安装 docker run -d --namemaxkb -p 8…...

React Hooks 封装可粘贴图片的输入框组件(wangeditor)
需求是需要一个文本框 但是可以支持右键或者ctrlv粘贴图片,原生js很麻烦,那不如用插件来实现吧~我这里用的wangeditor插件,初次写初次用,可能不太好,但目前是可以达到实现需求的一个效果啦!后面再改进吧~ …...

Wireshark TS | 应用传输丢包问题
问题背景 仍然是来自于朋友分享的一个案例,实际案例不难,原因也就是互联网线路丢包产生的重传问题。但从一开始只看到数据包截图的判断结果,和最后拿到实际数据包的分析结果,却不是一个结论,方向有点跑偏,…...

架构设计-web项目中跨域问题涉及到的后端和前端配置
WEB软件项目中经常会遇到跨域问题,解决方案早已是业内的共识,简要记录主流的处理方式: 跨域感知session需要解决两个问题: 1. 跨域问题 2. 跨域cookie传输问题 跨域问题 解决跨域问题有很多种方式,如使用springboot…...
==Redis淘汰策略(内存满了触发)==
好的,面试官。这个问题我需要从三个方面来回答。第一个方面: 当 Redis 使用的内存达到 maxmemory 参数配置的阈值的时候,Redis 就会根据配置的内存淘汰策略。 把访问频率不高的 key 从内存中移除。maxmemory 默认情况是当前服务器的最大内存…...
在鸿蒙HarmonyOS 5中实现抖音风格的点赞功能
下面我将详细介绍如何使用HarmonyOS SDK在HarmonyOS 5中实现类似抖音的点赞功能,包括动画效果、数据同步和交互优化。 1. 基础点赞功能实现 1.1 创建数据模型 // VideoModel.ets export class VideoModel {id: string "";title: string ""…...

PPT|230页| 制造集团企业供应链端到端的数字化解决方案:从需求到结算的全链路业务闭环构建
制造业采购供应链管理是企业运营的核心环节,供应链协同管理在供应链上下游企业之间建立紧密的合作关系,通过信息共享、资源整合、业务协同等方式,实现供应链的全面管理和优化,提高供应链的效率和透明度,降低供应链的成…...

高频面试之3Zookeeper
高频面试之3Zookeeper 文章目录 高频面试之3Zookeeper3.1 常用命令3.2 选举机制3.3 Zookeeper符合法则中哪两个?3.4 Zookeeper脑裂3.5 Zookeeper用来干嘛了 3.1 常用命令 ls、get、create、delete、deleteall3.2 选举机制 半数机制(过半机制࿰…...
条件运算符
C中的三目运算符(也称条件运算符,英文:ternary operator)是一种简洁的条件选择语句,语法如下: 条件表达式 ? 表达式1 : 表达式2• 如果“条件表达式”为true,则整个表达式的结果为“表达式1”…...

MMaDA: Multimodal Large Diffusion Language Models
CODE : https://github.com/Gen-Verse/MMaDA Abstract 我们介绍了一种新型的多模态扩散基础模型MMaDA,它被设计用于在文本推理、多模态理解和文本到图像生成等不同领域实现卓越的性能。该方法的特点是三个关键创新:(i) MMaDA采用统一的扩散架构…...

江苏艾立泰跨国资源接力:废料变黄金的绿色供应链革命
在华东塑料包装行业面临限塑令深度调整的背景下,江苏艾立泰以一场跨国资源接力的创新实践,重新定义了绿色供应链的边界。 跨国回收网络:废料变黄金的全球棋局 艾立泰在欧洲、东南亚建立再生塑料回收点,将海外废弃包装箱通过标准…...

2021-03-15 iview一些问题
1.iview 在使用tree组件时,发现没有set类的方法,只有get,那么要改变tree值,只能遍历treeData,递归修改treeData的checked,发现无法更改,原因在于check模式下,子元素的勾选状态跟父节…...
C++ 基础特性深度解析
目录 引言 一、命名空间(namespace) C 中的命名空间 与 C 语言的对比 二、缺省参数 C 中的缺省参数 与 C 语言的对比 三、引用(reference) C 中的引用 与 C 语言的对比 四、inline(内联函数…...
Java入门学习详细版(一)
大家好,Java 学习是一个系统学习的过程,核心原则就是“理论 实践 坚持”,并且需循序渐进,不可过于着急,本篇文章推出的这份详细入门学习资料将带大家从零基础开始,逐步掌握 Java 的核心概念和编程技能。 …...

Netty从入门到进阶(二)
二、Netty入门 1. 概述 1.1 Netty是什么 Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients. Netty是一个异步的、基于事件驱动的网络应用框架,用于…...