mysql api---从一个小例子开始mysql编程入门（6）

jsnjzlw

　　先了解几个概念：
　　MYSQL默认是自动提交的，也就是你提交一个QUERY，它就直接执行！我们可以通过
　　set autocommit=0  禁止自动提交
　　set autocommit=1 开启自动提交
　　mysql中INNODB引擎才支持事务处理，默认是自动提交的；
　　另外一种常用的MYISAM引擎是不支持事务的，本身就没有事务的概念
　　从代码中来看：
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　//oracle的事务:事务起始标志 DML语言 (oracle默认事务似是打开的)
　　//MYSQL默认是自动提交的 (每执行一个sql语言都给你自动提交)
　　/*
　　MySQL set autocommit = 0或1分别什么啊,哪个是自动提交啊
　　要熟练使用mysql的帮助文档，在里面查找autocommit，就会有相应的注释，比我在这里直接给你说要深刻得多。
　　autocoomit是事务，根据mysql的文档如果等于1是立即提交。但在transction中只有遇到commit或rollback才提交。希望对你有用。
　　*/
　　#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回滚无效