python连接oracle数据库相对较为麻烦,需要先配置客户端的环境
下面介绍window和ubuntu配置方式
相关软件包的下载链接
https://www.oracle.com/technetwork/database/database-technologies/instant-client/downloads/index.html
http://www.liangchan.net/soft/softdown.asp?softid=3106
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
网友评论