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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。