亿迅智能制造网
工业4.0先进制造技术信息网站!
首页 | 制造技术 | 制造设备 | 工业物联网 | 工业材料 | 设备保养维修 | 工业编程 |
home  MfgRobots >> 亿迅智能制造网 >  >> Industrial programming >> Python
Python - MySQL 数据库访问

上一页下一页

数据库接口的 Python 标准是 Python DB-API。大多数 Python 数据库接口都遵循此标准。

您可以为您的应用程序选择正确的数据库。 Python 数据库 API 支持广泛的数据库服务器,例如 -

以下是可用 Python 数据库接口的列表:Python 数据库接口和 API。您必须为需要访问的每个数据库下载单独的 DB API 模块。例如,如果您需要访问 Oracle 数据库和 MySQL 数据库,则必须同时下载 Oracle 和 MySQL 数据库模块。

DB API 提供了一个尽可能使用 Python 结构和语法处理数据库的最低标准。此 API 包括以下内容 -

MySQL 的所有概念我们都会学习到,所以让我们来谈谈 MySQLdb 模块。

什么是 MySQLdb?

MySQLdb 是一个用于从 Python 连接到 MySQL 数据库服务器的接口。它实现了 Python 数据库 API v2.0,并建立在 MySQL C API 之上。

如何安装 MySQLdb?

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

#!/usr/bin/pythonimport MySQLdb

如果它产生以下结果,则表示未安装 MySQLdb 模块 -

回溯(最近一次调用最后一次):文件“test.py”,第 3 行,在  中 import MySQLdbImportError:No module named MySQLdb

要安装 MySQLdb 模块,请使用以下命令 -

对于 Ubuntu,使用以下命令 -$ sudo apt-get install python-pip python-dev libmysqlclient-dev 对于 Fedora,使用以下命令 -$ sudo dnf install python python-devel mysql-devel redhat-rpm-config gcc对于Python命令提示符,使用如下命令-pip install MySQL-python

注意 − 确保您具有安装上述模块的 root 权限。

数据库连接

在连接到 MySQL 数据库之前,请确保以下事项 -

示例

以下是连接MySQL数据库“TESTDB”的例子

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 使用 execute() 执行 SQL 查询 method.cursor.execute("SELECT VERSION()")#使用fetchone()获取单行 method.data =cursor.fetchone()print "Database version :%s " % data# 从 serverdb.close() 断开

运行此脚本时,它在我的 Linux 机器上产生以下结果。

数据库版本:5.0.45

如果与数据源建立连接,则返回一个连接对象并保存到 db 供进一步使用,否则 db 设置为无。接下来,db 对象用于创建光标 对象,该对象又用于执行 SQL 查询。最后,在出来之前,保证关闭数据库连接,释放资源。

创建数据库表

一旦建立了数据库连接,我们就可以使用 execute 在数据库表中创建表或记录 创建游标的方法。

示例

让我们创建数据库表 EMPLOYEE -

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 使用execute()删除已经存在的表 method.cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")#根据需求创建表sql ="""CREATE TABLE EMPLOYEE (FIRST_NAME CHAR(20) NOT NULL, LAST_NAME CHAR(20), AGE INT, SEX CHAR(1) , 收入浮动 )"""cursor.execute(sql)# 从 serverdb.close() 断开

插入操作

要将记录创建到数据库表中时需要它。

示例

下面的例子,执行 SQL INSERT 在 EMPLOYEE 表中创建记录的语句 -

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 准备 SQL 查询以将记录插入数据库.sql ="""INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, INCOME) VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""try:# 执行 SQL 命令 cursor.execute(sql) # 在数据库中提交你的更改 db.commit()except:# 回滚以防出现任何错误 db.rollback()#与 serverdb.close() 断开连接

上面的例子可以写成如下动态创建 SQL 查询 -

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 准备 SQL 查询以将记录插入到数据库中。sql ="INSERT INTO EMPLOYEE(FIRST_NAME, \ LAST_NAME, AGE, SEX, INCOME) \ VALUES ('%s', '%s', '%d', '%c', '%d' )" % \ ('Mac', 'Mohan', 20, 'M', 2000)try:# 执行 SQL 命令 cursor.execute(sql) # Commit您在数据库中的更改 db.commit()except:# 回滚以防出现任何错误 db.rollback()# disconnect from serverdb.close()

示例

以下代码段是另一种执行形式,您可以直接传递参数 -

.................................user_id ="test123"password ="password"con.execute('insert into Login values("%s", "%s")' % \ (user_id, password))......... ......

读操作

READ 对任何数据库的操作意味着从数据库中获取一些有用的信息。

一旦我们的数据库连接建立,您就可以开始查询这个数据库了。您可以使用 fetchone() 获取单个记录的方法或 fetchall() 从数据库表中获取多个值的方法。

示例

下面的过程查询EMPLOYEE表中工资大于1000的所有记录 -

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()sql ="SELECT * FROM EMPLOYEE \ WHERE INCOME> '%d'" % (1000)try:# 执行 SQL 命令 cursor.execute(sql) # 获取列表列表中的所有行. results =cursor.fetchall() for row in results:fname =row[0] lname =row[1] age =row[2] sex =row[3]income =row[4] # 现在打印获取的结果 print "fname =%s,lname=%s,age=%d,sex=%s,income=%d" % \ (fname, lname, age, sex,income )except:打印 "错误:无法获取数据"# 断开连接来自 serverdb.close()

这将产生以下结果 -

fname=Mac,lname=Mohan,age=20,sex=M,收入=2000

更新操作

UPDATE 对任何数据库的操作是更新一个或多个数据库中已有的记录。

以下过程更新所有 SEX 为 'M' 的记录 .在这里,我们将所有雄性的 AGE 增加一年。

示例

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 准备 SQL 查询以更新所需的记录sql ="UPDATE EMPLOYEE SET AGE =AGE + 1 WHERE SEX ='%c'" % ('M')try:# 执行 SQL 命令 cursor.execute( sql) # 在数据库中提交您的更改 db.commit()except:# 回滚以防出现任何错误 db.rollback()# 从 serverdb.close() 断开

删除操作

当您要从数据库中删除某些记录时,需要执行 DELETE 操作。以下是从 EMPLOYEE 中删除 AGE 大于 20 的所有记录的过程 -

示例

#!/usr/bin/pythonimport MySQLdb# 打开数据库连接db =MySQLdb.connect("localhost","testuser","test123","TESTDB")# 使用 <准备一个游标对象i>光标() methodcursor =db.cursor()# 准备 SQL 查询以删除所需的记录sql ="DELETE FROM EMPLOYEE WHERE AGE> '%d'" % (20)try:# 执行 SQL 命令 cursor.execute(sql) # 在数据库 db.commit()except:# 回滚以防出现任何错误 db.rollback()# 从 serverdb.close() 断开

执行交易

事务是一种确保数据一致性的机制。交易具有以下四个属性 -

Python DB API 2.0 提供了两种方法来提交回滚 一笔交易。

示例

您已经知道如何实现事务。这又是一个类似的例子 -

# 准备 SQL 查询以删除所需的记录sql ="DELETE FROM EMPLOYEE WHERE AGE> '%d'" % (20)try:# 执行 SQL 命令 cursor.execute(sql) # Commit your数据库中的变化 db.commit()except:# 回滚以防出现任何错误 db.rollback()

提交操作

Commit是一个操作,给数据库一个绿色的信号来完成更改,此操作后,任何更改都无法恢复。

这是一个调用 commit 的简单示例 方法。

db.commit()

回滚操作

如果您对一项或多项更改不满意,并且想要完全还原这些更改,请使用 rollback() 方法。

这是调用 rollback() 的简单示例 方法。

db.rollback()

断开数据库

要断开数据库连接,请使用 close() 方法。

db.close()

如果用户使用 close() 方法关闭了与数据库的连接,则数据库将回滚任何未完成的事务。但是,您的应用程序最好不要依赖于任何 DB 较低级别的实现细节,而最好显式调用 commit 或 rollback。

处理错误

错误的来源有很多。一些示例是已执行的 SQL 语句中的语法错误、连接失败或为已取消或已完成的语句句柄调用 fetch 方法。

DB API 定义了许多错误,这些错误必须存在于每个数据库模块中。下表列出了这些例外情况。

Sr.No. 异常和描述
1

警告

用于非致命问题。必须继承 StandardError。

2

错误

错误的基类。必须继承 StandardError。

3

接口错误

用于数据库模块中的错误,而不是数据库本身。必须对 Error 进行子类化。

4

数据库错误

用于数据库中的错误。必须对 Error 进行子类化。

5

数据错误

DatabaseError 的子类,指的是数据中的错误。

6

操作错误

DatabaseError 的子类,指的是错误,例如与数据库的连接丢失。这些错误通常不在 Python 脚本编写者的控制范围内。

7

完整性错误

DatabaseError 的子类,用于可能破坏关系完整性的情况,例如唯一性约束或外键。

8

内部错误

DatabaseError 的子类,指的是数据库模块内部的错误,例如游标不再处于活动状态。

9

编程错误

DatabaseError 的子类,它指的是错误,例如错误的表名和其他可以安全归咎于您的事情。

10

NotSupportedError

DatabaseError 的子类,指的是尝试调用不受支持的功能。

您的 Python 脚本应该处理这些错误,但在使用上述任何异常之前,请确保您的 MySQLdb 支持该异常。您可以通过阅读 DB API 2.0 规范来获取有关它们的更多信息。


Python

  1. 在 Python 中复制文件:shutil.copy()、shutil.copystat() 方法
  2. Python 自定义异常
  3. Python 使用 os.rename() 重命名文件和目录
  4. Python - 正则表达式
  5. Python - 函数
  6. Python sleep()