主页
  • 主页
  • 分类
  • 热文
  • 教程
  • 面试
  • 标签
Python

Python 基础

Python 主页
Python 概述
Python 历史
Python 功能
Python 与 C++
Python Hello World
Python 应用领域
Python 解释器及其模式
Python 环境设置
Python 虚拟环境
Python 语法
Python 变量
Python 数据类型
Python 类型转换
Python Unicode 系统
Python 文字
Python 运算符
Python 算术运算符
Python 比较运算符
Python 赋值运算符
Python 逻辑运算符
Python 位运算符
Python 成员运算符
Python 身份运算符
Python 运算符优先级
Python 注释
Python 用户输入
Python 数字
Python 布尔值

Python 控制语句

Python 控制流
Python 决策
Python if 语句
Python if-else 语句
Python 嵌套 if 语句
Python match-case 语句
Python 循环
Python For 循环
Python for-else 循环
Python while 循环
Python break 语句
Python Continue 语句
Python pass 语句
Python 嵌套循环

Python 函数和模块

Python 函数
Python 默认参数
Python 关键字参数
Python 关键字专用参数
Python 位置参数
Python 仅限位置参数
Python 任意或可变长度参数
Python 变量作用域
Python 函数注释
Python 模块
Python 内置函数

Python 字符串

Python 字符串
Python 字符串切片
Python 字符串修改
Python 字符串连接
Python 字符串格式化
Python 转义字符
Python 字符串方法
Python 字符串练习

Python 列表

Python 列表
Python 访问列表项
Python 更改列表项
Python 添加列表项
Python 删除列表项
Python 循环列表
Python 列表推导式
Python 排序列表
Python 复制列表
Python 合并列表
Python 列表方法
Python 列表练习

Python 元组

Python 元组
Python 访问元组项
Python 更新元组
Python 解包元组项
Python 循环元组
Python 合并元组
Python 元组方法
Python 元组练习

Python 集合

Python 集合
Python 访问集合项
Python 添加集合项
Python 删除集合项
Python 循环集合
Python 合并集合
Python 复制集合
Python 集合运算符
Python 集合方法
Python 集合练习

Python 字典

Python 字典
Python 访问字典项
Python 更改字典项
Python 添加字典项
Python 移除字典项
Python 字典视图对象
Python 循环字典
Python 复制字典
Python 嵌套字典
Python 字典方法
Python 字典练习

Python 数组

Python 数组
Python 访问数组项
Python 添加数组项
Python 移除数组项
Python 循环数组
Python 复制数组
Python 反转数组
Python 排序数组
Python 合并数组
Python 数组方法
Python 数组练习

Python 文件处理

Python 文件处理
Python 文件写入
Python 文件读取
Python 重命名和删除文件
Python 目录
Python 文件方法
Python 文件/目录方法
Python OS.Path 方法

Python 面向对象编程

Python OOP 概念
Python 类和对象
Python 类属性
Python 类方法
Python 静态方法
Python 构造函数
Python 访问修饰符
Python 继承
Python 多态
Python 方法重写
Python 方法重载
Python 动态绑定
Python 动态类型
Python 抽象
Python 封装
Python 接口
Python 包
Python 内部类
Python 匿名类和对象
Python 单例类
Python 包装器类
Python 枚举
Python 反射

Python 错误和异常

Python 语法错误
Python 异常处理
Python Try-Except
Python Try-Finally
Python 抛出异常
Python 异常链
Python 嵌套 try
Python 用户定义异常
Python 日志记录
Python 断言
Python 内置异常

Python 多线程

Python 多线程
Python 线程生命周期
Python 创建线程
Python 启动线程
Python 合并线程
Python 命名线程
Python 线程调度
Python 线程池
Python 主线程
Python 线程优先级
Python 守护线程
Python 线程同步

Python 同步

Python 线程间通信
Python 死锁
Python 中断线程

Python 网络

Python 网络编程
Python 套接字编程
Python URL 处理
Python 泛型

Python 杂项

Python Date and Time
Python math模块
Python 迭代器
Python 生成器
Python 闭包
Python 装饰器
Python 递归
Python 正则表达式
Python Pip
Python 数据库访问
Python 弱引用
Python 序列化
Python 模板技术
Python 输出格式化
Python 性能测量
Python 数据压缩
Python 通用网关接口
Python XML 处理
Python 用户界面(GUI)
Python 命令行参数
Python Docstrings
Python JSON
Python 发送电子邮件
Python 进一步扩展
Python 工具/实用程序
Python GUI

Python 高级概念

Python 抽象基类
Python 自定义异常
Python 高阶函数
Python 对象的内部机制
Python 内存管理
Python 元类
Python 元编程
Python 模拟与桩
Python 猴子补丁
Python 信号处理
Python 类型提示
Python 进行自动化
Python Humanize包
Python 上下文管理器
Python 协程
Python 描述符
Python 内存泄漏
Python 不可变数据结构

基础

Python 主页
Python 概述
Python 历史
Python 功能
Python 与 C++
Python Hello World
Python 应用领域
Python 解释器及其模式
Python 环境设置
Python 虚拟环境
Python 语法
Python 变量
Python 数据类型
Python 类型转换
Python Unicode 系统
Python 文字
Python 运算符
Python 算术运算符
Python 比较运算符
Python 赋值运算符
Python 逻辑运算符
Python 位运算符
Python 成员运算符
Python 身份运算符
Python 运算符优先级
Python 注释
Python 用户输入
Python 数字
Python 布尔值

控制语句

Python 控制流
Python 决策
Python if 语句
Python if-else 语句
Python 嵌套 if 语句
Python match-case 语句
Python 循环
Python For 循环
Python for-else 循环
Python while 循环
Python break 语句
Python Continue 语句
Python pass 语句
Python 嵌套循环

函数和模块

Python 函数
Python 默认参数
Python 关键字参数
Python 关键字专用参数
Python 位置参数
Python 仅限位置参数
Python 任意或可变长度参数
Python 变量作用域
Python 函数注释
Python 模块
Python 内置函数

字符串

Python 字符串
Python 字符串切片
Python 字符串修改
Python 字符串连接
Python 字符串格式化
Python 转义字符
Python 字符串方法
Python 字符串练习

列表

Python 列表
Python 访问列表项
Python 更改列表项
Python 添加列表项
Python 删除列表项
Python 循环列表
Python 列表推导式
Python 排序列表
Python 复制列表
Python 合并列表
Python 列表方法
Python 列表练习

元组

Python 元组
Python 访问元组项
Python 更新元组
Python 解包元组项
Python 循环元组
Python 合并元组
Python 元组方法
Python 元组练习

集合

Python 集合
Python 访问集合项
Python 添加集合项
Python 删除集合项
Python 循环集合
Python 合并集合
Python 复制集合
Python 集合运算符
Python 集合方法
Python 集合练习

字典

Python 字典
Python 访问字典项
Python 更改字典项
Python 添加字典项
Python 移除字典项
Python 字典视图对象
Python 循环字典
Python 复制字典
Python 嵌套字典
Python 字典方法
Python 字典练习

数组

Python 数组
Python 访问数组项
Python 添加数组项
Python 移除数组项
Python 循环数组
Python 复制数组
Python 反转数组
Python 排序数组
Python 合并数组
Python 数组方法
Python 数组练习

文件处理

Python 文件处理
Python 文件写入
Python 文件读取
Python 重命名和删除文件
Python 目录
Python 文件方法
Python 文件/目录方法
Python OS.Path 方法

面向对象编程

Python OOP 概念
Python 类和对象
Python 类属性
Python 类方法
Python 静态方法
Python 构造函数
Python 访问修饰符
Python 继承
Python 多态
Python 方法重写
Python 方法重载
Python 动态绑定
Python 动态类型
Python 抽象
Python 封装
Python 接口
Python 包
Python 内部类
Python 匿名类和对象
Python 单例类
Python 包装器类
Python 枚举
Python 反射

错误和异常

Python 语法错误
Python 异常处理
Python Try-Except
Python Try-Finally
Python 抛出异常
Python 异常链
Python 嵌套 try
Python 用户定义异常
Python 日志记录
Python 断言
Python 内置异常

多线程

Python 多线程
Python 线程生命周期
Python 创建线程
Python 启动线程
Python 合并线程
Python 命名线程
Python 线程调度
Python 线程池
Python 主线程
Python 线程优先级
Python 守护线程
Python 线程同步

同步

Python 线程间通信
Python 死锁
Python 中断线程

网络

Python 网络编程
Python 套接字编程
Python URL 处理
Python 泛型

杂项

Python Date and Time
Python math模块
Python 迭代器
Python 生成器
Python 闭包
Python 装饰器
Python 递归
Python 正则表达式
Python Pip
Python 数据库访问
Python 弱引用
Python 序列化
Python 模板技术
Python 输出格式化
Python 性能测量
Python 数据压缩
Python 通用网关接口
Python XML 处理
Python 用户界面(GUI)
Python 命令行参数
Python Docstrings
Python JSON
Python 发送电子邮件
Python 进一步扩展
Python 工具/实用程序
Python GUI

高级概念

Python 抽象基类
Python 自定义异常
Python 高阶函数
Python 对象的内部机制
Python 内存管理
Python 元类
Python 元编程
Python 模拟与桩
Python 猴子补丁
Python 信号处理
Python 类型提示
Python 进行自动化
Python Humanize包
Python 上下文管理器
Python 协程
Python 描述符
Python 内存泄漏
Python 不可变数据结构

Python 数据库访问


上一章 下一章

Python 中的数据库访问用于与数据库交互,允许应用程序一致地存储、检索、更新和管理数据。各种关系数据库管理系统 (RDBMS) 都支持这些任务,每种 RDBMS 都需要特定的 Python 包来进行连接 −

  • GadFly
  • MySQL
  • PostgreSQL
  • Microsoft SQL Server
  • Informix
  • Oracle
  • Sybase
  • SQLite
  • 以及更多...

程序执行期间产生的数据通常存储在 RAM 中。如果需要持久化存储,则需要将数据存入数据库表中。

关系数据库使用 SQL(结构化查询语言)来执行对数据库表的操作,如插入、删除和更新。然而,SQL 的实现因数据库类型的不同而有所差异。这就引发了兼容性问题:适用于一种数据库的 SQL 指令可能并不适用于另一种数据库。

DB-API(数据库 API)

为了应对兼容性的问题,Python 改进提案 (PEP) 249 引入了一个标准化接口,即 DB-API。这个接口提供了一个一致的框架给数据库驱动程序,确保了跨不同数据库系统的统一行为。它简化了在各种数据库之间迁移的过程,通过建立一套通用的规则和方法。

驱动程序接口

使用 Python 进行数据库操作

Python 的标准库包含了 sqlite3 模块,这是一个与 DB-API 兼容的 SQLite3 数据库驱动器。它作为 DB-API 的参考实现。对于其他类型的数据库,你需要安装相应的 Python 包 −

  • Oracle: cx_oracle, pyodbc
  • SQL Server: pymssql, pyodbc
  • PostgreSQL: psycopg2
  • MySQL: MySQL Connector/Python, pymysql

使用 SQLite

由于内置的 sqlite3 模块,使用 Python 进行 SQLite 数据库的操作变得非常简单。过程包括 −

  • 连接建立: 使用 sqlite3.connect() 创建一个连接对象,提供必要的连接凭证,如服务器名、端口、用户名和密码。
  • 事务管理: 连接对象管理数据库操作,包括打开、关闭以及事务控制(提交或回滚事务)。
  • 游标对象: 从连接中获取一个游标对象以执行 SQL 查询。游标作为执行数据库上的 CRUD(创建、读取、更新、删除)操作的入口。

让我们通过导入 sqlite3 来开始,并检查它的版本。

>>> import sqlite3
>>> sqlite3.sqlite_version
'3.39.4'

连接对象

通过 sqlite3 模块中的 connect() 函数建立连接对象。此函数的第一个位置参数是一个字符串,表示 SQLite 数据库文件的路径(相对或绝对)。函数返回一个指向数据库的连接对象。

>>> conn = sqlite3.connect('testdb.sqlite3')
>>> type(conn)
<class 'sqlite3.Connection'>

连接类定义了多种方法。其中之一是 cursor() 方法,它返回一个游标对象,我们将在下一节中了解。通过连接对象的 commit() 和 rollback() 方法可以实现事务控制。连接类还有重要的方法来定义用于 SQL 查询的自定义函数和聚合。

游标对象

接下来,我们需要从连接对象中获取游标对象。它是你在对数据库执行任何 CRUD 操作时的句柄。通过连接对象上的 cursor() 方法返回游标对象。

>>> cur = conn.cursor()
>>> type(cur)
<class 'sqlite3.Cursor'>

现在我们可以借助游标对象上的 execute() 方法执行所有 SQL 查询操作。此方法需要一个有效的 SQL 语句作为字符串参数。

创建数据库表

我们现在在新创建的 'testdb.sqlite3' 数据库中添加 Employee 表。在下面的脚本中,我们调用游标对象的 execute() 方法,并传入一个带有 CREATE TABLE 语句的字符串。

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = '''
CREATE TABLE Employee (
    EmpID INTEGER PRIMARY KEY AUTOINCREMENT,
    FIRST_NAME TEXT (20),
    LAST_NAME TEXT(20),
    AGE INTEGER,
    SEX TEXT(1),
    INCOME FLOAT
);
'''

try:
    cur.execute(qry)
    print('Table created successfully')
except:
    print('error in creating table')
conn.close()

当上述程序运行时,在当前工作目录中创建了一个包含 Employee 表的数据库。

我们可以通过列出 SQLite 控制台中的数据库表来验证。

sqlite> .open mydb.sqlite
sqlite> .tables
Employee

插入操作

当你要向数据库表中创建记录时,需要插入操作。

示例

下面的例子执行 SQL 插入语句以在 EMPLOYEE 表中创建一条记录。

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = """INSERT INTO EMPLOYEE(FIRST_NAME,
       LAST_NAME, AGE, SEX, INCOME)
       VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""

try:
    cur.execute(qry)
    conn.commit()
    print('Record inserted successfully')
except:
    conn.rollback()
    print('error in INSERT operation')
conn.close()

你也可以使用参数替换技术来执行插入查询,如下所示:

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = """INSERT INTO EMPLOYEE(FIRST_NAME,
       LAST_NAME, AGE, SEX, INCOME)
       VALUES (?, ?, ?, ?, ?)"""

try:
    cur.execute(qry, ('Makrand', 'Mohan', 21, 'M', 5000))
    conn.commit()
    print('Record inserted successfully')
except Exception as e:
    conn.rollback()
    print('error in INSERT operation')
conn.close()

读取操作

在任何数据库上的读取操作意味着从数据库中提取有用的信息。

一旦建立了数据库连接,你就可以准备好向数据库中发出查询。你可以使用 fetchone() 方法来提取单条记录或者使用 fetchall() 方法来从数据库表中提取多条值。

  • fetchone() − 它提取查询结果集中的下一行。结果集是使用游标对象查询表格时返回的对象。
  • fetchall() − 它提取结果集中的所有行。如果已经有部分行从结果集中抽取出来,则它提取剩余的行。
  • rowcount − 这是一个只读属性,返回由 execute() 方法影响的行数。

示例

在下面的代码中,游标对象执行 SELECT * FROM EMPLOYEE 查询。通过 fetchall() 方法获得结果集。我们使用一个 for 循环打印结果集中的所有记录。

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = "SELECT * FROM EMPLOYEE"

try:
    # 执行 SQL 命令
    cur.execute(qry)
    # 以列表的形式获取所有行。
    results = cur.fetchall()
    for row in results:
        fname = row[1]
        lname = row[2]
        age = row[3]
        sex = row[4]
        income = row[5]
        # 现在打印提取的结果
        print("fname={},lname={},age={},sex={},income={}".format(fname, lname, age, sex, income))
except Exception as e:
    print(e)
    print("Error: unable to fetch data")

conn.close()

它会产生以下输出 −

fname=Mac,lname=Mohan,age=20,sex=M,income=2000.0
fname=Makrand,lname=Mohan,age=21,sex=M,income=5000.0

更新操作

在任何数据库上的更新操作意味着更新数据库中已经存在的一个或多个记录。

下面的过程更新所有收入为 2000 的记录。这里我们将收入增加 1000。

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = "UPDATE EMPLOYEE SET INCOME = INCOME+1000 WHERE INCOME=?"

try:
    # 执行 SQL 命令
    cur.execute(qry, (1000,))
    # 提交事务
    conn.commit()
    print("Records updated")
except Exception as e:
    print("Error: unable to update data")
conn.close()

删除操作

当你要从数据库中删除一些记录时,需要删除操作。下面是删除所有收入小于 2000 的记录的过程。

import sqlite3
conn = sqlite3.connect('testdb.sqlite3')
cur = conn.cursor()
qry = "DELETE FROM EMPLOYEE WHERE INCOME<?"

try:
    # 执行 SQL 命令
    cur.execute(qry, (2000,))
    # 提交事务
    conn.commit()
    print("Records deleted")
except Exception as e:
    print("Error: unable to delete data")

conn.close()

进行事务处理

事务是一种确保数据一致性的机制。事务具有以下四个特性 −

  • 原子性 − 要么事务完成,要么什么都不发生。
  • 一致性 − 事务必须在一个一致的状态下开始,并且使系统处于一个一致的状态。
  • 隔离性 − 事务的中间结果对外部不可见。
  • 持久性 − 一旦事务被提交,其效果是持久的,即使是在系统故障之后。

执行交易

进行事务处理

Python DB API 2.0 提供了两种方法来提交或回滚一个事务。

示例

你已经知道如何实现事务。以下是一个类似的例子 −

# 准备 SQL 查询以删除所需的记录
sql = "DELETE FROM EMPLOYEE WHERE AGE > ?"
try:
   # 执行 SQL 命令
   cursor.execute(sql, (20,))
   # 在数据库中提交更改
   db.commit()
except:
   # 如果有任何错误则回滚
   db.rollback()

COMMIT 操作

提交是一个操作,它向数据库发出信号以最终确定更改,在此操作后,更改无法撤销。

以下是一个简单的调用 commit 方法的例子。

db.commit()

ROLLBACK 操作

如果你不满意一个或多个更改,并希望完全恢复这些更改,那么使用 rollback() 方法。

以下是一个简单的调用 rollback() 方法的例子。

db.rollback()

PyMySQL 模块

PyMySQL 是一个用于从 Python 连接到 MySQL 数据库服务器的接口。它实现了 Python Database API v2.0 并且包含了一个纯 Python 的 MySQL 客户端库。PyMySQL 的目标是作为一个 MySQLdb 的直接替代品。

安装 PyMySQL

在继续之前,请确保你的机器上已安装了 PyMySQL。只需在你的 Python 脚本中输入以下内容并执行它 −

import PyMySQL

如果它产生了以下结果,那么就说明 MySQLdb 模块未安装 −

Traceback (most recent call last):
   File "test.py", line 3, in <module>
      Import PyMySQL
ImportError: No module named PyMySQL

最新的稳定版本可以在 PyPI 上找到,并且可以使用 pip 安装 −

pip install PyMySQL

注意 − 确保你有安装上述模块的管理员权限。

MySQL 数据库连接

在连接到 MySQL 数据库之前,请确保以下几点 −

  • 你已经创建了一个名为 TESTDB 的数据库。
  • 你已经在 TESTDB 中创建了一个名为 EMPLOYEE 的表。
  • 此表有字段 FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
  • 用户 ID "testuser" 和密码 "test123" 已设置为访问 TESTDB。
  • Python 模块 PyMySQL 已经正确安装在你的机器上。
  • 你已经阅读了 MySQL 教程以理解 MySQL 的基础知识。

示例

为了在前面的例子中使用 MySQL 数据库而不是 SQLite 数据库,我们需要将 connect() 函数修改如下 −

import PyMySQL
# 打开数据库连接
db = PyMySQL.connect("localhost", "testuser", "test123", "TESTDB")

除了这个改变外,每个数据库操作都可以毫无困难地执行。

错误处理

有很多错误的来源。几个例子是一个执行 SQL 语句的语法错误、一个连接失败、或者对一个已经被取消或完成的语句句柄调用 fetch 方法。

DB API 定义了许多必须存在于每个数据库模块中的错误。以下表格列出了这些异常。

序号 异常 & 描述
1 Warning
2 Error
3 InterfaceError
4 DatabaseError
5 DataError
6 OperationalError
7 IntegrityError
8 InternalError
9 ProgrammingError
10 NotSupportedError
上一章 下一章
阅读号二维码

关注阅读号

联系二维码

联系我们

© 2024 Yoagoa. All rights reserved.

粤ICP备18007391号

站点地图