mysql c语言实现事务

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

int main() {
    MYSQL *conn;
    MYSQL_RES *res;
    MYSQL_ROW row;

    const char *server = "localhost";
    const char *user = "root";
    const char *password = "password";
    const char *database = "testdb";

    conn = mysql_init(NULL);

    if (!mysql_real_connect(conn, server, user, password, database, 0, NULL, 0)) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        exit(1);
    }

    // 开始事务
    if (mysql_query(conn, "START TRANSACTION")) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        exit(1);
    }

    // 执行SQL语句
    if (mysql_query(conn, "INSERT INTO users(name, email) VALUES('John Doe', 'john@example.com')")) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        mysql_query(conn, "ROLLBACK"); // 回滚事务
        exit(1);
    }

    if (mysql_query(conn, "UPDATE accounts SET balance = balance - 100 WHERE user_id = 1")) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        mysql_query(conn, "ROLLBACK"); // 回滚事务
        exit(1);
    }

    // 提交事务
    if (mysql_query(conn, "COMMIT")) {
        fprintf(stderr, "%s\n", mysql_error(conn));
        mysql_query(conn, "ROLLBACK"); // 回回滚事务
        exit(1);
    }

    mysql_close(conn);
    printf("Transaction completed successfully.\n");

    return 0;
}