python操作oracle的完整教程分享
1.连接对象
操作数据库之前，首先要建立数据库连接。
有下面几个方法进行连接。
>>>importcx_Oracle
>>>db=cx_Oracle.connect('hr','hrpwd','localhost:1521/XE')
>>>db1=cx_Oracle.connect('hr/hrpwd@localhost:1521/XE')
>>>dsn_tns=cx_Oracle.makedsn('localhost',1521,'XE')
>>>printdsn_tns
>>>printdb.version
10.2.0.1.0
>>>versioning=db.version.split('.')
>>>printversioning
['10','2','0','1','0']
>>>ifversioning[0]=='10':
...print"Running10g"
...elifversioning[0]=='9':
...print"Running9i"
...
Running10g
>>>printdb.dsn
localhost:1521/XE
2.cursor对象
使用数据库连接对象的cursor（）方法，你可以定义任意数量的cursor对象，简单的程序可能使用一个cursor，并重复使用了，但大型项目会使用多个不同的cursor。
>>>cursor=db.cursor()
应用程序逻辑通常需要清楚的区分处理数据操作的每个阶段。这将帮助更好的理解性能瓶颈和代码优化。
这些步骤有：
parse（optional）
无需调用该方法，因为执行阶段会自动先执行，用于检查sql语句是否正确，当有错误时，抛出DatabaseError异常及相应的错误信息。如：‘'ORA-00900：invalidSQLstatement.“。
Execute cx_Oracle.Cursor.execute( statement,[parameters],**keyword_parameters)
该方法能接收单个参数SQL，直接操作数据库，也可以通过绑定变量执行动态SQL，parames或keyworparameters可以是字典、序列或一组关键字参数。
cx_Oracle.Cursor.executemany(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.绑定变量
绑定变量查询可以提高效率，避免不必要的编译；参数可以是名称参数或位置参数，尽量使用名称绑定。
>>>named_params={'dept_id':50,'sal':1000}
>>>query1=cursor.execute('SELECT*FROMemployeesWHEREdepartment_id=:dept_idANDsalary>:sal',named_params)
>>>query2=cursor.execute('SELECT*FROMemployeesWHEREdepartment_id=:dept_idANDsalary>:sal',dept_id=50,sal=1000)
Whenusingnamedbindvariablesyoucancheckthecurrentlyassignedonesusingthebindnames()methodofthecursor:
>>>printcursor.bindnames()
['DEPT_ID','SAL']
4.批量插入
大量插入插入操作，可以使用python的批量插入功能，无需多次单独调用insert，这样可以提升性能。参考后面示例代码。
5.示例代码
'''
Createdon2016年7月7日
@author:Tommy
'''
importcx_Oracle
classOracle(object):
"""oracledboperator"""
def__init__(self,userName,password,host,instance):
self._conn=cx_Oracle.connect("%s/%s@%s/%s"%(userName,password,host,instance))
self.cursor=self._conn.cursor()
defqueryTitle(self,sql,nameParams={}):
iflen(nameParams)>0:
self.cursor.execute(sql,nameParams)
else:
self.cursor.execute(sql)
colNames=[]
foriinrange(0,len(self.cursor.description)):
colNames.append(self.cursor.description[i][0])
returncolNames
#querymethods
defqueryAll(self,sql):
self.cursor.execute(sql)
returnself.cursor.fetchall()
defqueryOne(self,sql):
self.cursor.execute(sql)
returnself.cursor.fetchone()
defqueryBy(self,sql,nameParams={}):
iflen(nameParams)>0:
self.cursor.execute(sql,nameParams)
else:
self.cursor.execute(sql)
returnself.cursor.fetchall()
definsertBatch(self,sql,nameParams=[]):
"""batchinsertmuchrowsonetime,uselocationparameter"""
self.cursor.prepare(sql)
self.cursor.executemany(None,nameParams)
self.commit()
defcommit(self):
self._conn.commit()
def__del__(self):
ifhasattr(self,'cursor'):
self.cursor.close()
ifhasattr(self,'_conn'):
self._conn.close()
deftest1():
#sql="""selectuser_name,user_real_name,to_char(create_date,'yyyy-mm-dd')create_datefromsys_userwhereid='10000'"""
sql="""selectuser_name,user_real_name,to_char(create_date,'yyyy-mm-dd')create_datefromsys_userwhereid=:id"""
oraDb=Oracle('test','java','192.168.0.192','orcl')
fields=oraDb.queryTitle(sql,{'id':'10000'})
print(fields)
print(oraDb.queryBy(sql,{'id':'10000'}))
deftest2():
oraDb=Oracle('test','java','192.168.0.192','orcl')
cursor=oraDb.cursor
create_table="""
CREATETABLEpython_modules(
module_nameVARCHAR2(50)NOTNULL,
file_pathVARCHAR2(300)NOTNULL
)
"""
fromsysimportmodules
cursor.execute(create_table)
M=[]
form_name,m_infoinmodules.items():
try:
M.append((m_name,m_info.__file__))
exceptAttributeError:
pass
sql="INSERTINTOpython_modules(module_name,file_path)VALUES(:1,:2)"
oraDb.insertBatch(sql,M)
cursor.execute("SELECTCOUNT(*)FROMpython_modules")
print(cursor.fetchone())
print('insertbatchok.')
cursor.execute("DROPTABLEpython_modulesPURGE")
test2()
以上这篇python操作oracle的完整教程分享就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。