Python連接oracle的問題怎麼解決-Python教學-PHP中文網

Python連接oracle的問題怎麼解決

王林

發布： 2023-04-25 10:07:06

轉載

2268 人瀏覽過

技術框架

開發語言：Python，資料庫：oracle，第三方函式庫：cx_Oracle（用於python和oracle的連接），prettytable（用於表格化輸出展示資料）

開發步驟

一、安裝cx_Oracle

pip install cx_Oracle

登入後複製

二、寫資料庫操作類別

直接使用了chatgpt提供的程式碼，因為我只用到了查詢方法，所以只查沒有增刪改，另外考慮到要同時查詢多次數據，所以自己修改了實現了一個連接池的功能。

import cx_Oracle
import queue

class OracleDatabase:
    # 构造函数，传入数据库连接参数
    def __init__(self, user, pwd, dsn, size):
        self.user = user
        self.pwd = pwd
        self.dsn = dsn
        ## 定义连接池
        self.size = size
        self.conn_queue = queue.Queue(maxsize=self.size)
        for i in range(self.size):
            self.conn_queue.put(self._create_connection())

    # 创建数据库连接
    def _create_connection(self):
        return cx_Oracle.connect(self.user, self.pwd, self.dsn)
  
    # 从连接池里面获取连接
    def _get_conn(self):
        conn = self.conn_queue.get()
        if conn is None:
            self._create_connection()
        return conn

    # 将连接put到连接池中
    def _put_conn(self, conn):
        self.conn_queue.put(conn)

    # 关闭所有连接
    def _close_conn(self):
        try:
            while True:
                conn = self.conn_queue.get_nowait()
                if conn:
                    conn.close()
        except queue.Empty:
            print(">>>>数据库连接全部关闭<<<<")
            pass 

    # 执行查询语句
    def query(self, sql, params=None):
        res = []
        conn = self._get_conn()
        cursor = conn.cursor()
        try:
            if params:
                cursor.execute(sql, params)
            else:
                cursor.execute(sql)
            rows = cursor.fetchall()
            for row in rows:
                res.append(row)
        except Exception as e:
            print(str(e))
        finally:
            cursor.close()
            self._put_conn(conn)
        return res

登入後複製

三、輸入訂單號，執行查詢

if __name__ == &#39;__main__&#39;:
    user = "user_dba"
    pwd = "user_password"
    dsn = cx_Oracle.makedsn(&#39;0.0.0.0&#39;, &#39;1521&#39;, service_name=&#39;s_demo_db&#39;)
    db = OracleDatabase(user, pwd, dsn, 2)
    cl_code = input("输入订单号: ").strip()
    
    print("数据信息展示:")
    sql_1 = """select *
		  from table_demo c
		  where c.cl_code = :cl_code"""

    results_1 = db.query(sql_1, [cl_code])
	print(results_1)
	# ......

登入後複製

四、格式化列印

安裝prettytable

pip install PrettyTable

登入後複製

#範例程式碼

from prettytable import PrettyTable

## 接着第三部分的代码
tb_1 = PrettyTable([&#39;**号&#39;, &#39;**时间&#39;, &#39;当前状态&#39;, &#39;单号&#39;, &#39;机构&#39;])
for rs_1 in results_1:
	tb_1.add_row([rs_1[0], rs_1[1], rs_1[2], rs_1[3], rs_1[4]])
print(tb_1)

登入後複製

五、列印效果

使用效果如下：貼上訂單號碼回車，直接傳回下面所需的資訊資料(測試資料)：

Python連接oracle的問題怎麼解決

問題記錄

第一個問題就是安裝cx_Oracle的時候出錯：

ERROR: Could not build wheels for cx_Oracle, which is required to install pyproject.toml-based projects

解決方式：安裝Microsoft C 產生工具，Microsoft C 產生工具- Visual Studio,變更安裝目錄，依照預設選項安裝即可。

錯誤訊息

cx_Oracle.DatabaseError: DPI-1047: Cannot locate a 64-bit Oracle Client library:"The specified module could not be found".See https:// cx-oracle.readthedocs.io/en/latest/user_guide/installation.html for help

解決方式：複製oracle客戶端(客戶端下載請參閱問題3)目錄中的oci，oraocci11， oraociei11的3個DLL貼到你的Paython目錄的Lib/site-packages資料夾下面。

錯誤訊息