import pandas as pd import cx_Oracle def import_data_to_oracle(file_path,table_name): # 连接 ORACLE 数据库 conn = cx_Oracle.connect('lh','Lh*202209','10.66.20.20/lhdb') cursor = conn.cursor() # 读取 CSV 文件 csv_data = pd.read_csv(file_path) # 迭代插入数据 count = 0 for index, row in csv_data.iterrows(): # 构造插入语句 insert_sql = "INSERT INTO " + table_name + " (column1, column2, ...) " \ + "VALUES (value1, value2, ...)" print(insert_sql) # 执行插入操作 cursor.execute(insert_sql) # 计数器 +1 count += 1 # 每 10000 行数据，执行一次提交操作 if count % 10000 == 0: conn.commit() print(f"{count}rows committed.") # 最后执行一次提交操作，确保所有数据被正确插入 conn.commit() # 关闭游标和连接 cursor.close() conn.close()

这是一段 Python 代码，导入了 Pandas 和 cx_Oracle 两个库。它定义了一个名为 import_data_to_oracle 的函数，该函数接受两个参数：文件路径和表名。该函数的功能是将指定路径下的数据导入到 Oracle 数据库的指定表格中。