mysql api---從一個小例子開始mysql程式設計入門（6）

先了解幾個概念：

MYSQL預設是自動送出的，也就是你送出一個QUERY，它就直接執行！我們可以通過

set autocommit=0 禁止自動送出

set autocommit=1 開啟自動送出

mysql中INNODB引擎才支援事務處理，預設是自動送出的；

另外一種常用的MYISAM引擎是不支援事務的，本身就沒有事務的概念

從代碼中來看：

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <dlfcn.h>

#include <mysql/mysql.h>

#include <unistd.h>

#include <errno.h>

//oracle的事務:事務起始标志 DML語言 (oracle預設事務似是打開的)

//MYSQL預設是自動送出的 (每執行一個sql語言都給你自動送出)

#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;
           

}

// drop table test_table

// 建表 create table test_table(col1 int, col2 varchar(10), col3 varchar(10));

#define sql01 "INSERT INTO test_table(col1,col2,col3) VALUES(10, '10', '1')"

#define sql02 "INSERT INTO test_table(col1,col2,col3) VALUES(20, '20', '2')"

#define sql03 "INSERT INTO test_table(col1,col2,col3) VALUES(30, '30', '3')"

#define sql04 "INSERT INTO test_table(col1,col2,col3) VALUES(40, '40', '4')"

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);
           

}

結果顯然sql1 sql2 commit 生效

sql3 sql4 rollback復原無效

轉載于:https://blog.51cto.com/13375232/2056818