如何使用Python连接Oracle数据库

已编辑 2 几个月前 通过 ExtremeHow 编辑团队

Oracle数据库Python集成编程数据库管理脚本管理工具系统配置性能云计算企业解决方案

Oracle数据库是一个功能强大且被广泛使用的关系数据库管理系统（RDBMS）。它以稳定的功能、高性能和可靠性著称。另一方面，Python是一种用途广泛且易于学习的编程语言，被广泛应用于数据分析、Web开发等领域。通过结合这两种技术，开发人员可以创建能够有效与Oracle数据库中存储的数据交互的应用程序。在本教程中，我们将探讨如何使用Python连接Oracle数据库。我们将介绍设置环境、建立连接、执行基本数据库操作和处理异常所需的步骤。

设置环境

在您开始使用Python与Oracle数据库进行交互之前，必须先设置开发环境。这包括安装必要的库和工具，以便Python和Oracle数据库之间的通信。

安装cx_Oracle

cx_Oracle是一个Python模块，它允许访问Oracle数据库，使您能够执行SQL查询、进行数据操作等。由于其广泛的功能集，它是连接Python和Oracle数据库的热门选择。

要安装cx_Oracle，您可以使用例如pip这样的包管理器。打开您的命令提示符或终端，输入以下命令：

pip install cx_Oracle

这将下载并安装cx_Oracle模块，使其可用于您的Python脚本中。

安装Oracle即时客户端

cx_Oracle模块需要在您的系统上安装Oracle即时客户端。Oracle即时客户端提供了与Oracle数据库通信所需的库和工具。

您可以从Oracle官方网站下载Oracle即时客户端。选择适合您操作系统的安装包，并按照Oracle提供的安装说明进行安装。

安装后，您需要设置适当的环境变量，以确保cx_Oracle可以找到Oracle即时客户端。这通常涉及在Linux上设置LD_LIBRARY_PATH或在Windows上设置PATH，以包含Oracle即时客户端的安装目录。

连接Oracle数据库

设置好环境后，您现在可以将Python连接到Oracle数据库。本节将指导您如何使用cx_Oracle建立与Oracle数据库实例的连接。

建立连接

一旦您安装并配置好cx_Oracle和Oracle即时客户端，就可以从您的Python脚本中创建到Oracle数据库的连接。以下是建立连接的基本示例：

import cx_Oracle
# 定义连接详细信息
dsn_tns = cx_Oracle.makedsn('hostname', 'port', service_name='service_name')
username = 'your_username'
password = 'your_password'
# 建立连接
try:
    connection = cx_Oracle.connect(user=username, password=password, dsn=dsn_tns)
    print('连接成功。')
except cx_Oracle.DatabaseError as e:
    print('连接数据库时发生错误：', e)
# 关闭连接
connection.close()

在此示例中，我们首先导入cx_Oracle模块。我们定义必要的连接详细信息，包括主机名、端口、用户名和密码，以及Oracle数据库实例的服务名。然后我们使用cx_Oracle.connect()函数建立连接。通常最好使用try和except块包裹连接尝试，以处理任何潜在的数据库错误。

执行SQL查询

一旦您建立了与Oracle数据库的连接，就可以执行SQL查询与数据库中存储的数据进行交互。本节将探讨如何执行基本的数据库操作，如查询数据、插入记录和更新数据。

查询数据

要从Oracle数据库中检索数据，可以使用SQL SELECT语句。以下是使用cx_Oracle执行SELECT查询的示例：

import cx_Oracle
# 连接详细信息
dsn_tns = cx_Oracle.makedsn('hostname', 'port', service_name='service_name')
username = 'your_username'
password = 'your_password'
# 建立连接
try:
    connection = cx_Oracle.connect(user=username, password=password, dsn=dsn_tns)
    cursor = connection.cursor()
    # 执行SELECT查询
    cursor.execute('SELECT * FROM your_table_name')
    # 获取并打印结果
    for row in cursor.fetchall():
        print(row)
except cx_Oracle.DatabaseError as e:
    print('执行SQL查询时出错：', e)
finally:
    cursor.close()
    connection.close()

在本示例中，我们像之前一样建立连接并使用connection.cursor()方法创建游标对象。游标用于执行SQL查询。我们使用cursor.execute()执行SELECT查询，并使用cursor.fetchall()检索结果。然后将结果打印到控制台。始终记得关闭游标和连接以释放资源。

插入数据

要向Oracle数据库中的表添加新记录，可以使用SQL INSERT语句。以下是使用cx_Oracle插入数据的示例：

import cx_Oracle
# 连接详细信息
dsn_tns = cx_Oracle.makedsn('hostname', 'port', service_name='service_name')
username = 'your_username'
password = 'your_password'
# 建立连接
try:
    connection = cx_Oracle.connect(user=username, password=password, dsn=dsn_tns)
    cursor = connection.cursor()
    # 定义INSERT查询和数据
    insert_query = 'INSERT INTO your_table_name (column1, column2) VALUES (:1, :2)'
    data_to_insert = [("Value1_1", "Value1_2"), ("Value2_1", "Value2_2")]
    # 执行INSERT查询
    cursor.executemany(insert_query, data_to_insert)
    connection.commit()
    print('数据插入成功。')
except cx_Oracle.DatabaseError as e:
    print('插入数据时出错：', e)
    connection.rollback()
finally:
    cursor.close()
    connection.close()

在此示例中，我们定义要插入的数据及INSERT查询。cursor.executemany()方法允许我们使用多组数据执行INSERT查询。执行后，重要的是使用connection.commit()提交事务以使更改永久生效。如果发生错误，我们使用connection.rollback()回滚以还原所做的更改。

更新数据

要更新表中现有记录，可以使用SQL UPDATE语句。以下是使用cx_Oracle更新数据的示例：

import cx_Oracle
# 连接详细信息
dsn_tns = cx_Oracle.makedsn('hostname', 'port', service_name='service_name')
username = 'your_username'
password = 'your_password'
# 建立连接
try:
    connection = cx_Oracle.connect(user=username, password=password, dsn=dsn_tns)
    cursor = connection.cursor()
    # 定义UPDATE查询
    update_query = 'UPDATE your_table_name SET column1 = :1 WHERE column2 = :2'
    data_to_update = ("NewValue1", "CriteriaValue2")
    # 执行UPDATE查询
    cursor.execute(update_query, data_to_update)
    connection.commit()
    print('数据更新成功。')
except cx_Oracle.DatabaseError as e:
    print('更新数据时出错：', e)
    connection.rollback()
finally:
    cursor.close()
    connection.close()

在此示例中，我们执行UPDATE查询以修改表中的现有数据。cursor.execute()方法用于传递带有占位符和更新条件的新值。执行后，我们提交事务以应用更改。

处理异常

在与数据库进行操作时，处理异常对于确保您的应用程序能够顺利处理错误至关重要。在数据库操作周围使用try-except块有助于捕获和管理发生的异常。

例如，您可以使用cx_Oracle的DatabaseError异常来捕获和处理与数据库相关的错误，无论是在建立连接还是执行查询时：

try:
    # 数据库操作
except cx_Oracle.DatabaseError as e:
    print('发生错误：', e)

除了处理异常外，释放数据库资源也是重要的，即在不再需要时关闭游标和连接。将这些操作包装在finally块中可确保无论是否引发异常，都会执行这些操作。

结论

使用cx_Oracle模块，Python开发人员可以有效地连接和使用Oracle数据库。在本教程中，我们介绍了如何设置环境、建立与Oracle数据库的连接、执行查询、执行SQL查询以插入和更新数据以及处理异常。通过将这些技术融入您的工作流程，您可以构建利用Oracle数据库和Python优势的稳健应用程序。

  分享本文

如果你发现文章内容有误, 您可以 请求更新