本文實例講述了Python操作Oracle數據庫的簡單方法和封裝類。分享給大家供大家參考，具體如下：
最近工作有接觸到Oracle，發現很多地方用Python腳本去做的話，應該會方便很多，所以就想先學習下Python操作Oracle的基本方法。
考慮到Oracle的使用還有一個OracleClient的NetConfig的存在，我覺得連接起來就應該不是個簡單的事情。
果然，網上找了幾個連接方法，然后依葫蘆卻畫了半天，卻也不得一個瓢。
方法1：用戶名，密碼和監聽分別作為參數
|
1
|
conn=cx_Oracle.connect('用戶名','密碼','數據庫地址:數據庫端口/SID') |
根據我看的幾篇文章和我寫代碼出錯的提示，我找到了python連接數據庫的配置項應該和Oracle客戶端的配置文件tnsnames.ora有關。但是我的配置項并沒有SID項，而且一開始我也不知SID是個什么東西，網上寫什么我就跟著寫，所以這種方法失敗了。后來想通了要在配置項加一個SID，然后想想這個東西配置完了我系統是不是要重啟啊。所以，先看看其他方法吧….
方法2：用戶名，密碼和監聽共同作為一個參數
|
1
|
conn=cx_Oracle.connect('用戶名/密碼@數據庫地址:數據庫端口/SID') |
這個方法基本和方法一一樣，換湯不換藥…
方法3：使用tns配置信息
|
1
|
conn=cx_Oracle.connect('用戶名','密碼',tns) |
網上的代碼獲取tns是用函數做的，依然會使用SID，但是..我已經可以用的配置項并沒有SID啊，所以使用
|
1
|
tns=cx_Oracle.makedsn('數據庫地址','數據庫端口', 'SID') |
依舊不行，但是看看這個tns的生成方法和上面的兩種方法差不多的。但是我發現我隨便輸入一個SID后生成的數據是這樣的。
(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試試。
|
1
2
|
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) |
嗯。成功了~
最后，貼一個基本使用方法全代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
#coding:utf-8import cx_Oracle# 創建數據庫連接# cx_Oracle.connect('username','pwd','ora的tns信息')# oracle數據庫的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)# 操作游標cursor = conn.cursor()# 執行查詢cursor.execute("SELECT * FROM inst_info")# 獲取返回信息rs = cursor.fetchall()# 輸出信息for v in rs: print v#關閉連接，釋放資源cursor.close()conn.close() |
觀察發現總結很重要，理解也需要
貼上一個自己封裝Oracle的類
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
#coding:utf-8import cx_Oracle# 封裝的類class cxOracle: ''' tns的取值tnsnames.ora對應的配置項的值，如： 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() # 檢查是否允許執行的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不予執行 elif sql_elems[0] in [ 'update', 'delete']: if 'where' not in sql_elems : rt = False return rt # 導出結果為文件 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是否允許其執行 if not _PermitedUpdateSql(sql ): return rt # 執行語句 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)# 導出結果為文件rs = ora .Export("SELECT * FROM org", '1.txt')# 查詢結果到列表rs = ora.Query("SELECT * FROM org")print rs# 更新數據ora.Exec("update org set org_name='NewNameForUpdate' where org_id=123456;") |
希望本文所述對大家Python程序設計有所幫助。
原文鏈接：https://blog.csdn.net/arbboter/article/details/52953692
