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

vscode中使用C++实现mysql数据库编程（附带相关案例）_vscode 连接mysql c++

作者：羊村懒王 | 2024-03-15 16:35:39

赞

踩

vscode 连接mysql c++

windows下vscode连接Linux中的MySQL教程见：https://blog.csdn.net/weixin_47156401/article/details/129469835?spm=1001.2014.3001.5501

分布式数据库，顾名思义：分布式+数据库。用一句话总结为：由多个独立实体组成，并且彼此通过网络进行互联的数据库。

使用vscode连接Linux中的mysql，并进行mysql开发，对于初学者来讲多少有些摸不着头脑，下面给出mysql的建库、建表，以及增、删、改、查等基本操作。

一、代码解读

（1）主函数

  1. #include<iostream>
  2. #include<mysql.h>
  3. #include<cstring>
  4. #include<istream>
  5. #include<vector>
  6.  
  7. using namespace std;
  8.  
  9. MYSQL mysql;            //mysql连接
  10. MYSQL_FIELD*fd;         //字段列数组
  11. char field[32][32];     //存字段名二维数组
  12. MYSQL_RES *res;         //这个结构代表返回行的一个查询结果集
  13. MYSQL_ROW column;       //一个行数据的类型安全(type-safe)的表示，表示数据行的列
  14.  
  15. bool ConnectDatabase(); //函数声明
  16. void FreeConnect();
  17. bool InsertData();      //增
  18. bool ModifyData();      //改
  19. bool DeleteData();      //删
  20.  
  21.  
  22. int main(){
  23.     ConnectDatabase();
  24.     InsertData();
  25.     ModifyData();
  26.     DeleteData();
  27.     mysql_close(&mysql);
  28.     return 0;
  29. }

（2）连接Linux中的mysql并进行创建库(my_database)、表(my_table)操作

  1. //连接mysql并创建库和表
  2. bool ConnectDatabase(){
  3.     //初始化mysql连接
  4.     mysql_init(&mysql);                 //等价于&mysql=mysql_init(NULL);
  5.  
  6.     const char host[]="localhost";
  7.     const char user[]="root";
  8.     const char psw[]="123456";
  9.     //const char table[]="test";        //需要链接的数据库,如果已经创建了直接连接即可
  10.  
  11.     const int port =3306;
  12.  
  13.     //返回false则连接失败，返回true则连接成功
  14.     if(!mysql_real_connect(&mysql, host, user, psw, NULL, port, NULL,0))
  15.     {
  16.         //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
  17.         cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
  18.         return false;
  19.     }
  20.     else
  21.     {
  22.         cout<<"Connected..."<<endl;
  23.     }
  24.  
  25.     //-------------创建库-------------//
  26.     char *drop_db_query = "DROP DATABASE IF EXISTS my_database";
  27.     mysql_query(&mysql, drop_db_query);
  28.  
  29.     string db_name= "CREATE DATABASE IF NOT EXISTS my_database";
  30.  
  31.     //执行库创建语句，返回0表示执行成功，返回1表示执行失败
  32.     int result=mysql_query(&mysql,db_name.c_str());
  33.  
  34.     if(result){
  35.         cout<<"库创建失败！"<<endl;
  36.         return false;
  37.     }else{
  38.         cout<<"student库创建成功......"<<endl;
  39.     }
  40.  
  41.     // //-------------连接数据库-------------//
  42.     // if(!mysql_real_connect(&mysql, host, user, psw, "my_database", port, NULL,0))
  43.     // {
  44.     //     //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
  45.     //     cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
  46.     //     return false;
  47.     // }
  48.     // else
  49.     // {
  50.     //     cout<<"Connected..."<<endl;
  51.     //     return true;
  52.     // }
  53.  
  54.     //选择数据库
  55.     if (mysql_select_db(&mysql, "my_database")) {
  56.         cout<<"选择数据库失败！"<<mysql_error(&mysql)<<endl;
  57.         return false;
  58.     }
  59.  
  60.     //-------------在my_database库中创建表-------------//
  61.     char *drop_table_query = "DROP TABLE IF EXISTS my_table";
  62.     mysql_query(&mysql, drop_table_query);
  63.  
  64.     string table="CREATE TABLE IF NOT EXISTS my_table (id int, name VARCHAR(20), number VARCHAR(20), email VARCHAR(20))";
  65.  
  66.     if (mysql_query(&mysql, table.c_str())) {
  67.         cout << "user创建失败!" << mysql_error(&mysql) << endl;
  68.         return false;
  69.     }else{
  70.         cout << "user创建成功......"<<endl;
  71.     }
  72. }

（3）往表(my_table)中插入数据

  1. //插入数据
  2. bool InsertData(){
  3.  
  4.     //插入数据
  5.     string query="INSERT INTO my_table (id, name, number, email) VALUES (1, 'liubei', '33333333', '165438490@qq.com')";
  6.     
  7.     //执行SQL语句
  8.     if(mysql_query(&mysql, query.c_str())){
  9.         cout<<"数据插入失败！"<<mysql_error(&mysql)<<endl;
  10.         return false;
  11.     }
  12.     else
  13.     {
  14.         cout<<"数据插入成功！"<<endl;
  15.     }
  16.  
  17.     //插入数据
  18.     string data1="insert into my_table values(2, 'guanyu', '22222222', '163438490@qq.com');";
  19.     mysql_query(&mysql, data1.c_str());
  20.  
  21.     //插入数据
  22.     string data2="insert into my_table values(3, 'zhangfei', '11111111', '164438490@qq.com');";
  23.     mysql_query(&mysql, data2.c_str());
  24.  
  25.     // select and print data
  26.     string query2 = "SELECT * FROM my_table";
  27.  
  28.     if (mysql_query(&mysql, query2.c_str())) {
  29.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  30.         return false;
  31.     }
  32.  
  33.     MYSQL_RES *res = mysql_use_result(&mysql);
  34.     MYSQL_ROW row;
  35.     
  36.     while ((row = mysql_fetch_row(res)) != NULL) {
  37.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  38.     }
  39.     mysql_free_result(res);
  40. }

（4）修改表(my_table)中的数据

  1. //修改数据
  2. bool ModifyData(){
  3.     //修改内容
  4.     string query="UPDATE my_table SET email='166438490@qq.com' where name='liubei'";
  5.  
  6.     //执行SQL语句
  7.     if(mysql_query(&mysql, query.c_str())){
  8.         cout<<"修改数据失败！"<<mysql_error(&mysql)<<endl;
  9.         return false;
  10.     }else{
  11.         cout<<"数据修改成功！"<<endl;
  12.     }
  13.  
  14.     // select and print data
  15.     string query2 = "SELECT * FROM my_table";
  16.  
  17.     if (mysql_query(&mysql, query2.c_str())) {
  18.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  19.         return false;
  20.     }
  21.  
  22.     MYSQL_RES *res = mysql_use_result(&mysql);
  23.     MYSQL_ROW row;
  24.     
  25.     while ((row = mysql_fetch_row(res)) != NULL) {
  26.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  27.     }
  28.     mysql_free_result(res);
  29. }

（5）删除表(my_table)中的指定数据

  1. //删除数据
  2. bool DeleteData(){
  3.     /*eg: "DELETE FROM my_table where id=2";*/
  4.     string query="DELETE FROM my_table where id=2";
  5.     cout<<"please input the sql:"<<endl;
  6.     getline(cin,query);//这里手动输入sql语句
  7.  
  8.     //执行SQL语句
  9.     if(mysql_query(&mysql, query.c_str())){
  10.         cout<<"删除数据失败！"<<mysql_error(&mysql)<<endl;
  11.         return false;
  12.     }else{
  13.         cout<<"成功删除数据！"<<endl;
  14.     }
  15.  
  16.     // select and print data
  17.     string query2 = "SELECT * FROM my_table";
  18.  
  19.     if (mysql_query(&mysql, query2.c_str())) {
  20.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  21.         return false;
  22.     }
  23.  
  24.     MYSQL_RES *res = mysql_use_result(&mysql);
  25.     MYSQL_ROW row;
  26.     
  27.     while ((row = mysql_fetch_row(res)) != NULL) {
  28.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  29.     }
  30.     mysql_free_result(res);
  31. }

（6）释放资源

  1. //释放资源
  2. void FreeConnect(){
  3.     mysql_free_result(res);     //释放一个结果集合使用的内存。
  4.     mysql_close(&mysql);        //关闭一个服务器连接。
  5. }

二、完整代码

  1. #include<iostream>
  2. #include<mysql.h>
  3. #include<cstring>
  4. #include<istream>
  5. #include<vector>
  6.  
  7. using namespace std;
  8.  
  9. MYSQL mysql;            //mysql连接
  10. MYSQL_FIELD*fd;         //字段列数组
  11. char field[32][32];     //存字段名二维数组
  12. MYSQL_RES *res;         //这个结构代表返回行的一个查询结果集
  13. MYSQL_ROW column;       //一个行数据的类型安全(type-safe)的表示，表示数据行的列
  14.  
  15. bool ConnectDatabase(); //函数声明
  16. void FreeConnect();
  17. bool InsertData();      //增
  18. bool ModifyData();      //改
  19. bool DeleteData();      //删
  20.  
  21.  
  22. int main(){
  23.     ConnectDatabase();
  24.     InsertData();
  25.     ModifyData();
  26.     DeleteData();
  27.  
  28.     mysql_close(&mysql);
  29.     return 0;
  30. }
  31.  
  32. //连接mysql并创建库和表
  33. bool ConnectDatabase(){
  34.     //初始化mysql连接
  35.     mysql_init(&mysql);                 //等价于&mysql=mysql_init(NULL);
  36.  
  37.     const char host[]="localhost";
  38.     const char user[]="root";
  39.     const char psw[]="123456";
  40.     //const char table[]="test";        //需要链接的数据库,如果已经创建了直接连接即可
  41.  
  42.     const int port =3306;
  43.  
  44.     //返回false则连接失败，返回true则连接成功
  45.     if(!mysql_real_connect(&mysql, host, user, psw, NULL, port, NULL,0))
  46.     {
  47.         //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
  48.         cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
  49.         return false;
  50.     }
  51.     else
  52.     {
  53.         cout<<"Connected..."<<endl;
  54.     }
  55.  
  56.     //-------------创建库-------------//
  57.     char *drop_db_query = "DROP DATABASE IF EXISTS my_database";
  58.     mysql_query(&mysql, drop_db_query);
  59.  
  60.     string db_name= "CREATE DATABASE IF NOT EXISTS my_database";
  61.  
  62.     //执行库创建语句，返回0表示执行成功，返回1表示执行失败
  63.     int result=mysql_query(&mysql,db_name.c_str());
  64.  
  65.     if(result){
  66.         cout<<"库创建失败！"<<endl;
  67.         return false;
  68.     }else{
  69.         cout<<"student库创建成功......"<<endl;
  70.     }
  71.  
  72.     // //-------------连接数据库-------------//
  73.     // if(!mysql_real_connect(&mysql, host, user, psw, "my_database", port, NULL,0))
  74.     // {
  75.     //     //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
  76.     //     cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
  77.     //     return false;
  78.     // }
  79.     // else
  80.     // {
  81.     //     cout<<"Connected..."<<endl;
  82.     //     return true;
  83.     // }
  84.  
  85.     //选择数据库
  86.     if (mysql_select_db(&mysql, "my_database")) {
  87.         cout<<"选择数据库失败！"<<mysql_error(&mysql)<<endl;
  88.         return false;
  89.     }
  90.  
  91.     //-------------在my_database库中创建表-------------//
  92.     char *drop_table_query = "DROP TABLE IF EXISTS my_table";
  93.     mysql_query(&mysql, drop_table_query);
  94.  
  95.     string table="CREATE TABLE IF NOT EXISTS my_table (id int, name VARCHAR(20), number VARCHAR(20), email VARCHAR(20))";
  96.  
  97.     if (mysql_query(&mysql, table.c_str())) {
  98.         cout << "user创建失败!" << mysql_error(&mysql) << endl;
  99.         return false;
  100.     }else{
  101.         cout << "user创建成功......"<<endl;
  102.     }
  103. }
  104.  
  105.  
  106. //释放资源
  107. void FreeConnect(){
  108.     mysql_free_result(res);     //释放一个结果集合使用的内存。
  109.     mysql_close(&mysql);        //关闭一个服务器连接。
  110. }
  111.  
  112. /******************************数程库操作***********************************/
  113.  
  114. //插入数据
  115. bool InsertData(){
  116.  
  117.     //插入数据
  118.     string query="INSERT INTO my_table (id, name, number, email) VALUES (1, 'liubei', '33333333', '165438490@qq.com')";
  119.     
  120.     //执行SQL语句
  121.     if(mysql_query(&mysql, query.c_str())){
  122.         cout<<"数据插入失败！"<<mysql_error(&mysql)<<endl;
  123.         return false;
  124.     }
  125.     else
  126.     {
  127.         cout<<"数据插入成功！"<<endl;
  128.     }
  129.  
  130.     //插入数据
  131.     string data1="insert into my_table values(2, 'guanyu', '22222222', '163438490@qq.com');";
  132.     mysql_query(&mysql, data1.c_str());
  133.  
  134.     //插入数据
  135.     string data2="insert into my_table values(3, 'zhangfei', '11111111', '164438490@qq.com');";
  136.     mysql_query(&mysql, data2.c_str());
  137.  
  138.     // select and print data
  139.     string query2 = "SELECT * FROM my_table";
  140.  
  141.     if (mysql_query(&mysql, query2.c_str())) {
  142.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  143.         return false;
  144.     }
  145.  
  146.     MYSQL_RES *res = mysql_use_result(&mysql);
  147.     MYSQL_ROW row;
  148.     
  149.     while ((row = mysql_fetch_row(res)) != NULL) {
  150.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  151.     }
  152.     mysql_free_result(res);
  153. }
  154.  
  155. //修改数据
  156. bool ModifyData(){
  157.     //修改内容
  158.     string query="UPDATE my_table SET email='166438490@qq.com' where name='liubei'";
  159.  
  160.     //执行SQL语句
  161.     if(mysql_query(&mysql, query.c_str())){
  162.         cout<<"修改数据失败！"<<mysql_error(&mysql)<<endl;
  163.         return false;
  164.     }else{
  165.         cout<<"数据修改成功！"<<endl;
  166.     }
  167.  
  168.     // select and print data
  169.     string query2 = "SELECT * FROM my_table";
  170.  
  171.     if (mysql_query(&mysql, query2.c_str())) {
  172.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  173.         return false;
  174.     }
  175.  
  176.     MYSQL_RES *res = mysql_use_result(&mysql);
  177.     MYSQL_ROW row;
  178.     
  179.     while ((row = mysql_fetch_row(res)) != NULL) {
  180.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  181.     }
  182.     mysql_free_result(res);
  183. }
  184.  
  185. //删除数据
  186. bool DeleteData(){
  187.     /*eg: "DELETE FROM my_table where id=2";*/
  188.     string query="DELETE FROM my_table where id=2";
  189.     cout<<"please input the sql:"<<endl;
  190.     getline(cin,query);//这里手动输入sql语句
  191.  
  192.     //执行SQL语句
  193.     if(mysql_query(&mysql, query.c_str())){
  194.         cout<<"删除数据失败！"<<mysql_error(&mysql)<<endl;
  195.         return false;
  196.     }else{
  197.         cout<<"成功删除数据！"<<endl;
  198.     }
  199.  
  200.     // select and print data
  201.     string query2 = "SELECT * FROM my_table";
  202.  
  203.     if (mysql_query(&mysql, query2.c_str())) {
  204.         cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
  205.         return false;
  206.     }
  207.  
  208.     MYSQL_RES *res = mysql_use_result(&mysql);
  209.     MYSQL_ROW row;
  210.     
  211.     while ((row = mysql_fetch_row(res)) != NULL) {
  212.         cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
  213.     }
  214.     mysql_free_result(res);
  215. }

若有帮到你，点个赞，留下你的脚印哦！

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

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

  

闽ICP备14008679号