Python高效处理Oracle数据库与CSV文件：数据导入导出与批量操作362

在日常数据处理工作中，我们经常需要在Python程序中操作Oracle数据库和CSV文件。这两种数据存储方式各有优劣，Oracle数据库提供强大的数据管理和安全性，而CSV文件则以其简单易读的格式方便数据交换。因此，掌握Python高效处理这两种数据格式的能力至关重要。本文将详细介绍如何使用Python连接Oracle数据库，以及如何将数据从Oracle数据库导出到CSV文件，或将CSV文件导入到Oracle数据库，并涵盖批量操作以提高效率。

一、连接Oracle数据库

连接Oracle数据库需要使用`cx_Oracle`库。首先，确保已安装该库：pip install cx_Oracle。安装完成后，可以使用以下代码连接到Oracle数据库：```python
import cx_Oracle
def connect_to_oracle(username, password, host, port, sid):
"""连接到Oracle数据库。"""
try:
connection = (username, password, f"{host}:{port}/{sid}")
print("连接成功!")
return connection
except as e:
print(f"连接失败: {e}")
return None
# 配置信息，请替换为你的实际信息
username = "your_username"
password = "your_password"
host = "your_host"
port = "your_port"
sid = "your_sid"
connection = connect_to_oracle(username, password, host, port, sid)
if connection:
cursor = ()
# ... 执行数据库操作 ...
()
()
```

这段代码定义了一个函数`connect_to_oracle`，接收数据库连接信息并返回连接对象。请将占位符替换为你的实际Oracle数据库连接信息。连接成功后，可以使用游标对象`cursor`执行SQL语句。

二、从Oracle数据库导出数据到CSV文件

导出数据可以使用`()`执行SQL查询，并将结果写入CSV文件。以下代码演示如何将Oracle数据库表中的数据导出到CSV文件：```python
import csv
import cx_Oracle
# ... (连接数据库代码，参考上面) ...
def export_to_csv(cursor, table_name, csv_filepath):
"""将Oracle数据库表数据导出到CSV文件。"""
try:
(f"SELECT * FROM {table_name}")
rows = ()
with open(csv_filepath, 'w', newline='', encoding='utf-8') as csvfile:
writer = (csvfile)
([i[0] for i in ]) # 写入表头
(rows)
print(f"数据已成功导出到{csv_filepath}")
except as e:
print(f"导出数据失败: {e}")
# 指定表名和CSV文件路径
table_name = "your_table_name"
csv_filepath = ""
export_to_csv(cursor, table_name, csv_filepath)
# ... (关闭连接) ...
```

这段代码定义了一个函数`export_to_csv`，接收游标对象、表名和CSV文件路径作为参数，将查询结果写入CSV文件。注意`encoding='utf-8'`用于处理中文等特殊字符。你需要根据你的数据库表结构调整代码。

三、将CSV文件导入到Oracle数据库

导入CSV文件到Oracle数据库，可以使用SQL的`INSERT ALL`语句或者使用Python循环插入。以下代码演示如何使用`INSERT ALL`语句批量导入数据：```python
import csv
import cx_Oracle
# ... (连接数据库代码，参考上面) ...
def import_from_csv(cursor, csv_filepath, table_name):
"""将CSV文件导入到Oracle数据库表。"""
try:
with open(csv_filepath, 'r', encoding='utf-8') as csvfile:
reader = (csvfile)
header = next(reader) # 读取表头
sql = f"INSERT ALL "
for row in reader:
values = ",".join([f"'{value}'" for value in row]) # 简单处理，避免SQL注入，更稳妥的方式是使用参数化查询
sql += f"INTO {table_name} ({','.join(header)}) VALUES ({values}) "
sql += "SELECT 1 FROM dual"
(sql)
()
print(f"数据已成功导入到{table_name}")
except as e:
print(f"导入数据失败: {e}")
()

csv_filepath = ""
table_name = "your_table_name"
import_from_csv(cursor, csv_filepath, table_name)
# ... (关闭连接) ...
```