MySQL入门之事务概念

mysql默认是自动提交的,也就是你提交一个query,它就直接执行!我们可以通过 
set autocommit=0 禁止自动提交 
set autocommit=1开启自动提交 
mysql中innodb引擎才支持事务处理,默认是自动提交的; 
另外一种常用的myisam引擎是不支持事务的,本身就没有事务的概念 .

可类比Oracle事务的概念!!!

能够避免MySQL的自动提交,自己封装API以后实现回滚等操作!!!

#include <stdio.h>  #include <stdlib.h>  #include <string.h>  #include <dlfcn.h>  #include <mysql>  #include <stdio.h>  #include <stdlib.h>  #include <unistd.h>  #include <string.h>  #include <errno.h>  #include <termios.h>  #include <mysql>  /*  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: %dn", ret);          return ret;      }      //--设置事务手动提交      ret = mysql_query(mysql, SET_TRAN);      if (ret != 0)      {          printf("func mysql_query() err: %dn", 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: %dn", ret);          return ret;      }      //--恢复事务自动提交标志      ret = mysql_query(mysql, UNSET_TRAN);      if (ret != 0)      {          printf("func mysql_query() err: %dn", 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: %dn", ret);          return ret;      }      //--恢复自动提交设置      ret = mysql_query(mysql, UNSET_TRAN);      if (ret != 0)      {          printf("func mysql_query() err: %dn", 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, '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() errn");          return ret;      }      else      {          printf(" ok......n");      }      ret = mysql_BeginTran(mysql);      if (ret != 0)      {          printf("mysql_BeginTran() err:%dn", ret);          return ret;      }      ret = mysql_query(mysql, sql01);      if (ret != 0)      {          printf("mysql_query() err:%dn", ret);          return ret;      }      ret = mysql_query(mysql, sql02);      if (ret != 0)      {          printf("mysql_query() err:%dn", ret);          return ret;      }      ret = mysql_Commit(mysql);      if (ret != 0)      {          printf("mysql_Commit() err:%dn", ret);          return ret;      }      ret = mysql_BeginTran(mysql);      if (ret != 0)      {          printf("mysql_BeginTran() err:%dn", ret);          return ret;      }      ret = mysql_query(mysql, sql03);      if (ret != 0)      {          printf("mysql_query() err:%dn", ret);          return ret;      }      ret = mysql_query(mysql, sql04);      if (ret != 0)      {          printf("mysql_query() err:%dn", ret);          return ret;      }      ret = mysql_Rollback(mysql);      if (ret != 0)      {          printf("mysql_Rollback() err:%dn", ret);          return ret;      }      mysql_close(mysql);  }</mysql></termios.h></errno.h></string.h></unistd.h></stdlib.h></stdio.h></mysql></dlfcn.h></string.h></stdlib.h></stdio.h>

以上就是MySQL入门之事务概念的内容,更多相关内容请关注PHP中文网(www.php.cn)!

© 版权声明
THE END
喜欢就支持一下吧
点赞15 分享