ORACLE中CX_ORACLE库怎么用

小编给大家分享一下ORACLE中CX_ORACLE库怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

1、安装cx_Oracle包：

pip install cx_Oracle

         当前版本7.0

2、创建数据库连接的三种方式：

方法一：用户名、密码和监听分开写

import cx_Oracle

db=cx_Oracle.connect('username/password@host/orcl')

db.close()

方法二：用户名、密码和监听写在一起

import cx_Oracle

db=cx_Oracle.connect('username','password','host/orcl')

db.close()

方法三：配置监听并连接

import cx_Oracle

tns=cx_Oracle.makedsn('host',1521,'orcl')

db=cx_Oracle.connect('username','password',tns)

db.close()

3、建立cursor并执行SQL语句：查询、更新、插入、删除

创建数据库连接，创建游标cursor，然后执行sql语句，执行完成后，关闭游标，关闭数据库连接

创建连接后，建立cursor，并执行SQL语句

#encoding=utf-8

# 示例

import cx_Oracle

conn = cx_Oracle.connect('system/oracle@192.0.2.7/orcl')

cursor = conn.cursor()

#执行语句的两种方式，预处理和直接执行

# 首先准备该语句，然后利用改变的参数执行 None。根据绑定变量时准备一个语句即足够这一原则，Oracle 将如同在上例中一样对其进行处理。准备好的语句可执行任意次。

sql = "select * from dba_users where user_id = :dbv"

cursor.prepare(sql)

rs = cursor.execute (None,{'dbv':63})

rsa = cursor.fetchall()

print (rsa)

# 直接执行

cursor.execute ("select * from dba_users where user_id=62")

row = cursor.fetchone ()

print (row[0])

cursor.close ()

conn.close()

import cx_Oracle

# 创建连接后，建立cursor，并执行SQL语句

db=cx_Oracle.connect('system','oracle','10.98.156.148/oral')

# db.close()

cr =  db.cursor() # 创建cursor

sql =  'select * from v$version'

cr.execute(sql) # 执行sql语句

# 一次返回所有结果集 fetchall

rs = cr.fetchall()

print("print all:(%s)" %rs)

for x in rs:

    print (x)

# 一次返回一行 fetchone

print("fetchone")

cr.execute(sql)

while (1):

    rs = cr.fetchone()

    if rs == None:

        break

    print(rs)

#使用参数查询

pr = {'dbv':'61'}

cr.execute('select * from dba_users where user_id = :dbv',pr)

# 这里将参数作为一个字典来处理

rs = cr.fetchall()

print("parameter print all:(%s)" %rs)

cr.execute('select * from dba_users where user_id =  :dbv',dbv = '61')

# 这里直接写参数

rs = cr.fetchall()

print("parameter print all: (%s)" %rs)

cr.close()

db.close()

#  插入、更新、删除操作后需要提交commit

#  查询include:select

def sqlSelect(sql,db):

    cr=db.cursor()

    cr.execute(sql)

    rs=cr.fetchall()

    cr.close()

    return rs

# 插入、更新、删除操作后需要提交include:insert,update,delete

def sqlDML(sql,db):

    cr=db.cursor()

    cr.execute(sql)

    cr.close()

    db.commit()

# execute dml with parameters

def sqlDML2(sql,params,db):

    cr=db.cursor()

    cr.execute(sql,params)

    cr.close()

    db.commit()

#增删改查 示例

#1、单条插入：

sql = "INSERT INTO T_AUTOMONITOR_TMP(point_id) VALUES(:pointId)"

cursorObj.prepare(sql)

rown = cursorObj.execute(None, {'pointId' : pointId})

connectObj.commit()

#2、多条插入：

sql = "INSERT INTO T_AUTOMONITOR_TMP(point_id) VALUES(:pointId)"

cursorObj.prepare(sql)

rown = cursorObj.executemany(None, recordList)

connectObj.commit()

#删

sql = "DELETE FROM T_AUTOMONITOR_TMP t WHERE t.point_id = :pointId "

cursorObj.prepare(sql)

rown = cursorObj.execute(None, {'pointId' : pointId})

connectObj.commit()

#改

sql = "UPDATE t_automonitor_other t\

      SET t.active = '2'\

      WHERE t.active = '1'\

      AND t.point_id = :pointId\

      "

cursorObj.prepare(sql)

cursorObj.execute(None, {'pointId' : pointId})

connectObj.commit()

#查

sql = "SELECT t.describ FROM t_automonitor_tmp t WHERE t.point_id = :pointId"

cursorObj.prepare(sql)

cursorObj.execute(None, {'pointId' : pointId})

#在绑定时，您可以首先准备该语句，然后利用改变的参数执行 None。根据绑定变量时准备一个语句即足够这一原则，Oracle 将如同在上例中一样对其进行处理。准备好的语句可执行任意次。

r1 = cursor.execute('SELECT * FROM locations WHERE country_id=:1 AND city=:2', ('US', 'Seattle'))

#数据库操作简单工具

class baseUtilsX():

    """baseUtils"""

    def __init__(self):

        self.connectObj = ""

        self.connCnt = 0

        self.cursorCnt = 0

    def initOracleConnect(self):

        oracle_tns = cx_Oracle.makedsn('XXX.XXX.XXX.XXX', 1521,'XX')

        if self.connCnt == 0:

            self.connectObj = cx_Oracle.connect('oracleUserName', 'password', oracle_tns)

            self.connCnt += 1

    def getOracleConnect(self):

        self.initOracleConnect()

        return self.connectObj

    def closeOracleConnect(self, connectObj):

        connectObj.close()

        self.connCnt -= 1

    def getOracleCursor(self):

        self.initOracleConnect()

        self.cursorCnt += 1

        return self.connectObj.cursor()

    def closeOracleCursor(self, cursorObj):

        cursorObj.close()

        self.cursorCnt -= 1

        if self.cursorCnt == 0:

            print "will close conn"

            self.closeOracleConnect(self.connectObj)

    def selectFromDbTable(self, sql, argsDict):

        # 将查询结果由tuple转为list

        queryAnsList = []

        selectCursor = self.getOracleCursor()

        selectCursor.prepare(sql)

        queryAns = selectCursor.execute(None, argsDict)

        for ansItem in queryAns:

            queryAnsList.append(list(ansItem))

        self.closeOracleCursor(selectCursor)

        return queryAnsList

# 摘录oracle官方文档https://www.oracle.com/technetwork/cn/articles/dsl/mastering-oracle-python-1391323-zhs.html 

# oracle 日期函数

# 使用 EXTRACT 语句通过 SQL 查询将年、月、日这些字段提取出来

SELECT EXTRACT(YEAR FROM hire_date) FROM employees ORDER BY 1;

使用 Python 的 datetime.date、datetime.time 和 datetime.datetime 对象作为绑定变量来查询日期

如果您需要将现有的字符串分析为 date(time) 对象，可以使用 datetime 对象的 strptime() 方法。

>>> from datetime import datetime

>>> datetime.strptime("2007-12-31 23:59:59", "%Y-%m-%d %H:%M:%S")

datetime.datetime(2007, 12, 31, 23, 59, 59)

>>> import datetime

>>> d = datetime.datetime.now()

>>> print d

2007-03-03 16:48:27.734000

>>> print type(d)

<type 'datetime.datetime'>

>>> print d.hour, d.minute, d.second

(16, 48, 27)

--EXTRACT() 函数用于提取日期/时间的单独部分，比如年、月、日、小时、分钟等等。 

select sysdate,

       extract(year from sysdate),

       extract(month from sysdate),

       extract(day from sysdate)

  from dual s;

SELECT EXTRACT(HOUR FROM TIMESTAMP '2010-01-10 11:12:13'),

       EXTRACT(minute FROM TIMESTAMP '2010-01-10 11:12:13'),

       EXTRACT(second FROM TIMESTAMP '2010-01-10 11:12:13')

  FROM DUAL;

#精通 Oracle+Python，第 3 部分：数据解析

https://www.oracle.com/technetwork/cn/articles/dsl/prez-python-dataparsing-087750-zhs.html

有关使用正则表达式的最好建议是尽可能地避免使用它们。在将它们嵌入代码前，请确定没有字符串方法可以完成相同的工作，因为字符串方法更快且不会带来导入以及正则表达式处理这些额外的开销。在字符串对象上使用 dir() 就可以看到可用的内容。

下例展示了在 Python 这样一种动态语言中看待正则表达式的方式。解析 tnsnames.ora 文件以便为每个网络别名创建简单连接字符串（将 file() 函数指向您的 tnsnames.ora 文件的位置）：

>>> import re

>>> tnsnames = file(r'tnsnames.ora').read()

>>> easy_connects = {}

>>> tns_re = "^(\w+?)\s?=.*?HOST\s?=\s?(.+?)\).*?PORT\s?=\s?(\d+?)\).*?SERVICE_NAME\s?=\s?(.+?)\)"

>>> for match in re.finditer(tns_re, tnsnames, re.M+re.S):

...  t = match.groups()

...  easy_connects[t[0]] = "%s:%s/%s" % t[1:]

>>> print easy_connects

此程序在 Oracle Database XE 默认的 tnsnames.ora 文件上的输出是：

{'XE': 'localhost:1521/XE'}

以上是“ORACLE中CX_ORACLE库怎么用”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注亿速云行业资讯频道！