怎么在Python中使用cx_Oracle模块对Oracle数据库进行操作

发布时间：2021-03-17 16:32:34

来源：亿速云

阅读：67

作者：Leah

本篇文章为大家展示了怎么在Python中使用cx_Oracle模块对Oracle数据库进行操作，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。

1. 下载cx_Oracle

Python一个官方网站PyPI，上面有丰富的模块。cx_Oracle就可以在PyPI中下载。打开PyPI的网址https://pypi.python.org/pypi，在里面搜索cx_Oracle，即可找到该模块，其下载地址为http://cx-oracle.sourceforge.net/。当然也可以通过其它的途径下载。

下载之后就可以使用了。

2. 使用流程

简单的使用流程如下：

①.引用模块cx_Oracle

②.连接数据库

③.获取cursor

④.使用cursor进行各种操作

⑤.关闭cursor

⑥.关闭连接

下面是一个简单的例子：

cx_Oracle.connect("用户名 /  密码@ Oracle服务器IP  /  Oracle的SERVICE_NAME")

获得 Oracle的SERVICE_NAME：

su - oracle #切换至oracle用户

env | grep ORACLE #查询ORACLE的环境变量

ORACLE_SID=benguo # benguo就是SERVICE_NAMEimport cx_Oracle                     #引用模块cx_Oracle

conn=cx_Oracle.connect('load/123456@localhost/ora11g')  #连接数据库

c=conn.cursor()                      #获取cursor

x=c.execute('select sysdate from dual')          #使用cursor进行各种操作

x.fetchone()

c.close()                         #关闭cursor

conn.close()                       #关闭连接

例子：#coding:utf-8

import cx_Oracle

def main():

conn = cx_Oracle.connect("zebra/zebra@192.168.0.113/benguo")

cur =conn.cursor()

r= cur.execute("select * from userinfo")

print

print r.fetchone()

if __name__ == '__main__':

main()

3. 几种用法

Python对数据库的操作主要有2方面：一个是写数据，一个是读数据。这2个方面的实现可以通过SQL语句实现，也可以通过存储过程实现。所以cx_Oracle的主要用法有：

①. 执行SQL语句

②. 调用存储过程和函数。

4. 执行SQL语句

执行SQL语句很简单，从上面的例子就可以看出。使用cursor.execute即可执行。使用fetchone或fetchall即可将执行结果读出来。

下面一个例子是Insert语句，使用的变量绑定。import cx_Oracle

conn=cx_Oracle.connect('load/123456@loaclhost/ora11g')

c=conn.cursor()

x=c.execute('insert into demo(v) values(:1)',['nice'])

conn.commit();

c.close()

conn.close()

变量绑定和Oracle的动态SQL一样，都是冒号将占位符，即代码中的:1，对变量的复制就是传入一个List，即代码中的['nice']。有多少个变量，list中就应该对应多少个值，数目要一致，否则会报错。

执行之后，可以使用连接的一个方法connect.commit()，将事务提交。

5. 调用存储过程和方法

直接上代码：--存储过程代码：

CREATE OR REPLACE PROCEDURE P_DEMO(V1 IN VARCHAR2, V2 OUT VARCHAR2) IS

BEGIN

V2 := V1;

END;#Python代码：

import cx_Oracle

conn=cx_Oracle.connect('load/123456@localhost/ora11g')

c=conn.cursor()

str1='nice'

str2='  '#需要有值，即len(str2)>=len(str1)

x=c.callproc('p_demo',[str1,str2])

print(str2)

c.close()

conn.close()

调用存储过程使用的是cursor.callproc方法。上面的存储过程中，一个变量的值是OUT型的，在Python中，对OUT型的变量赋值，主要该变量的长度不能小于存储过程中的。--函数代码：

CREATE OR REPLACE function F_DEMO(V1 VARCHAR2) RETURN VARCHAR2 IS

BEGIN

RETURN V1;

END;#Python代码：

import cx_Oracle

conn=cx_Oracle.connect('load/123456@localhost/ora11g')

c=conn.cursor()

str1='nice'

str2=c.callfunc('f_demo',cx_Oracle.STRING,[str1])

print(str2)

c.close()

conn.close()

调用函数使用的方法是cursor.callfunc。这个与调用存储过程不同之处在于，它需要指定传输参数的类型。

上述内容就是怎么在Python中使用cx_Oracle模块对Oracle数据库进行操作，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。