首頁  >  文章  >  後端開發  >  Python連接oracle的問題怎麼解決

Python連接oracle的問題怎麼解決

王林
王林轉載
2023-04-25 10:07:062116瀏覽

    技術框架

    開發語言: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資料夾下面。

    錯誤訊息

    cx_Oracle.DatabaseError: DPI-1072: the Oracle Client library version is unsupported

    下載oracle客戶端,並解壓縮安裝。下載地址:oracle.github.io/odpi/doc/installation 我出現這個問題,是因為我本機原來安裝的是19.18版本,換成11.2版本的客戶端,按照問題2的操作,將三個dll文件重新複製過去,解決問題。

    Python連接oracle的問題怎麼解決

    後期最佳化

    • 將sql語句集中放到設定檔裡面,並且配置表頭,可以實現多查詢自由擴展。

    • 透過bat腳本呼叫執行,真正實作一鍵查詢。

    #

    以上是Python連接oracle的問題怎麼解決的詳細內容。更多資訊請關注PHP中文網其他相關文章!

    陳述:
    本文轉載於:yisu.com。如有侵權,請聯絡admin@php.cn刪除