unixODBC編程（七）數組查詢

介紹了怎樣使用數組通過ODBC查詢數據，如何設置語句句柄屬性以及綁定數組變量的方式，最后以一個實際可執行的程序代碼來演示操作過程。訪問www.tomcoding.com網站，學習Oracle內部數據結構，詳細文檔說明，下載Oracle的exp/imp，DUL，logminer，ASM工具的源代碼，學習高技術含量的內容。還有數據庫實時復制軟件下載。

訪問www.tomcoding.com網站，學習Oracle內部數據結構，詳細文檔說明，下載Oracle的exp/imp，DUL，logminer，ASM工具的源代碼，學習高技術含量的內容。

數組查詢與單條查詢編程的步驟差不多，只是在執行語句前要設置4個語句句柄屬性，在綁定輸出變量時使用變量數組，先看一看需要哪四個句柄屬性。

第一個屬性告訴語句使用列數組綁定，屬性名稱為SQL_ATTR_ROW_BIND_TYPE，屬性值為SQL_BIND_BY_COLUMN，例如：

SQLSetStmtAttr(stmth, SQL_ATTR_ROW_BIND_TYPE, SQL_BIND_BY_COLUMN, 0);

第二個屬性告訴語句綁定的數組大小，就是綁定的行數，屬性名稱為SQL_ATTR_ROW_ARRAY_SIZE，屬性值為10，例如：

SQLSetStmtAttr(stmth, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)10, 0);

第三個屬性告訴語句返回每一行的狀態，屬性名稱為SQL_ATTR_ROW_STATUS_PTR，屬性值為一個SQLUSMALLINT類型的數組，比如叫status[10]，例如：

SQLSetStmtAttr(stmth, SQL_ATTR_ROW_STATUS_PTR, (SQLPOINTER)status, 0);

第四個屬性告訴語句返回每次從結果集中取回的數據條數，屬性名稱為SQL_ATTR_ROWS_FETCHED_PTR，屬性值為一個SQLULEN類型的整數，不是數組，比如叫做num_fetched，例如：

SQLSetStmtAttr(stmth, SQL_ATTR_ROWS_FETCHED_PTR, (SQLPOINTER)&num_fetched, 0);

在使用SQLBindCol()函數綁定輸出變量時，TargetValuePtr參數使用數組綁定，StrLen_or_IndPtr參數也使用數組綁定，例如綁定一個整數數組id[10]，返回長度和指示變量數組len_id1[10]，調用函數如下：

SQLBindCol(stmth, 1, SQL_C_ULONG, (SQLPOINTER)id, 0, len_ind1);

下面看一個完整的例子，還是從前面創建的表test_tab1中查詢數據，使用數組操作。

#include "stdio.h"
#include "stdlib.h"
#include "string.h"
#include "sql.h"
#include "sqlext.h"
#include "sqltypes.h"


SQLHANDLE       envh;           /* env handle */
SQLHANDLE       dbch;           /* connect handle */
SQLHANDLE       stmth;          /* statement handle */

int main(int argc, char *argv[]){
    int                 i;
    int                 conn = 0;
    SQLRETURN           rc;
    SQLULEN             num_fetched;
    SQLUSMALLINT        status[10];
    SQLLEN              len_ind1[10];
    SQLLEN              len_ind2[10];
    SQLLEN              len_ind3[10];
    SQLLEN              len_ind4[10];
    SQLLEN              len_ind5[10];
    SQLINTEGER          id[10];
    char                dsn_str[32];
    char                usrname[32];
    char                passwd[32];
    char                sqltxt[128];
    char                f1[10][32];
    char                f2[10][32];
    char                f3[10][32];
    char                f4[10][32];


    if (argc < 3) {
        fprintf(stderr, "usage: %s dsn username password\n", argv[0]);
        return (-1);
    }

    strncpy(dsn_str, argv[1], 32);
    dsn_str[31] = '\0';
    strncpy(usrname, argv[2], 32);
    usrname[31] = '\0';
    strncpy(passwd, argv[3], 32);
    passwd[31] = '\0';

    rc = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &envh);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Allocate environment handle error.\n");
        return (-1);
    }

    rc = SQLSetEnvAttr(envh, SQL_ATTR_ODBC_VERSION, (void *)SQL_OV_ODBC3, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set ODBC version error.\n");
        goto free_exit;
    }

    rc = SQLAllocHandle(SQL_HANDLE_DBC, envh, &dbch);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Allocate DB connection handle error.\n");
        goto free_exit;
    }

    rc = SQLSetConnectAttr(dbch, SQL_ATTR_LOGIN_TIMEOUT, (SQLPOINTER)10, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set connection timeout value error.\n");
        goto free_exit;
    }

    rc = SQLConnect(dbch, (SQLCHAR *)dsn_str, SQL_NTS, (SQLCHAR *)usrname, SQL_NTS,
        (SQLCHAR *)passwd, SQL_NTS);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Connect to DB error.\n");
        goto free_exit;
    }

    conn = 1;
    fprintf(stdout, "connect DB ok ......\n");

    rc = SQLAllocHandle(SQL_HANDLE_STMT, dbch, &stmth);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Allocate statment handle error.\n");
        goto free_exit;
    }

    sprintf(sqltxt, "select id, f1, f2, f3, f4 from test_tab1");
    rc = SQLPrepare(stmth, (SQLCHAR *)sqltxt, SQL_NTS);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Prepare statment error.\n");
        goto free_exit;
    }

    /* 使用列數組綁定 */
    rc = SQLSetStmtAttr(stmth, SQL_ATTR_ROW_BIND_TYPE, SQL_BIND_BY_COLUMN, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set statment attribute error.\n");
        goto free_exit;
    }

    /* 設置數組大小為10，每次取回10條數據 */
    rc = SQLSetStmtAttr(stmth, SQL_ATTR_ROW_ARRAY_SIZE, (SQLPOINTER)10, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set statement attribute error.\n");
        goto free_exit;
    }


    /* 設置返回每條數據的狀態數組 */
    rc = SQLSetStmtAttr(stmth, SQL_ATTR_ROW_STATUS_PTR, (SQLPOINTER)status, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set statement attribute error.\n");
        goto free_exit;
    }

    /* 設置返回每次取回數據的條數 */
    rc = SQLSetStmtAttr(stmth, SQL_ATTR_ROWS_FETCHED_PTR, (SQLPOINTER)&num_fetched, 0);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Set statement attribute error.\n");
        goto free_exit;
    }

    /* 執行語句 */
    rc = SQLExecute(stmth);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Execute statment error.\n");
        goto free_exit;
    }

    /* 綁定第一列，id使用數組，len_ind1也使用數組 */
    rc = SQLBindCol(stmth, 1, SQL_C_ULONG, (SQLPOINTER)id, 0, len_ind1);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Bind column 1 error.\n");
        goto free_exit;
    }

    rc = SQLBindCol(stmth, 2, SQL_C_CHAR, (SQLPOINTER)f1, 32, len_ind2);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Bind column 2 error.\n");
        goto free_exit;
    }

    rc = SQLBindCol(stmth, 3, SQL_C_CHAR, (SQLPOINTER)f2, 32, len_ind3);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Bind column 3 error.\n");
        goto free_exit;
    }

    rc = SQLBindCol(stmth, 4, SQL_C_CHAR, (SQLPOINTER)f3, 32, len_ind4);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Bind column 4 error.\n");
        goto free_exit;
    }

    rc = SQLBindCol(stmth, 5, SQL_C_CHAR, (SQLPOINTER)f4, 32, len_ind5);
    if (rc != SQL_SUCCESS) {
        fprintf(stderr, "Bind column 5 error.\n");
        goto free_exit;
    }

    while (1) {
        rc = SQLFetch(stmth);

        if (rc == SQL_NO_DATA) {
            fprintf(stderr, "No data in result set, break.\n");
            break;
        } else if (rc == SQL_ERROR) {
            fprintf(stderr, "Fetch data error.\n");
            goto free_exit;
        }

        fprintf(stdout, "%lu rows fetched.\n", num_fetched);

        for (i=0; i<num_fetched; i++) {
            fprintf(stdout, "id=%d, f1=%s, f2=%s, f3=%s, f4=%s\n",
                id[i], f1[i], f2[i], f3[i], f4[i]);
        }
    }

    SQLFreeHandle(SQL_HANDLE_STMT, stmth);

    SQLDisconnect(dbch);

    SQLFreeHandle(SQL_HANDLE_DBC, dbch);

    SQLFreeHandle(SQL_HANDLE_ENV, envh);

    return (0);

free_exit:
    if (stmth != NULL) {
        SQLFreeHandle(SQL_HANDLE_STMT, stmth);
    }

    if (conn) {
        SQLDisconnect(dbch);
    }

    if (dbch != NULL) {
        SQLFreeHandle(SQL_HANDLE_DBC, dbch);
    }

    if (envh != NULL) {
        SQLFreeHandle(SQL_HANDLE_ENV, envh);
    }

    return (-1);
}

訪問www.tomcoding.com網站，可以下載Oracle內部數據結構的文檔，還有DUL，exp/imp，logminer及ASM工具的源代碼。

posted @ 2025-08-15 20:44 湯姆花花閱讀(7) 評論(0) 收藏舉報

刷新頁面返回頂部

湯姆花花

unixODBC編程（七）數組查詢

公告