Oracle Pro*C/C++ 多線程數據導出程序實戰：上下文隔離與游標預取優化

編輯：關於C語言

Oracle Pro*C 多線程編程的核心挑戰在於運行時上下文隔離與共享連接池管理。本文解析一個生產級多線程導出程序，重點講解 sql_context、THREADS 模式、游標預取優化。

核心架構設計

struct paramater {
    sql_context stx;      // 線程專屬 SQL 上下文
    char table[17];
    char fileName[17];
};

每線程獨立 sql_context 實現連接級隔離，避免共享 sqlca 衝突。

關鍵技術點深度解析

1. 多線程模式啟用與上下文管理

EXEC SQL ENABLE THREADS;           // 必須在首次 CONTEXT ALLOCATE 前調用
EXEC SQL CONTEXT ALLOCATE :ctx[i]; // 分配線程上下文
// ... 使用 ctx[i] ...
EXEC SQL CONTEXT FREE :ctx[i];     // 釋放

ENABLE THREADS 告訴預編譯器生成線程安全代碼
每線程一個 sql_context，內含連接、游標、sqlca 狀態

2. 上下文切換宏：EXEC SQL CONTEXT USE

EXEC SQL CONTEXT USE :ctx;  // 後續 SQL 語句綁定此上下文
EXEC SQL CONNECT ...;
EXEC SQL DECLARE cur CURSOR ...;

編譯器將展開為運行時上下文切換調用，確保多線程安全。

3. 游標預取優化：PREFETCH 選項

EXEC ORACLE OPTION (PREFETCH=65535);  // 開啟大額預取
EXEC SQL OPEN cur;
for (;;) {
    EXEC SQL FOR :this_count FETCH cur INTO :str;
    // 批量處理...
}
EXEC ORACLE OPTION (PREFETCH=1);      // 恢復默認

網絡往返從「每行一次」降為「每 65535 行一次」
大幅減少客戶端-服務端交互延遲
需配合 FOR :n FETCH 數組接收

4. 數組 FETCH 與 sqlca.sqlerrd[2] 行計數

EXEC SQL FOR :this_count FETCH cur INTO :str;
this_count = sqlca.sqlerrd[2] - row_begin;
row_begin = sqlca.sqlerrd[2];

sqlca.sqlerrd[2] 累積已提取行數
差值即本次實際獲取行數
配合 FOR 子句實現高吞吐批量提取

5. 錯誤處理與資源清理

EXEC SQL WHENEVER SQLERROR CONTINUE;  // 避免錯誤觸發長跳轉
// ... 操作 ...
if (sqlca.sqlcode != 0) { /* 記錄錯誤 */ }
EXEC SQL CLOSE cur;
EXEC SQL COMMIT WORK RELEASE;
EXEC SQL CONTEXT FREE :ctx;

完整主流程

int main() {
    sql_context ctx[2];
    struct paramater pa[2];
    pthread_t pt[2];

    for (int i = 0; i < 2; i++) {
        EXEC SQL ENABLE THREADS;
        EXEC SQL CONTEXT ALLOCATE :ctx[i];
        connectDB("bill", "bill", "hntestbl", ctx[i]);
        
        sprintf(pa[i].table, "T_CI_USERINFO_B");
        sprintf(pa[i].fileName, "ttttt%d", i+1);
        pa[i].stx = ctx[i];
        
        pthread_create(&pt[i], NULL, exportTable, &pa[i]);
    }

    for (int j = 0; j < 2; j++) {
        pthread_join(pt[j], NULL);
        closeDB(ctx[j]);
        EXEC SQL CONTEXT FREE :ctx[j];
    }
    return 0;
}