目录
创建一个python项目,并配置运行环境
查看oracle对应数据库版本(该标题下内容只是为了查看版本,不用在意)
从oracle官网下载对应版本的oracle客户端
解压下载的压缩包,并获取依赖
将依赖文件导入python项目运行环境中
创建一个python项目,并配置运行环境
- 第一步:点击创建项目
- 创建该项目对应的文件目录,建议直接问gpt,我在项目中是使用了非常简单的关联关系,对应每个部分的具体功能如图所示。
查看oracle对应数据库版本
- 先在oracle数据库中查看对应的oracle数据库版本【需要根据oracle版本去下载对应的oracle依赖,否则的话会报错说版本不一致问题】。
- 我使用的是DBeaver软件去连接Oracle数据库的,这是连接数据库的软件,不用在意。
-- 执行语句如下 SELECT * FROM v$version;
从oracle官网下载对应版本的oracle客户端
- 浏览器直接搜索oracle.com即可,进入官网,找到对应的下载版本,我使用的是windows系统,所以从windows系统下的不同版本中选择“Oracle数据库对应的版本”
- 选择对应的版本后,从该版本多个不同的套餐中选择自己需要的,因为我只需要连接到oracle数据库进行简单的增删查改,所以就选择第一个套餐。
解压下载的压缩包,并获取依赖
- 解压下载到的压缩包,并从其中找到python项目所需的依赖
将依赖文件导入python项目运行环境中
- 将前面的oracle版本依赖导入到python项目运行环境中,直接复制粘贴即可,粘贴的目录通常位于你的Python安装目录下的
Lib\site-packages文件夹下面
- 到这里就大功告成了,直接运行代码即可
- 代码如下:
import json
import logging
from datetime import datetimeimport cx_Oracledef sql_data_process(sql, limit: str = None, pageNo: str = None):result = []try:connection = cx_Oracle.connect("用户名", "密码", "主机名:1521/orcl")cursor = connection.cursor()cursor.execute(sql)resultProxy = cursor.fetchall()# 获取列名columns = [desc[0] for desc in cursor.description]result = []for row in resultProxy:# 创建一个空字典来存储行数据row_data = {}for i, col in enumerate(columns):# 使用整数索引访问元组中的元素cell = row[i]# 检查是否为日期时间类型if isinstance(cell, datetime):# 将日期时间类型转换为字符串格式cell = cell.strftime('%Y-%m-%d %H:%M:%S')# 将列名和转换后的单元格数据存储在字典中row_data[col] = cellresult.append(row_data)cursor.close()connection.close()except Exception as e:print(f"sql执行失败,失败原因:{str(e)}")passif limit and pageNo:# 实现分页功能start_limit = (int(pageNo) - 1) * int(limit)end_limit = start_limit + int(limit)return result[start_limit:end_limit]return result