AI 助理
备案控制台
开发者社区 数据库 文章 正文

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

2023-06-26 568
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
云数据库 RDS MySQL，高可用系列 2核4GB
简介： vscode中使用C++实现mysql数据库编程（附带相关案例）

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


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

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


一、代码解读


（1）主函数


#include<iostream>
#include<mysql.h>
#include<cstring>
#include<istream>
#include<vector>
using namespace std;
MYSQL mysql;            //mysql连接
MYSQL_FIELD*fd;         //字段列数组
char field[32][32];     //存字段名二维数组
MYSQL_RES *res;         //这个结构代表返回行的一个查询结果集
MYSQL_ROW column;       //一个行数据的类型安全(type-safe)的表示，表示数据行的列
bool ConnectDatabase(); //函数声明
void FreeConnect();
bool InsertData();      //增
bool ModifyData();      //改
bool DeleteData();      //删
int main(){
    ConnectDatabase();
    InsertData();
    ModifyData();
    DeleteData();
    mysql_close(&mysql);
    return 0;
}


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


//连接mysql并创建库和表
bool ConnectDatabase(){
    //初始化mysql连接
    mysql_init(&mysql);                 //等价于&mysql=mysql_init(NULL);
    const char host[]="localhost";
    const char user[]="root";
    const char psw[]="123456";
    //const char table[]="test";        //需要链接的数据库,如果已经创建了直接连接即可
    const int port =3306;
    //返回false则连接失败，返回true则连接成功
    if(!mysql_real_connect(&mysql, host, user, psw, NULL, port, NULL,0))
    {
        //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
        cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
        return false;
    }
    else
    {
        cout<<"Connected..."<<endl;
    }
    //-------------创建库-------------//
    char *drop_db_query = "DROP DATABASE IF EXISTS my_database";
    mysql_query(&mysql, drop_db_query);
    string db_name= "CREATE DATABASE IF NOT EXISTS my_database";
    //执行库创建语句，返回0表示执行成功，返回1表示执行失败
    int result=mysql_query(&mysql,db_name.c_str());
    if(result){
        cout<<"库创建失败！"<<endl;
        return false;
    }else{
        cout<<"student库创建成功......"<<endl;
    }
    // //-------------连接数据库-------------//
    // if(!mysql_real_connect(&mysql, host, user, psw, "my_database", port, NULL,0))
    // {
    //     //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
    //     cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
    //     return false;
    // }
    // else
    // {
    //     cout<<"Connected..."<<endl;
    //     return true;
    // }
    //选择数据库
    if (mysql_select_db(&mysql, "my_database")) {
        cout<<"选择数据库失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    //-------------在my_database库中创建表-------------//
    char *drop_table_query = "DROP TABLE IF EXISTS my_table";
    mysql_query(&mysql, drop_table_query);
    string table="CREATE TABLE IF NOT EXISTS my_table (id int, name VARCHAR(20), number VARCHAR(20), email VARCHAR(20))";
    if (mysql_query(&mysql, table.c_str())) {
        cout << "user创建失败!" << mysql_error(&mysql) << endl;
        return false;
    }else{
        cout << "user创建成功......"<<endl;
    }
}


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


//插入数据
bool InsertData(){
    //插入数据
    string query="INSERT INTO my_table (id, name, number, email) VALUES (1, 'liubei', '33333333', '165438490@qq.com')";
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"数据插入失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    else
    {
        cout<<"数据插入成功！"<<endl;
    }
    //插入数据
    string data1="insert into my_table values(2, 'guanyu', '22222222', '163438490@qq.com');";
    mysql_query(&mysql, data1.c_str());
    //插入数据
    string data2="insert into my_table values(3, 'zhangfei', '11111111', '164438490@qq.com');";
    mysql_query(&mysql, data2.c_str());
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}


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


//修改数据
bool ModifyData(){
    //修改内容
    string query="UPDATE my_table SET email='166438490@qq.com' where name='liubei'";
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"修改数据失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }else{
        cout<<"数据修改成功！"<<endl;
    }
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}


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


//删除数据
bool DeleteData(){
    /*eg: "DELETE FROM my_table where id=2";*/
    string query="DELETE FROM my_table where id=2";
    cout<<"please input the sql:"<<endl;
    getline(cin,query);//这里手动输入sql语句
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"删除数据失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }else{
        cout<<"成功删除数据！"<<endl;
    }
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}


（6）释放资源


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


二、完整代码


#include<iostream>
#include<mysql.h>
#include<cstring>
#include<istream>
#include<vector>
using namespace std;
MYSQL mysql;            //mysql连接
MYSQL_FIELD*fd;         //字段列数组
char field[32][32];     //存字段名二维数组
MYSQL_RES *res;         //这个结构代表返回行的一个查询结果集
MYSQL_ROW column;       //一个行数据的类型安全(type-safe)的表示，表示数据行的列
bool ConnectDatabase(); //函数声明
void FreeConnect();
bool InsertData();      //增
bool ModifyData();      //改
bool DeleteData();      //删
int main(){
    ConnectDatabase();
    InsertData();
    ModifyData();
    DeleteData();
    mysql_close(&mysql);
    return 0;
}
//连接mysql并创建库和表
bool ConnectDatabase(){
    //初始化mysql连接
    mysql_init(&mysql);                 //等价于&mysql=mysql_init(NULL);
    const char host[]="localhost";
    const char user[]="root";
    const char psw[]="123456";
    //const char table[]="test";        //需要链接的数据库,如果已经创建了直接连接即可
    const int port =3306;
    //返回false则连接失败，返回true则连接成功
    if(!mysql_real_connect(&mysql, host, user, psw, NULL, port, NULL,0))
    {
        //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
        cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
        return false;
    }
    else
    {
        cout<<"Connected..."<<endl;
    }
    //-------------创建库-------------//
    char *drop_db_query = "DROP DATABASE IF EXISTS my_database";
    mysql_query(&mysql, drop_db_query);
    string db_name= "CREATE DATABASE IF NOT EXISTS my_database";
    //执行库创建语句，返回0表示执行成功，返回1表示执行失败
    int result=mysql_query(&mysql,db_name.c_str());
    if(result){
        cout<<"库创建失败！"<<endl;
        return false;
    }else{
        cout<<"student库创建成功......"<<endl;
    }
    // //-------------连接数据库-------------//
    // if(!mysql_real_connect(&mysql, host, user, psw, "my_database", port, NULL,0))
    // {
    //     //中间分别是主机，用户名，密码，数据库名，端口号(可以写默认0或者3306等)，可以先写成参数再传进去
    //     cout<<"Error connecting to database:"<<mysql_error(&mysql)<<endl;
    //     return false;
    // }
    // else
    // {
    //     cout<<"Connected..."<<endl;
    //     return true;
    // }
    //选择数据库
    if (mysql_select_db(&mysql, "my_database")) {
        cout<<"选择数据库失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    //-------------在my_database库中创建表-------------//
    char *drop_table_query = "DROP TABLE IF EXISTS my_table";
    mysql_query(&mysql, drop_table_query);
    string table="CREATE TABLE IF NOT EXISTS my_table (id int, name VARCHAR(20), number VARCHAR(20), email VARCHAR(20))";
    if (mysql_query(&mysql, table.c_str())) {
        cout << "user创建失败!" << mysql_error(&mysql) << endl;
        return false;
    }else{
        cout << "user创建成功......"<<endl;
    }
}
//释放资源
void FreeConnect(){
    mysql_free_result(res);     //释放一个结果集合使用的内存。
    mysql_close(&mysql);        //关闭一个服务器连接。
}
/******************************数程库操作***********************************/
//插入数据
bool InsertData(){
    //插入数据
    string query="INSERT INTO my_table (id, name, number, email) VALUES (1, 'liubei', '33333333', '165438490@qq.com')";
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"数据插入失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    else
    {
        cout<<"数据插入成功！"<<endl;
    }
    //插入数据
    string data1="insert into my_table values(2, 'guanyu', '22222222', '163438490@qq.com');";
    mysql_query(&mysql, data1.c_str());
    //插入数据
    string data2="insert into my_table values(3, 'zhangfei', '11111111', '164438490@qq.com');";
    mysql_query(&mysql, data2.c_str());
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}
//修改数据
bool ModifyData(){
    //修改内容
    string query="UPDATE my_table SET email='166438490@qq.com' where name='liubei'";
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"修改数据失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }else{
        cout<<"数据修改成功！"<<endl;
    }
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}
//删除数据
bool DeleteData(){
    /*eg: "DELETE FROM my_table where id=2";*/
    string query="DELETE FROM my_table where id=2";
    cout<<"please input the sql:"<<endl;
    getline(cin,query);//这里手动输入sql语句
    //执行SQL语句
    if(mysql_query(&mysql, query.c_str())){
        cout<<"删除数据失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }else{
        cout<<"成功删除数据！"<<endl;
    }
    // select and print data
    string query2 = "SELECT * FROM my_table";
    if (mysql_query(&mysql, query2.c_str())) {
        cout<<"数据查询失败！"<<mysql_error(&mysql)<<endl;
        return false;
    }
    MYSQL_RES *res = mysql_use_result(&mysql);
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(res)) != NULL) {
        cout<<row[0]<<"   "<<row[1]<<"   "<<row[2]<<"   "<<row[3]<<endl;
    }
    mysql_free_result(res);
}


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

文章标签：
云数据库 RDS MySQL 版
C++
关系型数据库
Linux
Windows
MySQL
数据库
分布式数据库
关键词：
数据库案例
云数据库 RDS MySQL 版案例
vscode编程
C++编程
vscode C++
相关实践学习
如何在云端创建MySQL数据库
开始实验后，系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
一米九零小胖子
目录
相关文章
1436047922066202
|
2月前
|
SQL 数据库
数据库数据恢复—SQL Server数据库报错“错误823”的数据恢复案例
SQL Server附加数据库出现错误823，附加数据库失败。数据库没有备份，无法通过备份恢复数据库。 SQL Server数据库出现823错误的可能原因有：数据库物理页面损坏、数据库物理页面校验值损坏导致无法识别该页面、断电或者文件系统问题导致页面丢失。
1436047922066202
103 12
数据库数据恢复—SQL Server数据库报错“错误823”的数据恢复案例
东方睿赢
|
24天前
|
存储 Java 关系型数据库
在Java开发中，数据库连接是应用与数据交互的关键环节。本文通过案例分析，深入探讨Java连接池的原理与最佳实践
在Java开发中，数据库连接是应用与数据交互的关键环节。本文通过案例分析，深入探讨Java连接池的原理与最佳实践，包括连接创建、分配、复用和释放等操作，并通过电商应用实例展示了如何选择合适的连接池库（如HikariCP）和配置参数，实现高效、稳定的数据库连接管理。
东方睿赢
44 2
1436047922066202
|
29天前
|
存储 数据挖掘 数据库
数据库数据恢复—SQLserver数据库ndf文件大小变为0KB的数据恢复案例
一个运行在存储上的SQLServer数据库，有1000多个文件，大小几十TB。数据库每10天生成一个NDF文件，每个NDF几百GB大小。数据库包含两个LDF文件。 存储损坏，数据库不可用。管理员试图恢复数据库，发现有数个ndf文件大小变为0KB。 虽然NDF文件大小变为0KB，但是NDF文件在磁盘上还可能存在。可以尝试通过扫描&拼接数据库碎片来恢复NDF文件，然后修复数据库。
1436047922066202
36 3
mzlogin
|
29天前
|
关系型数据库 MySQL 数据库
一个 MySQL 数据库死锁的案例和解决方案
本文介绍了一个 MySQL 数据库死锁的案例和解决方案。
mzlogin
65 3
java冯坚持
|
1月前
|
Java 数据库
案例一：去掉数据库某列中的所有英文，利用java正则表达式去做，核心：去掉字符串中的英文
这篇文章介绍了如何使用Java正则表达式从数据库某列中去除所有英文字符。
java冯坚持
50 15
1436047922066202
|
1月前
|
存储 Oracle 关系型数据库
数据库数据恢复—Oracle ASM磁盘组故障数据恢复案例
Oracle数据库数据恢复环境&故障： Oracle ASM磁盘组由4块磁盘组成。Oracle ASM磁盘组掉线 ，ASM实例不能mount。 Oracle数据库故障分析&恢复方案： 数据库数据恢复工程师对组成ASM磁盘组的磁盘进行分析。对ASM元数据进行分析发现ASM存储元数据损坏，导致磁盘组无法挂载。
1436047922066202
55 1
Dylaniou
|
1月前
|
Java 关系型数据库 MySQL
【编程基础知识】Eclipse连接MySQL 8.0时的JDK版本和驱动问题全解析
本文详细解析了在使用Eclipse连接MySQL 8.0时常见的JDK版本不兼容、驱动类错误和时区设置问题，并提供了清晰的解决方案。通过正确配置JDK版本、选择合适的驱动类和设置时区，确保Java应用能够顺利连接MySQL 8.0。
Dylaniou
168 1
1436047922066202
|
2月前
|
Oracle 关系型数据库 数据库
数据库数据恢复—Oracle数据库文件出现坏块的数据恢复案例
打开oracle数据库报错“system01.dbf需要更多的恢复来保持一致性，数据库无法打开”。 数据库没有备份，无法通过备份去恢复数据库。用户方联系北亚企安数据恢复中心并提供Oracle_Home目录中的所有文件，急需恢复zxfg用户下的数据。 出现“system01.dbf需要更多的恢复来保持一致性”这个报错的原因可能是控制文件损坏、数据文件损坏，数据文件与控制文件的SCN不一致等。数据库恢复工程师对数据库文件进一步检测、分析后，发现sysaux01.dbf文件损坏，有坏块。 修复并启动数据库后仍然有许多查询报错，export和data pump工具使用报错。从数据库层面无法修复数据库。
1436047922066202
77 7
数据库数据恢复—Oracle数据库文件出现坏块的数据恢复案例
1436047922066202
|
2月前
|
Oracle 关系型数据库 数据库
Oracle数据恢复—异常断电导致Oracle数据库数据丢失的数据恢复案例
Oracle数据库故障： 机房异常断电后，Oracle数据库启库报错：“system01.dbf需要更多的恢复来保持一致性，数据库无法打开”。数据库没有备份，归档日志不连续。用户方提供了Oracle数据库的在线文件，需要恢复zxfg用户的数据。 Oracle数据库恢复方案： 检测数据库故障；尝试挂起并修复数据库；解析数据文件。
1436047922066202
102 7
1436047922066202
|
2月前
|
存储 数据挖掘 数据库
服务器数据恢复—raid磁盘故障导致数据库数据损坏的数据恢复案例
存储中有一组由3块SAS硬盘组建的raid。上层win server操作系统层面划分了3个分区，数据库存放在D分区，备份存放在E分区。 RAID中一块硬盘的指示灯亮红色，D分区无法识别；E分区可识别，但是拷贝文件报错。管理员重启服务器，导致离线的硬盘上线开始同步数据，同步还没有完成就直接强制关机了，之后就没有动过服务器。
1436047922066202
63 4

热门文章

最新文章

  • 1
    测试开启MySQL performance_schema后对性能的影响
  • 2
    MySQL全文搜索与JSON支持：高效检索与灵活数据处理
  • 3
    JDBC操作MySQL5日期类型字段的问题解决方法
  • 4
    Mariadb/Mysql TEMPORARY表
  • 5
    MySQL的innodb_flush_log_at_trx_commit配置值的设定
  • 6
    JDBC 驱动升级到 Version 8.0.28 连接 MySQL 的踩坑记录
  • 7
    PG+MySQL第11课-多维向量搜索
  • 8
    FAQ系列 | 启用SELinux后，PHP连接MySQL异常
  • 9
    mysql合并查询(多张表) union 和 union all
  • 10
    mysql 数据类型
  • 1
    C++ 类构造函数 & 析构函数
    43
  • 2
    C++ this 指针详解
    37
  • 3
    C++友元函数和友元类
    47
  • 4
    从C++看编程语言发展脉络
    112
  • 5
    LabVIEW使用Python MathWorks® MATLAB®软件和C/C++
    65
  • 6
    LabVIEW传递接收C/C++DLL指针
    194
  • 7
    LabVIEW调用C/C++ DLLs
    114
  • 8
    C++中的栈和队列
    48
  • 9
    C++中的多态
    63
  • 10
    C++中的继承
    36

    • 相关课程

    更多
  • MySQL企业常见架构与调优经验分享
  • 云数据库MySQL版快速上手教程
  • 阿里云云原生数据仓库AnalyticDB MySQL版 使用教程
  • MySQL实战进阶
  • 数据库及SQL/MySQL基础
  • 云数据库MySQL快速入门

    • 相关电子书

    更多
  • 搭建电商项目架构连接MySQL
  • 搭建4层电商项目架构，实战连接MySQL
  • PolarDB MySQL引擎重磅功能及产品能力盛大发布

    • 相关实验场景

    更多
  • MySQL基础-学生管理系统数据库设计
  • 如何快速连接云数据库RDS MySQL
  • MySQL数据库快速部署实践
  • MySQL引擎及架构优化
  • 基于EBS部署高性能的MySQL服务
  • 使用CloudLens采集RDS日志并进行审计分析

    • 推荐镜像

    更多
  • mysql
  • mariadb
  • postgresql
    • 下一篇
    无影云桌面