devbox
羊村懒王
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Mysql 数据库APi 编程（c/c++）-1.1

作者：羊村懒王 | 2024-05-23 19:21:51

赞

踩

Mysql 数据库APi 编程（c/c++）-1.1

日期时间类API函数

练习：熟悉上述预处理类工作模式，模拟精简一个将时间插入数据库的程序。将时间存入数据库有两种方式： 1. 使用SQL语句方式

2. 预处理环境句柄变量方式存入

提示：

MYSQL_TIME  ts; 浏览头文件 mysql_time.h 熟悉MYSQL_TIME结构体。

MYSQL_BIND  bind[3];

MYSQL_STMT  *stmt;

可直接使用SQL语句提前创建表test_table2，也可以使用mysql_query函数来创建。

create table test_table2 (date_field date, time_field time, timestamp_field timestamp);

char query[1024] = "INSERT INTO test_table2(date_field, time_field, timestamp_field) VALUES(?,?,?)";

stmt = mysql_stmt_init(mysql);

MYSQL_TIME 是一个结构体，使用typedef定义。位于mysql_time.h文件中。

API参考：refman-5.6-en.a4.pdf手册25.2.10. 日期和时间值的C API处理

多查询执行的C API函数

一次性执行多条SQL语句，包括select、drop、update、create等。 如：

mysql_query(mysql,"DROP TABLE IF EXISTS test_table;\

                 CREATE TABLE test_table(id INT);\

              INSERT INTO test_table VALUES(10);\

             UPDATE test_table SET id=20 WHERE id=10;\

             SELECT * FROM test_table;\

              DROP TABLE test_table");

文档：25.2.9. 多查询执行的C API处理。中文文档只有demo框架。查阅对应英文文档refman-5.6-en.a4.pdf。关键字Multiple 23.8.17

注意：打桩函数——函数接口

if (mysql_real_connect (mysql, host_name, user_name, password,

db_name, port_num, socket_name, CLIENT_MULTI_STATEMENTS) == NULL)

CLIENT_MULTI_STATEMENTS：客户端通知Server，将要发送多个SQL语句。

mysql_field_count(mysql)：影响的行数。 如：

当select * from dept; 执行结束，提示：“5 rows in set” 表示影响了4行。

当Create一张表， 执行结束，提示：“Query OK, 0 rows affected (0.01 sec)”

当delete一行， 执行结束，提示：“Query OK, 1 row affected (0.00 sec)”

mysql_field_count函数调用后会将影响的行数保存到句柄 mysql 中。

将帮助文档中的demo导入程序，分析与我们之前掌握的API函数间的区别与联系：

  1. #include <stdio.h>
  2.  
  3. #include <stdlib.h>
  4.  
  5. #include <string.h>
  6.  
  7. #include "mysql.h"
  8.  
  9. void process_result_set(MYSQL *mysql, MYSQL_RES *result)
  10.  
  11. {
  12.  
  13. int i, num;
  14.  
  15. num = mysql_field_count(mysql);
  16.  
  17.  
  18.  
  19. MYSQL_FIELD *fields = NULL;
  20.  
  21. fields = mysql_fetch_fields(result);
  22.  
  23. for (i = 0; i < num; i++) {
  24.  
  25. printf("%10s\t", fields[i].name);
  26.  
  27. }
  28.  
  29. printf("\n");
  30.  
  31.  
  32.  
  33. MYSQL_ROW row = NULL;
  34.  
  35. while ((row = mysql_fetch_row(result))) {
  36.  
  37. for (i = 0; i < num; i++) {
  38.  
  39. printf("%10s\t", row[i]);
  40.  
  41. }
  42.  
  43. printf("\n");
  44.  
  45. }
  46.  
  47. }
  48.  
  49.  
  50.  
  51. int main(void)
  52.  
  53. {
  54.  
  55. int ret = 0, status = 0;
  56.  
  57.  
  58.  
  59. MYSQL_RES *result = NULL;
  60.  
  61.  
  62.  
  63. MYSQL *mysql = mysql_init(NULL);
  64.  
  65. if (mysql == NULL) {
  66.  
  67. //unsigned int mysql_errno(MYSQL *mysql)
  68.  
  69. ret = mysql_errno(mysql);
  70.  
  71. printf("mysql_init err:%d\n", ret);
  72.  
  73. return ret;
  74.  
  75. }
  76.  
  77.  
  78.  
  79. mysql = mysql_real_connect(mysql, "localhost", "root", "123456", "mydb61", 0, NULL, CLIENT_MULTI_STATEMENTS);
  80.  
  81. if (mysql == NULL) {
  82.  
  83. ret = mysql_errno(mysql);
  84.  
  85. printf("mysql_init err:%d\n", ret);
  86.  
  87. return ret;
  88.  
  89. }
  90.  
  91. /以下为demo源码//
  92.  
  93. /* execute multiple statements */
  94.  
  95. status = mysql_query(mysql,"DROP TABLE IF EXISTS test_table;\
  97. CREATE TABLE test_table(id INT);\
  99. INSERT INTO test_table VALUES(10);\
  101. UPDATE test_table SET id=20 WHERE id=10;\
  103. SELECT * FROM test_table;");
  104.  
  105. DROP TABLE test_table
  106.  
  107. if (status)
  108.  
  109. {
  110.  
  111. printf("Could not execute statement(s)");
  112.  
  113. mysql_close(mysql);
  114.  
  115. exit(0);
  116.  
  117. }
  118.  
  119. /* process each statement result */
  120.  
  121. do {
  122.  
  123. /* did current statement return data? */
  124.  
  125. result = mysql_store_result(mysql);
  126.  
  127. if (result)
  128.  
  129. {
  130.  
  131. /* yes; process rows and free the result set */
  132.  
  133. process_result_set(mysql, result);
  134.  
  135. mysql_free_result(result);
  136.  
  137. }
  138.  
  139. else /* no result set or error */
  140.  
  141. {
  142.  
  143. if (mysql_field_count(mysql) == 0)
  144.  
  145. {
  146.  
  147. printf("%lld rows affected\n",
  148.  
  149. mysql_affected_rows(mysql));
  150.  
  151. }
  152.  
  153. else /* some error occurred */
  154.  
  155. {
  156.  
  157. printf("Could not retrieve result set\n");
  158.  
  159. break;
  160.  
  161. } }
  162.  
  163.  
  164.  
  165. /* more results? -1 = no, >0 = error, 0 = yes (keep looping) */
  166.  
  167. if ((status = mysql_next_result(mysql)) > 0)
  168.  
  169. printf("Could not execute statement\n");
  170.  
  171.  
  172.  
  173. printf("------------status: %d\n", status);
  174.  
  175.  
  176.  
  177. } while (status == 0);
  178.  
  179. mysql_close(mysql);
  180.  
  181.  
  182.  
  183. return 0;
  184.  
  185. }

process_result_set函数是文档中给我们预留的打桩函数，需要我们在使用的过程中，自己实现它。

函数实现就是借助mysql和result两个参数打印一条sql语句查询到的结果集到屏幕。

可以直接使用mysq_tool.c中if (strncmp(sqlbuf, "select", 6) == 0 || strncmp(sqlbuf, "SELECT", 6) == 0)内的代码。“获取结果集”片段可以删除。“释放结果集”片段可以删除。API示例中含有该部分内容。

常见错误：在process_result_set函数实现中，不要使用mysql_store_result（mysql）再次获取结果集， 该result已经在API函数接口传入，直接使用参数result即可。否则会出现【段错误】。

MySQL中的事务

测试MySQL中事务的特性。

MySQL的事务的默认自动提交的，每执行一个sql语句都自动commit

Oracle的事务是自动打开的(以你执行的一条DML语句为标志)，但每次执行需要手动commit

在程序中设置autocommit修改MySQL事务的属性。

set autocommit = 0 禁止自动提交

set autocommit = 1 开启自动提交MySQL中InnoDB引擎才支持事务默认自动提交机制。MYISAM引擎不支持。

  1. #include <stdio.h>
  2.  
  3. #include <stdlib.h>
  4.  
  5. #include <string.h>
  6.  
  7. #include "mysql.h"
  8.  
  9. #define SET_TRAN "SET AUTOCOMMIT=0"   //手动commit
  10.  
  11. #define UNSET_TRAN "SET AUTOCOMMIT=1" //自动commit
  12.  
  13. //设置事务为手动提交
  14.  
  15. int mysql_OperationTran(MYSQL *mysql)  
  16.  
  17. {
  18.  
  19. //--开启事务
  20.  
  21. int ret = mysql_query(mysql, "start transaction");  
  22.  
  23. if (ret != 0) {
  24.  
  25. printf("mysql_OperationTran query start err: %s\n", mysql_error(mysql));
  26.  
  27. return ret;
  28.  
  29. }
  30.  
  31.  
  32.  
  33. //--设置事务为手动提交
  34.  
  35. ret = mysql_query(mysql, SET_TRAN);
  36.  
  37. if (ret != 0) {
  38.  
  39. printf("mysql_OperationTran query set err: %s\n", mysql_error(mysql));
  40.  
  41. return ret;
  42.  
  43. }
  44.  
  45. return ret;
  46.  
  47. }
  48.  
  49. //设置事务为自动提交
  50.  
  51. int mysql_AutoTran(MYSQL *mysql)
  52.  
  53. {
  54.  
  55. //--开启事务
  56.  
  57. int ret = mysql_query(mysql, "start transaction");  
  58.  
  59. if (ret != 0) {
  60.  
  61. printf("mysql_AutoTran query start err: %s\n", mysql_error(mysql));
  62.  
  63. return ret;
  64.  
  65. }
  66.  
  67. //--设置事务为自动提交
  68.  
  69. ret = mysql_query(mysql, UNSET_TRAN);
  70.  
  71. if (ret != 0) {
  72.  
  73. printf("mysql_AutoTran query set err: %s\n", mysql_error(mysql));
  74.  
  75. return ret;
  76.  
  77. }
  78.  
  79. return ret;
  80.  
  81. }
  82.  
  83. //执行commit，手动提交事务
  84.  
  85. int mysql_Commit(MYSQL *mysql)
  86.  
  87. {
  88.  
  89. int ret = mysql_query(mysql, "COMMIT");
  90.  
  91. if (ret != 0) {
  92.  
  93. printf("commit err: %s\n", mysql_error(mysql));
  94.  
  95. return ret;
  96.  
  97. }
  98.  
  99. return ret;
  100.  
  101. }
  102.  
  103.  
  104.  
  105. //执行rollback，回滚事务
  106.  
  107. int mysql_Rollback(MYSQL *mysql)
  108.  
  109. {
  110.  
  111. int ret = mysql_query(mysql, "ROLLBACK");
  112.  
  113. if (ret != 0) {
  114.  
  115. printf("rollback err: %s\n", mysql_error(mysql));
  116.  
  117. return ret;
  118.  
  119. }
  120.  
  121. return ret;
  122.  
  123. }
  124.  
  125. #define DROP_SAMPLE_TABLE "DROP TABLE IF EXISTS test_table"
  126.  
  127. #define CREATE_SAMPLE_TABLE "CREATE TABLE test_table(col1 INT,\
  129.                                                  col2 VARCHAR(10),\
  131.                                                  col3 VARCHAR(10))"
  132.  
  133.                                                                                        
  134.  
  135. #define sql01 "INSERT INTO test_table(col1,col2,col3) VALUES(10, 'AAA', 'A1')"
  136.  
  137. #define sql02 "INSERT INTO test_table(col1,col2,col3) VALUES(20, 'BBB', 'B2')"
  138.  
  139. #define sql03 "INSERT INTO test_table(col1,col2,col3) VALUES(30, 'CCC', 'C3')"
  140.  
  141. #define sql04 "INSERT INTO test_table(col1,col2,col3) VALUES(40, 'DDD', 'D4')"
  142.  
  143.  
  144.  
  145. int main(void)
  146.  
  147. {
  148.  
  149. int ret = 0;
  150.  
  151. MYSQL *mysql = mysql_init(NULL);
  152.  
  153.  
  154.  
  155. mysql = mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, 0);
  156.  
  157. if (mysql == NULL) {
  158.  
  159. ret = mysql_errno(mysql);
  160.  
  161. printf("func mysql_real_connect() err：%d\n", ret);
  162.  
  163. return ret;
  164.  
  165. }
  166.  
  167. printf(" --- connect ok......\n");
  168.  
  169.  
  170.  
  171. if (mysql_query(mysql, DROP_SAMPLE_TABLE)) {
  172.  
  173.   fprintf(stderr, " DROP TABLE failed\n");
  174.  
  175.   fprintf(stderr, " %s\n", mysql_error(mysql));
  176.  
  177.   exit(0);
  178.  
  179. }
  180.  
  181. if (mysql_query(mysql, CREATE_SAMPLE_TABLE)) {
  182.  
  183.   fprintf(stderr, " CREATE TABLE failed\n");
  184.  
  185.   fprintf(stderr, " %s\n", mysql_error(mysql));
  186.  
  187.   exit(0);
  188.  
  189. }
  190.  
  191.  
  192.  
  193. ret = mysql_OperationTran(mysql); //开启事务，并修改事务属性为手动commit
  194.  
  195. if (ret != 0) {
  196.  
  197. printf("mysql_OperationTran() err:%d\n", ret);
  198.  
  199. return ret;
  200.  
  201. }
  202.  
  203.  
  204.  
  205. ret = mysql_query(mysql, sql01); //向表中插入第一行数据 ‘AAA’
  206.  
  207. if (ret != 0) {
  208.  
  209. printf("mysql_query() err:%d\n", ret); return ret;
  210.  
  211. }
  212.  
  213. ret = mysql_query(mysql, sql02); //向表中插入第二行数据 ‘BBB’
  214.  
  215. if (ret != 0) {
  216.  
  217. printf("mysql_query() err:%d\n", ret);
  218.  
  219. return ret;
  220.  
  221. }
  222.  
  223. ret = mysql_Commit(mysql); //手动提交事务
  224.  
  225. if (ret != 0) {
  226.  
  227. printf("mysql_Commit() err:%d\n", ret);
  228.  
  229. return ret;
  230.  
  231. }
  232.  
  233.  
  234.  
  235. ret = mysql_AutoTran(mysql); // =再次= 修改事务属性为【自动】commit
  236.  
  237. if (ret != 0) {
  238.  
  239. printf("mysql_OperationTran() err:%d\n", ret);
  240.  
  241. return ret;
  242.  
  243. }
  244.  
  245. ret = mysql_OperationTran(mysql); // =再次= 修改事务属性为【手动】commit
  246.  
  247. if (ret != 0) {
  248.  
  249. printf("mysql_OperationTran() err:%d\n", ret);
  250.  
  251. return ret;
  252.  
  253. }
  254.  
  255. ret = mysql_query(mysql, sql03); //向表中插入第三行数据 ‘CCC’
  256.  
  257. if (ret != 0) {
  258.  
  259. printf("mysql_query() err:%d\n", ret);
  260.  
  261. return ret;
  262.  
  263. }
  264.  
  265. ret = mysql_query(mysql, sql04); //向表中插入第四行数据 ‘DDD’
  266.  
  267. if (ret != 0) {
  268.  
  269. printf("mysql_query() err:%d\n", ret);
  270.  
  271. return ret;
  272.  
  273. }
  274.  
  275. ret = mysql_Rollback(mysql); //直接rollback操作
  276.  
  277. if (ret != 0) {
  278.  
  279. printf("mysql_Rollback() err:%d\n", ret);
  280.  
  281. return ret;
  282.  
  283. }
  284.  
  285. //rollback操作是否能回退掉CCC、DDD的值，取决于事务属性。
  286.  
  287. mysql_close(mysql);
  288.  
  289. return 0;
  290.  
  291. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/羊村懒王/article/detail/614157
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号