1 安裝與導入

Python操作Oracle數據庫多用cx_Oracle這個第三方擴展，總體而言，cx_Oracle的使用方式與Python操作MySQL數據庫的pymysql庫還是很相似的，如果還沒有安裝，可以通過下面的命令進行安裝：
$ pip install -i https://pypi.douban.com/simple cx_oracle
使用前導入：

import cx_Oracle

千萬注意，包名稱cx_Oracle中，字母“O”是大寫的，寫成小寫將會導入失敗。

2 創建連接

cx_Oracle提供了兩種方式連接Oracle數據庫，分別是創建獨立的單一連接以及創建連接池。

2.1 單一連接

創建單一連接主要是通過cx_Oracle模塊中提供的connect()方法實現，雖然也可以直接通過Connection()類實現，但是不推薦。connect()方法參數有很多，說說其中最常用的四個：

• user：用戶名
• password：密碼
• dsn：數據庫地址和服務名
• encoding：編碼，合適的編碼可以避免出現亂碼

這里要重點說一下dsn，dsn是data source name的縮寫，用于描述數據源的詳細地址，一般由數據庫所在主機地址、端口和服務名組成。在默認情況下，Oracle數據庫對應1521端口，在這種情況下，dsn中可以省略端口：

connection = cx_Oracle.connect("username", "password", "192.168.1.2/helowin", encoding="UTF-8")

其中，username是用戶名，password是密碼，192.168.1.2是數據庫所在主機IP，helowin是服務名。
在一般情況下，可以這么寫：

connection = cx_Oracle.connect("username", "password", "192.168.1.2:1521/helowin", encoding="UTF-8")

有時候，我們需要以管理員身份登錄數據庫，這時候，直接連接時不行的，將會跑出異常：DatabaseError: ORA-28009: connection as SYS should be as SYSDBA or SYSOPER，這時候可以傳遞參數mode=cx_Oracle.SYSDBA。

connection = cx_Oracle.connect("sys", "psdpassword", "192.168.1.2:1521/helowin",mode=cx_Oracle.SYSDBA,encoding="UTF-8")

當確定不在使用連接時，可以使用connection.close()關閉連接（這是個好習慣）。

connection.close()

2.2 連接池

cx_Oracle中提供SessionPool()創建連接池，連接池一般是在應用程序初始化時創建。相比通過connect()方法創建單個數據庫連接，使用SessionPool()創建連接池時，需要額外指定最少連接數（min)和最大連接數(max)，連接池創建時會創建有min個數據庫連接，當連接不夠用時會繼續新增連接，當連接未被使用時連接池將會自動減少連接的數量。

在創建好連接池后，通過調用acquire()方法可以獲取一個數據庫連接，連接使用完畢之后，最好使用SessionPool.release(connection)或Connection.close()將連接放回連接池。

# 創建連接池 pool = cx_Oracle.SessionPool("username", "password","192.168.1.2:1521/helowin", min=2, max=5, increment=1, encoding="UTF-8")# 從連接池中獲取一個連接 connection = pool.acquire()# 使用連接進行查詢 cursor = connection.cursor() for result in cursor.execute("select * from scott.students"):print(result)# 將連接放回連接池 pool.release(connection)# 關閉連接池 pool.close()

運行結果：

(1, '張三', 20) (2, '李四', 30)

如果是在多線程下同時使用連接，那么在創建連接池時應該傳遞一個threaded參數，并將值設置為True：

# 創建連接池 pool = cx_Oracle.SessionPool("username", "password","192.168.1.2:1521/helowin", min=2, max=5, increment=1, threaded=True, encoding="UTF-8")pool.close()

3 游標

有了數據庫連接之后，可以通過連接來獲取游標：

cur = connection.cursor()

通過游標，可以執行SQL語句，實現與數據庫的交互，但是記住，游標使用完之后記得關閉：

cur.close()

游標對象中定義有Cursor.excute()方法和Cursor.executemany()兩個方法用于執行SQL語句，前者一次只能執行一條SQL語句，后者一次可執行多條SQL。當有類似的大量SQL語句需要執行時，使用Cursor.executemany()而不是多次執行Cursor.excute()可以極大提升性能。
另外，所有cx_Oracle執行的語句都含有分號“;”或斜杠“/”：

connection = cx_Oracle.connect("username", "password", "192.168.1.2/helowin", encoding="UTF-8") cur = connection.cursor()cur.execute("select * from SCOTT.STUDENTS;") # 含有分號，拋出異常--------------------------------------------------------------------------- DatabaseError Traceback (most recent call last) <ipython-input-68-2181d3923cb0> in <module> ----> 1cur.execute("select * from SCOTT.STUDENTS;") # 含有分號，拋出異常DatabaseError: ORA-00911: invalid character

4 執行SQL

4.1 SQL語句拼接

（1）使用Python原生占位符拼接
在很多應用場景中，我們查詢所用的SQL語句并不是固定的，而是根據當時環境靈活的對SQL進行拼接。最簡單的方式就是直接使用Python原生提供的占位符進行拼接，不過要注意如果變量是字符串時，引號不能少。

cur.execute("insert into SCOTT.STUDENTS (id, name, age) values ({student_id}, '{student_name}', {student_age})".format(student_id=4,student_name='李六',student_age=15 )) connection.commit()student_id = 4 result = cur.execute("select * from SCOTT.STUDENTS where id={}".format(student_id))result.fetchone()

運行結果：

(4, '李六', 15) student_name = "張三" result = cur.execute("select * from SCOTT.STUDENTS where name='{}'".format(student_name))result.fetchone()

運行結果：

(1, '張三', 20)

(2)通過變量名拼接
使用這種拼接方式時，字符串中的名稱與真實變量名必須一一對應。
所有變量可以統一存儲在一個字典中：

student = {'student_id':5, 'student_name':'陳七', 'student_age': 25} # 將所有變量存儲到一個字典中 cur.execute('insert into SCOTT.STUDENTS (id, name, age) values (:student_id, :student_name, :student_age)',student) connection.commit()

也可以逐一賦值：

cur.execute('insert into SCOTT.STUDENTS (id, name, age) values (:student_id, :student_name, :student_age)',student_id=6,student_name='毛八',student_age=60) connection.commit()

(3)通過參數位置拼接
通過參數位置進行拼接時，所有變量可以統一存儲在一個list中，list中的變量的順序必須與字符串中定義的順序保持一致。

cur.execute('insert into SCOTT.STUDENTS (id, name, age) values (:student_id, :student_name, :student_age)',[7,'魏九',30]) connection.commit()

這時候，在字符串中也可以不顯式的出現參數名，而是以數字來代替出現位置：

cur.execute('insert into SCOTT.STUDENTS (id, name, age) values (:1, :2, :3)',[8,'吳十',90]) connection.commit()

4.2 執行語句

cx_Oracle的游標中定義了execute()和executemany()兩個方法用于執行SQL語句，區別在于execute()一次只能執行一條SQL，而executemany()一次能執行多條SQL。在大量結構一樣，參數不同的語句需要執行時，使用executemany()而不是多次調用execute()執行可以大大提高代碼性能。
（1）execute()
對于execute()方法，其實在上面代碼實例中以及多次使用，大致形式如下：

cur.execute('insert into SCOTT.STUDENTS (id, name, age) values (:1, :2, :3)',[9,'蕭十一',32]) connection.commit()

（2）executemany()

students = [[10,'蕭十一',32],[11,'何十二',40],[12,'穆十三',35] ] cur.executemany('insert into SCOTT.STUDENTS (id, name, age) values (:1, :2, :3)',students) connection.commit()

cx_Oracle執行SQL時需要注意，若是執行查詢，可通過游標獲取查詢結果，具體如何獲取請繼續看下文；若是執行insert或update操作，需要在執行后繼續一步connection.commit()操作。

5 獲取查詢結果

當使用游標進行查詢后，可以直接迭代取出查詢結果

''' 遇到問題沒人解答？小編創建了一個Python學習交流QQ群：778463939 尋找有志同道合的小伙伴，互幫互助,群里還有不錯的視頻學習教程和PDF電子書！ ''' result = cur.execute("select * from SCOTT.STUDENTS") for row in result:print(row)(1, '張三', 20) (2, '李四', 30) (3, '王五', 40)

注意，這里的游標查詢結果對象result雖然不是生成器，但是可以當做生成器來用，每一次使用next()方法時，可以獲取一條記錄。當然，也與生成器一樣，查詢結果只能迭代遍歷一次，再次使用迭代不會有任何輸出：

result = cur.execute("select * from SCOTT.STUDENTS") next(result) ----------------------------------------------------- (1, '張三', 20) ----------------------------------------------------- next(result) ----------------------------------------------------- (2, '李四', 30) ----------------------------------------------------- next(result) ----------------------------------------------------- (3, '王五', 40) ----------------------------------------------------- for row in result: # 沒有任何輸出結果print(row)

其實，通過循環來獲取查詢結果時，每一次調用next()方法，result對象都會對數據庫發起一次請求，獲取一條查詢記錄，如果查詢記錄數量比較大時，性能會比較低，這時候，可以通過設置cur.arraysize參數改善性能。cur.arraysize參數配置的是每次請求獲取的數據包大小，默認為100，當設置為更大值時，一次請求就可以獲取更多的記錄，減少客戶端與數據庫服務器端網絡往返次數，從而提高性能，當然缺點就是消耗的內存會更大。

''' 遇到問題沒人解答？小編創建了一個Python學習交流QQ群：778463939 尋找有志同道合的小伙伴，互幫互助,群里還有不錯的視頻學習教程和PDF電子書！ ''' cur.arraysize = 500 for row in cur.execute("select * from SCOTT.STUDENTS"):print(row) ----------------------------------------------------- (1, '張三', 20) (2, '李四', 30) (3, '王五', 40)

除了在循環中直接遍歷外，還可以通過fetchone()、fetchmany()、fetchall()三個方法取出查詢結果。

fetchone()

fetchone()每次只取出一條記錄，功能效果與直接對result使用next()方法一樣。

cur = connection.cursor() result = cur.execute("select * from SCOTT.STUDENTS") ----------------------------------------------------- result.fetchone() ----------------------------------------------------- (1, '張三', 20) ----------------------------------------------------- result.fetchone() ----------------------------------------------------- (2, '李四', 30) ----------------------------------------------------- result.fetchone() ----------------------------------------------------- (3, '王五', 40)

fetchmany()

fetchmany()可以一次取出指定數量的記錄，如果不指定數量，表示一次性去除所有記錄。

cur = connection.cursor() result = cur.execute("select * from SCOTT.STUDENTS") ----------------------------------------------------- result.fetchmany(2) ----------------------------------------------------- [(1, '張三', 20), (2, '李四', 30)] ----------------------------------------------------- result.fetchmany(2) ----------------------------------------------------- [(3, '王五', 40)] ----------------------------------------------------- result.fetchmany(2) # 若所有記錄都取出來了，返回空列表 ----------------------------------------------------- []

fetchall()

fetchall()一次性去除所有結果。

cur = connection.cursor() result = cur.execute("select * from SCOTT.STUDENTS") ----------------------------------------------------- result.fetchall() ----------------------------------------------------- [(1, '張三', 20), (2, '李四', 30), (3, '王五', 40)]

總結

以上是生活随笔為你收集整理的Python操作Oracle数据库：cx_Oracle的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。