python连接oracle数据库（ubuntu和window）

python连接oracle数据库相对较为麻烦，需要先配置客户端的环境
下面介绍window和ubuntu配置方式

Ubuntu环境配置

1、安装cx_oracle模块，但是这个模块还是不能用，需要往下配置一些东西

   pip3 install cx_Oracle

2、下载所需的软件包：
注意：根据自己连接oracle数据库版本下载

3、在/usr/local/目录下创建Oracle文件夹

   sudo mkdir /usr/local/Oracle

4、解压instantclient-basic-linux.x64-11.2.0.4.0.zip和instantclient-sdk-linux.x64-11.2.0.4.0.zip，如图：
注意：两个文件夹下的文件都放在Oracle目录下，这步很重要！很重要！很重要！

5、配置环境变量

  sudo vim /etc/profife

将下面复制到profife文件末尾

  export ORACLE_HOME=/usr/local/Oracle
  export PATH=$PATH:$ORACLE_HOME
  export LD_LIBRARY_PATH=$LD_LIBRARY_PATH:$ORACLE_HOME
  # 下面两行是解决编码问题，如果不设置下面两行，从oracle导出中文数据会出现乱码
  export LANG="zh_CN.UTF-8"
  export NLS_LANG=AMERICAN_AMERICA.UTF8

6、重启Ubuntu系统

   reboot

Window系统配置

1、安装cx_oracle模块，还是跟Ubuntu一样，这样安装之后不能用，需要配置环境

   pip3 install cx_Oracle

2、下载所需的软件包
注意：根据自己连接oracle数据库版本和系统位数下载

3、解压instantclient-basic-windows.x64-11.2.0.4.0.zip，并将整个文件移动到某盘位置，本人是放置到C:\Program Files，然后点击运行instantclient_11_2里的adrci.exe如图：

4、双击安装vcredist_x64.exe
5、配置path变量
　　1）将instantclient_11_2路径添加到path环境变量中；如果本地还安装有oracle数据库，要添加到oracle的路径前面

　　2）新建ORACLE_HOME,TNS_ADMIN,NLS_LANG 三个变量，NLS_LANG是为了防止中文乱码

6、将instantclient_11_2目录下oci.dll，oraocci11.dll，oraociei11.dll复制到python\Lib\site-packages目录下
7、创建一个监听文件tnsnames.ora到C:\Program Files\instantclient_11_2，打开添加以下内容，并保存

oral=
     (DESCRIPTION =
     (ADDRESS = (PROTOCOL = TCP)(HOST= IP地址)(PORT =端口))
     (CONNECT_DATA =
     (SERVER = DEDICATED)
     (SERVICE_NAME =数据库名称)
     ) )

cx_Oracle模块

使用cx_Oracle模块连接有三种方式：

    第一种方式
    cx_Oracle.connect('账号/密码@ip:端口/数据库名称')
  
    第二种方式
    cx_Oracle.connect('账号', '密码', 'ip:端口/数据库名称')

    第三种方式
    tns = cx_Oracle.makedsn('ip', '端口'， '数据库名称')
    cx_Oracle.connect('账号', '密码', tns)

python操作oracle数据库方式

import cx_Oracle

class PyOracle(object):
"""创建python操作oracle类"""
def __init__(self, username, password, hosts):
    # 连接oracle数据库
    self.conn = cx_Oracle.connect(username, password, hosts)
    # 建立游标对象
    self.cursor = self.conn.cursor()

def __del__(self):
    # 关闭数据库连接
    self.cursor.close()
    self.conn.close()

def get_row(self, sql):
    # 生成器获取数据
    self.cursor.execute(sql)
    for row in self.cursor:
        yield row

def get_column(self, sql):
    # 获取字段
    self.cursor.execute(sql)
    fieldnames = []
    columns = self.cursor.description
    if columns:
        for column in columns:
            column = column[0].lower()
            fieldnames.append(column)
    return fieldnames

def get_one(self, sql):
    # 获取一条数据
    self.cursor.execute(sql)
    return self.cursor.fetchone()

def get_all(self, sql):
    # 获取所有数据
    self.cursor.execute(sql)
    return self.cursor.fetchall()

参考资料：

cx_oracle官方文档：https://cx-oracle.readthedocs.io/en/latest/module.html

最后编辑于：2019.01.12 10:06:04