1. 连接对象
*** 作数据库之前,首先要建立数据库连接。
有下面几个方法进行连接。
>>>import cx_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')>>>print dsn_tns >>>print db.version10.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.dsnlocalhost:1521/XE
2. cursor对象
使用数据库连接对象的cursor()方法,你可以定义任意数量的cursor对象,简单的程序可能使用一个cursor,并重复使用了,但大型项目会使用多个不同的cursor。
>>>cursor= db.cursor()
应用程序逻辑通常需要清楚的区分处理数据 *** 作的每个阶段。这将帮助更好的理解性能瓶颈和代码优化。
这些步骤有:
parse(optional)
无需调用该方法,因为执行阶段会自动先执行,用于检查SQL语句是否正确,当有错误时,抛出DatabaseError异常及相应的错误信息。如:‘'ORA-00900:invalID sql statement.“。
Executecx_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 * FROM employees WHERE department_ID=:dept_IDAND salary>:sal',named_params)>>> query2 = cursor.execute('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_Oracleclass Oracle(object): """ oracle db operator """ def __init__(self,username,password,host,instance): self._conn = cx_Oracle.connect("%s/%s@%s/%s" % (username,instance)) self.cursor = self._conn.cursor() def queryTitle(self,sql,nameParams={}): if len(nameParams) > 0 : self.cursor.execute(sql,nameParams) else: self.cursor.execute(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): self.cursor.execute(sql) return self.cursor.fetchall() def queryOne(self,sql): self.cursor.execute(sql) return self.cursor.fetchone() def queryBy(self,nameParams) else: self.cursor.execute(sql) return self.cursor.fetchall() def insertBatch(self,nameParams=[]): """batch insert much rows one time,use location parameter""" self.cursor.prepare(sql) self.cursor.executemany(None,nameParams) self.commit() def commit(self): self._conn.commit() 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,'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','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 cursor.execute(create_table) 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) cursor.execute("SELECT COUNT(*) FROM python_modules") print(cursor.fetchone()) print('insert batch ok.') cursor.execute("DROP table python_modules PURGE")test2()
以上这篇python *** 作oracle的完整教程分享就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持编程小技巧。
您可能感兴趣的文章:python链接Oracle数据库的方法python连接oracle数据库实例python安装oracle扩展及数据库连接方法windows下python连接oracle数据库 总结以上是内存溢出为你收集整理的python *** 作oracle的完整教程分享全部内容,希望文章能够帮你解决python *** 作oracle的完整教程分享所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)