快捷導(dǎo)航

python操作oracle的完整教程分享

更新時(shí)間：2018年01月30日 10:03:15 作者：neweastsun

下面小編就為大家分享一篇python操作oracle的完整教程，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧，祝大家游戲愉快哦

1. 連接對(duì)象

操作數(shù)據(jù)庫(kù)之前，首先要建立數(shù)據(jù)庫(kù)連接。

有下面幾個(gè)方法進(jìn)行連接。

>>>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.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對(duì)象

使用數(shù)據(jù)庫(kù)連接對(duì)象的cursor（）方法，你可以定義任意數(shù)量的cursor對(duì)象，簡(jiǎn)單的程序可能使用一個(gè)cursor，并重復(fù)使用了，但大型項(xiàng)目會(huì)使用多個(gè)不同的cursor。

>>>cursor= db.cursor()

應(yīng)用程序邏輯通常需要清楚的區(qū)分處理數(shù)據(jù)操作的每個(gè)階段。這將幫助更好的理解性能瓶頸和代碼優(yōu)化。

這些步驟有：

parse（optional）

無(wú)需調(diào)用該方法，因?yàn)閳?zhí)行階段會(huì)自動(dòng)先執(zhí)行，用于檢查sql語(yǔ)句是否正確，當(dāng)有錯(cuò)誤時(shí)，拋出DatabaseError異常及相應(yīng)的錯(cuò)誤信息。如：‘'ORA-00900：invalid SQL statement.“。

Execute
cx_Oracle.Cursor.execute(
statement,[parameters], **keyword_parameters)

該方法能接收單個(gè)參數(shù)SQL，直接操作數(shù)據(jù)庫(kù)，也可以通過(guò)綁定變量執(zhí)行動(dòng)態(tài)SQL，parames或keyworparameters可以是字典、序列或一組關(guān)鍵字參數(shù)。

cx_Oracle.Cursor.executemany(statement,parameters)

特別有用的批量插入，避免一次只能插入一條；

Fetch(optional)

僅用于查詢，因?yàn)镈DL和DCL語(yǔ)句沒有返回結(jié)果。如果cursor沒有執(zhí)行查詢，會(huì)拋出InterfaceError異常。

cx_Oracle.Cursor.fetchall()

獲取所有結(jié)果集，返回元祖列表，如果沒有有效行，返回空列表。

cx_Oracle.Cursor.fetchmany([rows_no])

從數(shù)據(jù)庫(kù)中取下一個(gè)rows_no數(shù)據(jù)

cx_Oracle.Cursor.fetchone()

從數(shù)據(jù)庫(kù)中取單個(gè)元祖，如果沒有有效數(shù)據(jù)返回none。

3. 綁定變量

綁定變量查詢可以提高效率，避免不必要的編譯；參數(shù)可以是名稱參數(shù)或位置參數(shù)，盡量使用名稱綁定。

>>>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的批量插入功能，無(wú)需多次單獨(dú)調(diào)用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 = cx_Oracle.connect("%s/%s@%s/%s" % (userName,password,host,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,sql,nameParams={}):
 if len(nameParams) > 0 :
  self.cursor.execute(sql,nameParams)
 else:
  self.cursor.execute(sql)
  
 return self.cursor.fetchall()
 
 def insertBatch(self,sql,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,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
 
 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的完整教程分享就是小編分享給大家的全部?jī)?nèi)容了，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

您可能感興趣的文章: