MySQL 多語句執行機制詳解：CLIENT_MULTI_STATEMENTS 與結果集處理

MySQL 多語句執行：C API 實現與結果集處理全解析

MySQL C API 支援單次調用執行多條 SQL 語句（以分號分隔），需顯式啟用 CLIENT_MULTI_STATEMENTS。本文詳細說明啟用方式、結果集讀取循環、常見錯誤與最佳實踐。

一、啟用多語句支持

// 方式 1：連接時指定
MYSQL *mysql = mysql_init(NULL);
mysql_real_connect(mysql, host, user, pass, db, port, NULL, CLIENT_MULTI_STATEMENTS);

// 方式 2：運行時開啟
mysql_set_server_option(mysql, MYSQL_OPTION_MULTI_STATEMENTS_ON);

二、執行多語句

const char *multi_sql =
    "INSERT INTO t1 VALUES (1);"
    "UPDATE t2 SET c=10 WHERE id=2;"
    "SELECT * FROM t3 LIMIT 5;";

if (mysql_query(mysql, multi_sql) != 0) {
    fprintf(stderr, "Error: %s\n", mysql_error(mysql));
}

三、結果集處理標準循環（官方推薦）

do {
    // 1. 獲取結果集（SELECT/SHOW/EXPLAIN 等返回結果集；INSERT/UPDATE 返回 NULL）
    MYSQL_RES *result = mysql_store_result(mysql);

    // 2. 處理結果集
    if (result) {
        // 有結果集：逐行讀取
        MYSQL_ROW row;
        while ((row = mysql_fetch_row(result))) {
            // 處理 row...
        }
        mysql_free_result(result);
    } else {
        // 無結果集：檢查是否為錯誤
        if (mysql_field_count(mysql) == 0) {
            // 正常的 INSERT/UPDATE/DELETE
            printf("Affected rows: %lld\n", mysql_affected_rows(mysql));
        } else {
            // 錯誤：如語法錯誤導致無結果集
            fprintf(stderr, "Error: %s\n", mysql_error(mysql));
            break;
        }
    }

    // 3. 移動到下一個結果集
    int status = mysql_next_result(mysql);
    if (status > 0) {
        fprintf(stderr, "Error: %s\n", mysql_error(mysql));
        break;
    }
} while (status == 0);

四、最小化處理模板（僅執行無結果語句）

do {
    MYSQL_RES *result = mysql_store_result(mysql);
    mysql_free_result(result);  // 釋放空結果集
} while (mysql_next_result(mysql) == 0);

五、常見錯誤與對策

六、應用層最佳實踐

1. 優先使用單條語句 + 事務：多語句調試困難、錯誤定位難、注入風險高。
2. 批量操作用預處理批次執行：PreparedStatement.addBatch() (Java) / executemany() (Python)。
3. 必須用多語句時：嚴格驗證輸入、限制語句數量、捕獲異常並完整讀取結果集。
4. 連接池配置：確保連接屬性 CLIENT_MULTI_STATEMENTS 在池創建時設置，避免借用連接時動態切換導致狀態不一致。