Python调用SQLPlus操作与解析Oracle数据库的实现方法

在无第三方驱动时的替代查询思路

常规 Python 连接 Oracle 多依赖 cx_Oracle 或 oracledb，但在某些安全管控严格或轻量级脚本场景中，禁止安装外部模块。此时可借助操作系统已安装的 Oracle Instant Client 中的 sqlplus 工具，以进程方式注入 SQL 语句，并读取标准输出进行二次解析。该方法的核心在于统一输出样式与准确还原列宽映射。

第1步：设定字符集与语言环境

为避免中文或特殊字符在命令行回显中显示为乱码，必须在 Python 启动初期同步服务端字符集。执行以下 SQL 获取当前实例参数：

SELECT USERENV('LANGUAGE') FROM DUAL;

获取返回值后，在 Python 脚本顶部写入环境变量：

import os
# 替换为实际查得的值，例如 AMERICAN_AMERICA.AL32UTF8
os.environ['NLS_LANG'] = 'AMERICAN_AMERICA.AL32UTF8'

第2步：规范化 SQLPlus 输出参数

默认的 sqlplus 输出会包含分页符、提示信息及动态换行，导致后续解析错位。在执行目标 SQL 前，需追加固定格式控制指令，使返回结果成为规整的定宽文本：

set linesize 32767
set pagesize 9999
set term off verify off feedback off tab off
set numwidth 40

上述参数作用如下：

• linesize 32767：解除单行最大长度限制，防止长字段被截断。
• pagesize 9999：关闭常规分页，避免输出中途插入 --more-- 提示。
• term off verify off feedback off tab off：关闭终端特效、变量回显、行数统计及制表符转换，仅保留纯数据。

第3步：封装执行与解析函数

结合 subprocess 模块与文本切片逻辑，可构建稳定的查询接口。以下为 Python 3 环境下的完整实现，已修复旧版语法并优化了字节流处理：

import subprocess
import os

def parse_query_result(stdout_lines):
    """将 sqlplus 输出的定宽文本解析为字典列表"""
    parsed_list = []
    if len(stdout_lines) < 4:
        return parsed_list

    # 第2行（索引2）为下划线分隔条，按空格拆分后统计各段长度即实际列宽
    dash_parts = stdout_lines[2].split()
    col_widths = [len(part) for part in dash_parts if part]

    # 第1行为字段名，按对应宽度截取并去空
    title_line = stdout_lines[1]
    field_names = []
    cursor = 0
    for w in col_widths:
        field_names.append(title_line[cursor:cursor + w].strip())
        cursor += w + 1

    # 第3行起为实际数据，按相同坐标提取
    for i in range(3, len(stdout_lines)):
        row_text = stdout_lines[i].strip()
        if not row_text:
            continue
        row_map = {}
        pos = 0
        for idx, w in enumerate(col_widths):
            row_map[field_names[idx]] = row_text[pos:pos + w].strip()
            pos += w + 1
        parsed_list.append(row_map)
    return parsed_list

def query_by_sqlplus(sql_command, connect_string='-S / as sysdba'):
    full_script = f"""set linesize 32767
set pagesize 9999
set term off verify off feedback off tab off
set numwidth 40
{sql_command}
"""
    proc = subprocess.Popen(
        ['sqlplus'] + connect_string.split(),
        stdin=subprocess.PIPE,
        stdout=subprocess.PIPE,
        stderr=subprocess.PIPE
    )
    out_bytes, err_bytes = proc.communicate(full_script.encode('utf-8'))

    if proc.returncode != 0:
        raise RuntimeError(f'SQLPlus 执行异常: {err_bytes.decode("utf-8", errors="ignore")}')

    raw_text = out_bytes.decode('utf-8', errors='ignore')
    lines = raw_text.replace('\r\n', '\n').strip().split('\n')
    return parse_query_result(lines)

调用示例与结果验证

完成封装后，传入任意合法 SQL 即可获取结构化数据：

try:
    # 示例：查询学生信息表
    result_data = query_by_sqlplus('select sid, sname, address from studentinfo')
    
    # 遍历打印或存入其他数据结构
    for row in result_data:
        print(row)
except Exception as e:
    print(f'查询失败: {e}')

当记录较少且字段宽度符合预期时，控制台将直接输出整齐的字典集合。若单行文本长度超过物理屏幕，因设置了 linesize 32767 与 tab off，回显仍会保持单行连续，确保解析器不会因为换行错位。

常见执行问题排查

如果在生产或测试环境中遇到解析异常，请按顺序核对以下条件：

1. 列宽不一致：若某列实际数据宽度大于定义宽度，解析会向左挤压。请确认 col owner for a10 等别名修饰是否已在 SQL 内部声明，或直接在 parse_query_result 中增加容错跳过机制。
2. 编码报错：检查系统 locale 是否与 NLS_LANG 匹配。Windows 默认 GBK 编码环境建议在进程创建时强制传入 env={'PYTHONIOENCODING': 'utf-8'}。
3. 权限拒绝：/ as sysdba 依赖操作系统认证。若为普通用户登录，请将 connect_string 替换为 '-S username/password@host:port/service_name'。

以上就是Python调用SQLPlus操作与解析Oracle数据库的详细内容，更多关于Python数据库交互与命令行调用的资料请关注本站其它相关文章！