C语言连接MySQL数据库的完整流程

#include <stdio.h>
#include <mysql.h>  // 必须包含 MySQL 核心头文件

int main() {
    // 获取客户端库版本
    const char* version = mysql_get_client_info();
    printf("MySQL Client Version: %s\n", version);
    return 0;
}

gcc -o test test.c -I./include -L./lib -lmysqlclient

export LD_LIBRARY_PATH=./lib
./test

MYSQL* mysql_init(MYSQL* mysql);

MYSQL* mysql = mysql_init(NULL);
if (mysql == NULL) {
    printf("初始化失败\n");
    return 1;
}

MYSQL* mysql_real_connect(
    MYSQL* mysql,
    const char* host,      // 主机：localhost / 127.0.0.1
    const char* user,      // 用户名：root
    const char* passwd,    // 密码
    const char* db,        // 要连接的数据库名
    unsigned int port,     // 端口：3306
    const char* unix_socket,// NULL
    unsigned long clientflag// 0
);

mysql_set_character_set(mysql, "utf8");

int mysql_query(MYSQL* mysql, const char* sql);

MYSQL_RES* result = mysql_store_result(mysql);
// ... 使用结果
mysql_free_result(result);

mysql_close(mysql);

#define _CRT_SECURE_NO_WARNINGS
#include <stdio.h>
#include <mysql.h>

int main() {
    // 1. 初始化
    MYSQL* mysql = mysql_init(NULL);
    if (mysql == NULL) {
        printf("mysql_init 失败\n");
        return 1;
    }

    // 2. 连接数据库（请修改为你的信息）
    const char* host = "localhost";
    const char* user = "root";
    const char* passwd = "123456";
    const char* db = "test";
    unsigned int port = 3306;

    if (mysql_real_connect(mysql, host, user, passwd, db, port, NULL, 0) == NULL) {
        printf("连接失败: %s\n", mysql_error(mysql));
        mysql_close(mysql);
        return 1;
    }
    printf("数据库连接成功 ✅\n");
    mysql_set_character_set(mysql, "utf8");

    // 3. 执行查询 SQL
    const char* sql = "SELECT id, name, age FROM student;";
    if (mysql_query(mysql, sql) != 0) {
        printf("查询失败: %s\n", mysql_error(mysql));
        mysql_close(mysql);
        return 1;
    }

    // 4. 获取结果
    MYSQL_RES* res = mysql_store_result(mysql);
    if (res == NULL) {
        printf("无结果或执行失败\n");
        mysql_close(mysql);
        return 1;
    }

    // 列数、列名
    int fields = mysql_num_fields(res);
    MYSQL_FIELD* field = mysql_fetch_fields(res);
    for (int i = 0; i < fields; i++) {
        printf("%s\t", field[i].name);
    }
    printf("\n----------------------------------------\n");

    // 逐行打印
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        for (int i = 0; i < fields; i++) {
            printf("%s\t", row[i] ? row[i] : "NULL");
        }
        printf("\n");
    }

    // 5. 释放资源 + 关闭
    mysql_free_result(res);
    mysql_close(mysql);
    printf("\n操作完成 ✅\n");
    return 0;
}

gcc -o mysql_demo mysql_demo.c -I./include -L./lib -lmysqlclient
export LD_LIBRARY_PATH=./lib
./mysql_demo

mysql_set_character_set(mysql, "utf8");

export LD_LIBRARY_PATH=./lib

mysql_autocommit(mysql, 0);  // 关闭自动提交
// 执行多条 SQL...
mysql_commit(mysql);         // 提交
// 出错则回滚
mysql_rollback(mysql);