MySQL 시작을 위한 트랜잭션 개념

MYSQL은 기본적으로 자동으로 제출됩니다. 즉, QUERY를 제출하면 바로 실행됩니다! 자동 제출을 활성화하려면
set autocommit=0
set autocommit=1을 사용하여 자동 제출을 비활성화할 수 있습니다.
mysql의 INNODB 엔진만 트랜잭션 처리를 지원하며 기본값은 자동 제출입니다.
일반적으로 사용되는 또 다른 방법입니다. MYISAM 엔진은 트랜잭션을 지원하지 않으며 트랜잭션 개념도 없습니다.

오라클 트랜잭션의 개념과 비교할 수 있습니다! ! !

MySQL의 자동 제출을 피하고 API를 직접 캡슐화하여 롤백 및 기타 작업을 구현할 수 있습니다! ! !

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dlfcn.h>
#include <mysql/mysql.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <termios.h>
#include <mysql/mysql.h>
/*
MySQL set autocommit = 0或1分别什么啊,哪个是自动提交啊
要熟练使用mysql的帮助文档，在里面查找autocommit，就会有相应的注释，比我在这里直接给你说要深刻得多。
autocoomit是事务，根据mysql的文档如果等于1是立即提交。但在transction中只有遇到commit或rollback才提交。希望对你有用。
*/
/*
MYSQL默认是自动提交的，也就是你提交一个QUERY，它就直接执行！我们可以通过
     set autocommit=0  禁止自动提交
     set autocommit=1 开启自动提交 
mysql中INNODB引擎才支持事务处理，默认是自动提交的；
另外一种常用的MYISAM引擎是不支持事务的，本身就没有事务的概念 
*/
#define BEGIN_TRAN      "START TRANSACTION"
#define SET_TRAN            "SET AUTOCOMMIT=0"  
#define UNSET_TRAN      "SET AUTOCOMMIT=1"
#define COMMIT_TRAN     "COMMIT"
#define ROLLBACK_TRAN   "ROLLBACK"
int mysql_BeginTran(MYSQL *mysql)
{
    int ret = 0;
    //--执行事务开始SQL
    ret = mysql_query(mysql, BEGIN_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    //--设置事务手动提交
    ret = mysql_query(mysql, SET_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    return ret;
}
int mysql_Rollback(MYSQL *mysql)
{
    int ret = 0;
    //--事务回滚操作
    ret = mysql_query(mysql, ROLLBACK_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    //--恢复事务自动提交标志
    ret = mysql_query(mysql, UNSET_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    return ret;
}
int mysql_Commit(MYSQL *mysql)
{
    int ret = 0;
    //--执行事务提交SQL
    ret = mysql_query(mysql, COMMIT_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    //--恢复自动提交设置
    ret = mysql_query(mysql, UNSET_TRAN);
    if (ret != 0)
    {
        printf("func mysql_query() err: %d\n", ret);
        return ret;
    }
    return ret;
}
// 建表 create table test_table(col1 int, col2 varchar(10), col3 varchar(10)); 
#define sql01 "INSERT INTO test_table(col1,col2,col3) VALUES(10, &#39;10&#39;, &#39;1&#39;)"
#define sql02 "INSERT INTO test_table(col1,col2,col3) VALUES(20, &#39;20&#39;, &#39;2&#39;)"
#define sql03 "INSERT INTO test_table(col1,col2,col3) VALUES(30, &#39;30&#39;, &#39;3&#39;)"
#define sql04 "INSERT INTO test_table(col1,col2,col3) VALUES(40, &#39;40&#39;, &#39;4&#39;)"
int main()
{
    int         ret = NULL;
    MYSQL       *mysql;
    MYSQL_RES   *res;
    MYSQL_ROW   row;
    char        *query;
    mysql = mysql_init(NULL);
    mysql =mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, 0 );
    if (mysql == NULL)
    {
        ret = mysql_errno(mysql);
        printf("func mysql_real_connect() err\n");
        return ret;
    }
    else
    {
        printf(" ok......\n");
    }
    ret = mysql_BeginTran(mysql);
    if (ret != 0)
    {
        printf("mysql_BeginTran() err:%d\n", ret);
        return ret;
    }
    ret = mysql_query(mysql, sql01);
    if (ret != 0)
    {
        printf("mysql_query() err:%d\n", ret);
        return ret;
    }
    ret = mysql_query(mysql, sql02);
    if (ret != 0)
    {
        printf("mysql_query() err:%d\n", ret);
        return ret;
    }
    ret = mysql_Commit(mysql);
    if (ret != 0)
    {
        printf("mysql_Commit() err:%d\n", ret);
        return ret;
    }
    ret = mysql_BeginTran(mysql);
    if (ret != 0)
    {
        printf("mysql_BeginTran() err:%d\n", ret);
        return ret;
    }
    ret = mysql_query(mysql, sql03);
    if (ret != 0)
    {
        printf("mysql_query() err:%d\n", ret);
        return ret;
    }
    ret = mysql_query(mysql, sql04);
    if (ret != 0)
    {
        printf("mysql_query() err:%d\n", ret);
        return ret;
    }
    ret = mysql_Rollback(mysql);
    if (ret != 0)
    {
        printf("mysql_Rollback() err:%d\n", ret);
        return ret;
    }
    mysql_close(mysql);
}

위는 MySQL 입문을 위한 트랜잭션 개념 내용입니다. 더 많은 관련 내용은 PHP 중국어 홈페이지(www.php.cn)를 참고해주세요!