MySQL 在 C/C++ 中的使用

说明：成功返回 0，失败返回非 0。适合执行 SELECT、INSERT、UPDATE 等常规语句。

(2) mysql_real_query()

功能：执行 SQL 语句（支持包含二进制数据的语句）。

int mysql_real_query(MYSQL *mysql, const char *stmt_str, unsigned long length);

说明：与 mysql_query() 类似，但需显式指定语句长度，适合处理含特殊字符的 SQL。

3. 处理查询结果函数

(1) mysql_store_result()

功能：获取 SELECT 等查询的全部结果集（一次性加载到内存）。

MYSQL_RES *mysql_store_result(MYSQL *mysql);

说明：成功返回结果集句柄，失败返回 NULL，需用 mysql_free_result() 释放。

(2) mysql_use_result()

功能：获取查询结果集（逐行读取，内存占用低）。

MYSQL_RES *mysql_use_result(MYSQL *mysql);

说明：适合处理大量数据，但需在读取完所有行后才能执行其他语句。

4. 错误处理函数

(1) mysql_error()

功能：返回最近一次操作的错误信息。

const char *mysql_error(MYSQL *mysql);

(2) mysql_errno()

功能：返回最近一次操作的错误代码。

unsigned int mysql_errno(MYSQL *mysql);

5. 行数据处理函数

功能：获取结果集的字段数（列数）/ 行数。

unsigned int mysql_num_fields(MYSQL_RES *result); // 列数
my_ulonglong mysql_num_rows(MYSQL_RES *result);   // 行数

(1) mysql_fetch_row()

功能：从结果集（MYSQL_RES*）中获取一行数据。

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

说明：

• 返回值是 MYSQL_ROW 类型（本质是 char**，字符串数组），每个元素对应一列数据
• 当无更多行或出错时返回 NULL
• 数据以字符串形式存储（即使是数字类型，也需手动转换）

示例：

MYSQL_RES *res = mysql_store_result(mysql);
if(res == nullptr) {
    std::cerr << "mysql_store_result error" << std::endl;
    return 4;
}
int rows = mysql_num_rows(res);
int fields = mysql_num_fields(res);
std::cout << "行：" << rows << std::endl;
std::cout << "列：" << fields << std::endl;
MYSQL_FIELD *fields_array = mysql_fetch_fields(res);
for(int i = 0; i < rows; i++) {
    MYSQL_ROW row = mysql_fetch_row(res);
    for(int j = 0; j < fields; j++) {
        std::cout << row[j] << "\t";
    }
    std::cout << "\n";
}

虽然外层循环的变量 i 没有直接参与 mysql_fetch_row(res) 的调用，但循环本身起到了控制读取次数的作用，而 mysql_fetch_row 函数内部会维护一个'当前行指针'，每次调用都会自动移动到下一行，这就是为什么能按行读取结果的核心原因。

(2) mysql_fetch_lengths()

功能：获取当前行中各字段的实际长度（字节数）。

unsigned long *mysql_fetch_lengths(MYSQL_RES *result);

说明：

• 需在 mysql_fetch_row() 之后调用，获取当前行的字段长度数组
• 用于处理二进制数据或包含 \0 的字符串（避免被截断）

示例：

MYSQL_ROW row = mysql_fetch_row(result);
unsigned long *lengths = mysql_fetch_lengths(result);
for (int i = 0; i < cols; i++) {
    // 安全处理字段数据（按实际长度读取）
    printf("字段 %d: %.*s\n", i, lengths[i], row[i]);
}

6. 字段（列）信息处理函数

(1) mysql_fetch_field()

功能：逐个获取结果集中的字段（列）元信息。

MYSQL_FIELD *mysql_fetch_field(MYSQL_RES *result);

说明：返回 MYSQL_FIELD 结构体指针，包含字段名、类型、长度等信息。多次调用可遍历所有字段，结束时返回 NULL。

示例：

MYSQL_FIELD *field;
while ((field = mysql_fetch_field(result))) {
    printf("字段名：%s, 类型：%d, 长度：%lu\n",
           field->name, field->type, field->length);
}

(2) mysql_fetch_fields()

功能：一次性获取所有字段的元信息数组。

MYSQL_FIELD *mysql_fetch_fields(MYSQL_RES *result);

说明：返回字段信息数组的首地址，数组长度为 mysql_num_fields(result)。适合批量获取字段信息，无需循环调用 mysql_fetch_field()。

结构体定义：

typedef struct st_mysql_field {
    char *name;             // 字段名称（列名）
    char *org_name;         // 原始字段名（未被别名替换的名称）
    char *table;            // 字段所属的表名
    char *org_table;        // 原始表名（未被别名替换的表名）
    char *db;               // 字段所属的数据库名
    char *catalog;          // 目录名（通常为 "def"）
    char *def;              // 字段的默认值（字符串形式）
    unsigned long length;   // 字段的显示长度（字节数）
    unsigned long max_length;// 结果集中该字段的最大实际长度
    unsigned int name_length;       // 字段名的长度
    unsigned int org_name_length;   // 原始字段名的长度
    unsigned int table_length;      // 表名的长度
    unsigned int org_table_length;  // 原始表名的长度
    unsigned int db_length;         // 数据库名的长度
    unsigned int catalog_length;    // 目录名的长度
    unsigned int def_length;        // 默认值的长度
    unsigned int flags;             // 字段的标志
    unsigned int decimals;          // 小数位数
    unsigned int charsetnr;         // 字符集编号
    enum enum_field_types type;     // 字段的数据类型
    void *extension;                // 扩展信息
} MYSQL_FIELD;

示例：

int cols = mysql_num_fields(result);
MYSQL_FIELD *fields = mysql_fetch_fields(result);
for (int i = 0; i < cols; i++) {
    printf("字段 %d: %s\n", i, fields[i].name);
}

7. 结果集定位与遍历函数

(1) mysql_data_seek()

功能：在结果集中定位到指定行（随机访问）。

void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);

说明：仅对 mysql_store_result() 获取的结果集有效（全量加载到内存）。offset 为行索引（从 0 开始），需小于 mysql_num_rows(result)。

示例：定位到第 5 行（索引 4）

mysql_data_seek(result, 4);
MYSQL_ROW row = mysql_fetch_row(result); // 获取第 5 行数据

(2) mysql_row_seek()

功能：通过行偏移量（MYSQL_ROW_OFFSET）定位行。

MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset);

说明：比 mysql_data_seek() 更底层，偏移量通过 mysql_row_tell() 获取。适用于需要保存 / 恢复行位置的场景。

(3) mysql_row_tell()

功能：获取当前行在结果集中的偏移量。

MYSQL_ROW_OFFSET mysql_row_tell(MYSQL_RES *result);

说明：返回当前行的 MYSQL_ROW_OFFSET 类型偏移量，可用于 mysql_row_seek()。

8. 其他实用函数

(1) mysql_affected_rows()

功能：获取上一条 INSERT/UPDATE/DELETE 语句影响的行数。

my_ulonglong mysql_affected_rows(MYSQL *mysql);

说明：对于 INSERT，返回插入的行数；对于 UPDATE/DELETE，返回受影响的行数。失败时返回 (my_ulonglong)-1。

(2) mysql_insert_id()

功能：获取上一条 INSERT 语句生成的自增 ID（如主键 AUTO_INCREMENT）。

my_ulonglong mysql_insert_id(MYSQL *mysql);

说明：仅对包含自增字段的表有效，且需在 INSERT 执行后立即调用。

这些函数主要用于精细化处理查询结果，包括行数据读取、字段元信息获取、结果集定位等，配合之前提到的核心函数可以完成复杂的数据库操作。