python操作oracle的完整教程分享
1. 连接对象
操作数据库之前，⾸先要建⽴数据库连接。
有下⾯⼏个⽅法进⾏连接。
>>>import cx_Oracle
>>>db = t('hr', 'hrpwd', 'localhost:1521/XE')
>>>db1 = t('hr/hrpwd@localhost:1521/XE')
>>>dsn_tns = cx_Oracle.makedsn('localhost', 1521, 'XE')
>>>print dsn_tns
>>>print db.version
10.2.0.1.0
>>> versioning = db.version.split('.')
>>> print versioning
['10', '2', '0', '1', '0']
>>> if versioning[0]=='10':
... print "Running 10g"
... elif versioning[0]=='9':
... print "Running 9i"
...
Running 10g
>>> print db.dsn
localhost:1521/XE
2. cursor对象
使⽤数据库连接对象的cursor（）⽅法，你可以定义任意数量的cursor对象，简单的程序可能使⽤⼀个cursor，并重复使⽤了，但⼤型项⽬会使⽤多个不同的cursor。
>>>cursor= db.cursor()
应⽤程序逻辑通常需要清楚的区分处理数据操作的每个阶段。这将帮助更好的理解性能瓶颈和代码优化。
这些步骤有：
parse（optional）
⽆需调⽤该⽅法，因为执⾏阶段会⾃动先执⾏，⽤于检查sql语句是否正确，当有错误时，抛出DatabaseError异常及相应的错误信息。如：‘'ORA-00900：invalid SQL statement.“。
Execute
cx_ute(
statement,[parameters], **keyword_parameters)
该⽅法能接收单个参数SQL，直接操作数据库，也可以通过绑定变量执⾏动态SQL，parames或keyworparameters可以是字典、序列或⼀组关键字参数。
cx_utemany(statement,parameters)
特别有⽤的批量插⼊，避免⼀次只能插⼊⼀条；
Fetch(optional)
仅⽤于查询，因为DDL和DCL语句没有返回结果。如果cursor没有执⾏查询，会抛出InterfaceError异常。
cx_Oracle.Cursor.fetchall()
获取所有结果集，返回元祖列表，如果没有有效⾏，返回空列表。
cx_Oracle.Cursor.fetchmany([rows_no])
从数据库中取下⼀个rows_no数据
cx_Oracle.Cursor.fetchone()
从数据库中取单个元祖，如果没有有效数据返回none。
3. 绑定变量
绑定变量查询可以提⾼效率，避免不必要的编译；参数可以是名称参数或位置参数，尽量使⽤名称绑定。
oracle10g程序异常终止>>>named_params = {'dept_id':50, 'sal':1000}
>>>query1 = ute('SELECT * FROM employees WHERE department_id=:dept_idAND salary>:sal', named_params)
>>> query2 = ute('SELECT * FROM employees WHERE department_id=:dept_idAND salary>:sal', dept_id=50, sal=1000) Whenusing named bind variables you can check the currently assigned ones using thebindnames() method of the cursor:
>>> printcursor.bindnames()
['DEPT_ID', 'SAL']
4. 批量插⼊
⼤量插⼊插⼊操作，可以使⽤python的批量插⼊功能，⽆需多次单独调⽤insert，这样可以提升性能。参考后⾯⽰例代码。
5. ⽰例代码
'''
Created on 2016年7⽉7⽇
@author: Tommy
'''
import cx_Oracle
class Oracle(object):
""" oracle db operator """
def __init__(self,userName,password,host,instance):
self._conn = t("%s/%s@%s/%s" % (userName,password,host,instance))
self.cursor = self._conn.cursor()
def queryTitle(self,sql,nameParams={}):
if len(nameParams) > 0 :
ute(sql,nameParams)
else:
ute(sql)
colNames = []
for i in range(0,len(self.cursor.description)):
colNames.append(self.cursor.description[i][0])
return colNames
# query methods
def queryAll(self,sql):
ute(sql)
return self.cursor.fetchall()
def queryOne(self,sql):
ute(sql)
return self.cursor.fetchone()
def queryBy(self,sql,nameParams={}):
if len(nameParams) > 0 :
ute(sql,nameParams)
else:
ute(sql)
return self.cursor.fetchall()
def insertBatch(self,sql,nameParams=[]):
"""batch insert much rows one time,use location parameter"""
self.cursor.prepare(sql)
utemany(None, nameParams)
selfmit()
def commit(self):
self._connmit()
def __del__(self):
if hasattr(self,'cursor'):
self.cursor.close()
if hasattr(self,'_conn'):
self._conn.close()
def test1():
# sql = """select user_name,user_real_name,to_char(create_date,'yyyy-mm-dd') create_date from sys_user where id = '10000' """
sql = """select user_name,user_real_name,to_char(create_date,'yyyy-mm-dd') create_date from sys_user where id =: id """
oraDb = Oracle('test','java','192.168.0.192','orcl')
fields = oraDb.queryTitle(sql, {'id':'10000'})
print(fields)
print(oraDb.queryBy(sql, {'id':'10000'}))
def test2():
oraDb = Oracle('test','java','192.168.0.192','orcl')
cursor = oraDb.cursor
create_table = """
CREATE TABLE python_modules (
module_name VARCHAR2(50) NOT NULL,
file_path VARCHAR2(300) NOT NULL
)
"""
from sys import modules
M = []
for m_name, m_info in modules.items():
try:
M.append((m_name, m_info.__file__))
except AttributeError:
pass
sql = "INSERT INTO python_modules(module_name, file_path) VALUES (:1, :2)"
oraDb.insertBatch(sql,M)
print(cursor.fetchone())
print('insert batch ok.')
test2()
以上这篇python操作oracle的完整教程分享就是⼩编分享给⼤家的全部内容了，希望能给⼤家⼀个参考，也希望⼤家多多⽀持。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。