本文實例講述了Python操作Oracle數(shù)據(jù)庫的簡單方法和封裝類。分享給大家供大家參考，具體如下：
最近工作有接觸到Oracle，發(fā)現(xiàn)很多地方用Python腳本去做的話，應(yīng)該會方便很多，所以就想先學(xué)習(xí)下Python操作Oracle的基本方法。
考慮到Oracle的使用還有一個OracleClient的NetConfig的存在，我覺得連接起來就應(yīng)該不是個簡單的事情。
果然，網(wǎng)上找了幾個連接方法，然后依葫蘆卻畫了半天，卻也不得一個瓢。
方法1：用戶名，密碼和監(jiān)聽分別作為參數(shù)
conn=cx_Oracle.connect('用戶名','密碼','數(shù)據(jù)庫地址:數(shù)據(jù)庫端口/SID')根據(jù)我看的幾篇文章和我寫代碼出錯的提示，我找到了python連接數(shù)據(jù)庫的配置項應(yīng)該和Oracle客戶端的配置文件tnsnames.ora有關(guān)。但是我的配置項并沒有SID項，而且一開始我也不知SID是個什么東西，網(wǎng)上寫什么我就跟著寫，所以這種方法失敗了。后來想通了要在配置項加一個SID，然后想想這個東西配置完了我系統(tǒng)是不是要重啟啊。所以，先看看其他方法吧….
方法2：用戶名，密碼和監(jiān)聽共同作為一個參數(shù)
conn=cx_Oracle.connect('用戶名/密碼@數(shù)據(jù)庫地址:數(shù)據(jù)庫端口/SID')這個方法基本和方法一一樣，換湯不換藥…
方法3：使用tns配置信息
conn=cx_Oracle.connect('用戶名','密碼',tns)網(wǎng)上的代碼獲取tns是用函數(shù)做的，依然會使用SID，但是..我已經(jīng)可以用的配置項并沒有SID啊，所以使用
tns=cx_Oracle.makedsn('數(shù)據(jù)庫地址','數(shù)據(jù)庫端口', 'SID')依舊不行，但是看看這個tns的生成方法和上面的兩種方法差不多的。但是我發(fā)現(xiàn)我隨便輸入一個SID后生成的數(shù)據(jù)是這樣的。
(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521)))(CONNECT_DATA=(SID=XE)))
然而，我的客戶端的配置項大概是這樣的，
(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=KGDB)))
我擦，好像長得一樣的，類型也都是字符串類型的，試試直接把我文件里的配置項賦值給tns試試。
tns = '(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=KGDB)))'conn = cx_Oracle.connect('nicker', '123456', tns)嗯。成功了~
最后，貼一個基本使用方法全代碼
#coding:utf-8import cx_Oracle# 創(chuàng)建數(shù)據(jù)庫連接# cx_Oracle.connect('username','pwd','ora的tns信息')# oracle數(shù)據(jù)庫的tns信息，從tnsnames.ora中找到plsql可用的配置項，將該配置項直接拷貝過來即可ora_tns = '(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=127.0.0.1)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=KGDB)))'conn = cx_Oracle.connect('nicker', '123456', ora_tns)# 操作游標(biāo)cursor = conn.cursor()# 執(zhí)行查詢cursor.execute("SELECT * FROM inst_info")# 獲取返回信息rs = cursor.fetchall()# 輸出信息for v in rs: print v#關(guān)閉連接，釋放資源cursor.close()conn.close()觀察發(fā)現(xiàn)總結(jié)很重要，理解也需要
貼上一個自己封裝Oracle的類
#coding:utf-8import cx_Oracle# 封裝的類class cxOracle: ''' tns的取值tnsnames.ora對應(yīng)的配置項的值，如： tns = '(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=10.16.18.23)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=MYDB)))' ''' def __init__(self ,uname, upwd,tns ): self ._uname = uname self ._upwd = upwd self ._tns = tns self ._conn = None self ._ReConnect() def _ReConnect(self ): if not self._conn : self ._conn = cx_Oracle.connect (self. _uname, self ._upwd, self._tns) else: pass def __del__(self ): if self. _conn: self ._conn. close() self ._conn = None def _NewCursor(self ): cur = self. _conn.cursor () if cur: return cur else: print "#Error# Get New Cursor Failed." return None def _DelCursor(self , cur): if cur: cur .close() # 檢查是否允許執(zhí)行的sql語句 def _PermitedUpdateSql(self ,sql): rt = True lrsql = sql. lower() sql_elems = [ lrsql.strip ().split()] # update和delete最少有四個單詞項 if len( sql_elems) < 4 : rt = False # 更新刪除語句，判斷首單詞，不帶where語句的sql不予執(zhí)行 elif sql_elems[0] in [ 'update', 'delete']: if 'where' not in sql_elems : rt = False return rt # 導(dǎo)出結(jié)果為文件 def Export(self , sql, file_name, colfg ='||'): rt = self. Query(sql ) if rt: with open( file_name, 'a') as fd: for row in rt: ln_info = '' for col in row: ln_info += str( col) + colfg ln_info += '/n' fd .write( ln_info) # 查詢 def Query(self , sql, nStart=0 , nNum=- 1): rt = [] # 獲取cursor cur = self. _NewCursor() if not cur: return rt # 查詢到列表 cur .execute(sql) if ( nStart==0 ) and (nNum==1 ): rt .append( cur.fetchone ()) else: rs = cur. fetchall() if nNum==- 1: rt .extend( rs[nStart:]) else: rt .extend( rs[nStart:nStart +nNum]) # 釋放cursor self ._DelCursor(cur) return rt # 更新 def Exec(self ,sql): # 獲取cursor rt = None cur = self. _NewCursor() if not cur: return rt # 判斷sql是否允許其執(zhí)行 if not _PermitedUpdateSql(sql ): return rt # 執(zhí)行語句 rt = cur. execute(sql ) # 釋放cursor self ._DelCursor(cur) return rt# 類使用示例tns = '(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=10.16.17.46)(PORT=1521)))(CONNECT_DATA=(SERVICE_NAME=MYDB)))'ora = cxOracle ('nicker', '123456', tns)# 導(dǎo)出結(jié)果為文件rs = ora .Export("SELECT * FROM org", '1.txt')# 查詢結(jié)果到列表rs = ora.Query("SELECT * FROM org")print rs# 更新數(shù)據(jù)ora.Exec("update org set org_name='NewNameForUpdate' where org_id=123456;")希望本文所述對大家Python程序設(shè)計有所幫助。
新聞熱點
疑難解答
圖片精選
