C/C++连接MySQL数据库“经典”例子!

举报
allin_allin 发表于 2021/05/29 13:52:21 2021/05/29
【摘要】 废话不多说,直接撸代码!!! //下面的代码是一个实现C++连接MYSQL数据库的很好的例子//这里用了建表,插入,检索,删表等常用功能//我用VC++6.0生成,已经成功连接了。//在VC++6.0中要想把做一下两步准备工作才可以。//(1)Tools->Options->Directories->Include files中添加C:\Prog...


废话不多说,直接撸代码!!!


  
  1. //下面的代码是一个实现C++连接MYSQL数据库的很好的例子
  2. //这里用了建表,插入,检索,删表等常用功能
  3. //我用VC++6.0生成,已经成功连接了。
  4. //在VC++6.0中要想把做一下两步准备工作才可以。
  5. //(1)Tools->Options->Directories->Include files中添加C:\Program Files\MySQL\MySQL Server 6.0\include
  6. //(2)Tools->Options->Directories->Library files中添加C:\Program Files\MySQL\MySQL Server 6.0\lib\opt
  7. //其实就是将头文件和库文件包含进来
  8. //我觉得这个例子写的很好,再结合自己的试验,特地介绍给大家!
  9. #include <winsock.h>
  10. #include <iostream>
  11. #include <string>
  12. #include <mysql.h>
  13. using namespace std;
  14. #pragma comment(lib, "ws2_32.lib")
  15. #pragma comment(lib, "libmysql.lib")
  16. //单步执行,不想单步执行就注释掉
  17. #define STEPBYSTEP
  18. int main() {
  19. cout << "****************************************" << endl;
  20. #ifdef STEPBYSTEP
  21. system("pause");
  22. #endif
  23. //必备的一个数据结构
  24. MYSQL mydata;
  25. //初始化数据库
  26. if (0 == mysql_library_init(0, NULL, NULL)) {
  27. cout << "mysql_library_init() succeed" << endl;
  28. } else {
  29. cout << "mysql_library_init() failed" << endl;
  30. return -1;
  31. }
  32. #ifdef STEPBYSTEP
  33. system("pause");
  34. #endif
  35. //初始化数据结构
  36. if (NULL != mysql_init(&mydata)) {
  37. cout << "mysql_init() succeed" << endl;
  38. } else {
  39. cout << "mysql_init() failed" << endl;
  40. return -1;
  41. }
  42. #ifdef STEPBYSTEP
  43. system("pause");
  44. #endif
  45. //在连接数据库之前,设置额外的连接选项
  46. //可以设置的选项很多,这里设置字符集,否则无法处理中文
  47. if (0 == mysql_options(&mydata, MYSQL_SET_CHARSET_NAME, "gbk")) {
  48. cout << "mysql_options() succeed" << endl;
  49. } else {
  50. cout << "mysql_options() failed" << endl;
  51. return -1;
  52. }
  53. #ifdef STEPBYSTEP
  54. system("pause");
  55. #endif
  56. //连接数据库
  57. if (NULL
  58. != mysql_real_connect(&mydata, "localhost", "root", "test", "test",
  59. 3306, NULL, 0))
  60. //这里的地址,用户名,密码,端口可以根据自己本地的情况更改
  61. {
  62. cout << "mysql_real_connect() succeed" << endl;
  63. } else {
  64. cout << "mysql_real_connect() failed" << endl;
  65. return -1;
  66. }
  67. #ifdef STEPBYSTEP
  68. system("pause");
  69. #endif
  70. //sql字符串
  71. string sqlstr;
  72. //创建一个表
  73. sqlstr = "CREATE TABLE IF NOT EXISTS user_info";
  74. sqlstr += "(";
  75. sqlstr +=
  76. "user_id INT UNSIGNED NOT NULL AUTO_INCREMENT PRIMARY KEY COMMENT 'Unique User ID',";
  77. sqlstr +=
  78. "user_name VARCHAR(100) CHARACTER SET gb2312 COLLATE gb2312_chinese_ci NULL COMMENT 'Name Of User',";
  79. sqlstr +=
  80. "user_second_sum INT UNSIGNED NOT NULL DEFAULT 0 COMMENT 'The Summation Of Using Time'";
  81. sqlstr += ");";
  82. if (0 == mysql_query(&mydata, sqlstr.c_str())) {
  83. cout << "mysql_query() create table succeed" << endl;
  84. } else {
  85. cout << "mysql_query() create table failed" << endl;
  86. mysql_close(&mydata);
  87. return -1;
  88. }
  89. #ifdef STEPBYSTEP
  90. system("pause");
  91. #endif
  92. //向表中插入数据
  93. sqlstr =
  94. "INSERT INTO user_info(user_name) VALUES('公司名称'),('一级部门'),('二级部门'),('开发小组'),('姓名');";
  95. if (0 == mysql_query(&mydata, sqlstr.c_str())) {
  96. cout << "mysql_query() insert data succeed" << endl;
  97. } else {
  98. cout << "mysql_query() insert data failed" << endl;
  99. mysql_close(&mydata);
  100. return -1;
  101. }
  102. #ifdef STEPBYSTEP
  103. system("pause");
  104. #endif
  105. //显示刚才插入的数据
  106. sqlstr = "SELECT user_id,user_name,user_second_sum FROM user_info";
  107. MYSQL_RES *result = NULL;
  108. if (0 == mysql_query(&mydata, sqlstr.c_str())) {
  109. cout << "mysql_query() select data succeed" << endl;
  110. //一次性取得数据集
  111. result = mysql_store_result(&mydata);
  112. //取得并打印行数
  113. int rowcount = mysql_num_rows(result);
  114. cout << "row count: " << rowcount << endl;
  115. //取得并打印各字段的名称
  116. unsigned int fieldcount = mysql_num_fields(result);
  117. MYSQL_FIELD *field = NULL;
  118. for (unsigned int i = 0; i < fieldcount; i++) {
  119. field = mysql_fetch_field_direct(result, i);
  120. cout << field->name << "\t\t";
  121. }
  122. cout << endl;
  123. //打印各行
  124. MYSQL_ROW row = NULL;
  125. row = mysql_fetch_row(result);
  126. while (NULL != row) {
  127. for (int i = 0; i < fieldcount; i++) {
  128. cout << row[i] << "\t\t";
  129. }
  130. cout << endl;
  131. row = mysql_fetch_row(result);
  132. }
  133. } else {
  134. cout << "mysql_query() select data failed" << endl;
  135. mysql_close(&mydata);
  136. return -1;
  137. }
  138. #ifdef STEPBYSTEP
  139. system("pause");
  140. #endif
  141. //删除刚才建的表
  142. sqlstr = "DROP TABLE user_info";
  143. if (0 == mysql_query(&mydata, sqlstr.c_str())) {
  144. cout << "mysql_query() drop table succeed" << endl;
  145. } else {
  146. cout << "mysql_query() drop table failed" << endl;
  147. mysql_close(&mydata);
  148. return -1;
  149. }
  150. mysql_free_result(result);
  151. mysql_close(&mydata);
  152. mysql_server_end();
  153. system("pause");
  154. return 0;
  155. }


文章来源: blog.csdn.net,作者:allinallinallin,版权归原作者所有,如需转载,请联系作者。

原文链接:blog.csdn.net/to_Baidu/article/details/53819829

【版权声明】本文为华为云社区用户转载文章,如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。