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

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

2023-06-26 847
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL DuckDB 分析主实例，集群系列 4核8GB
RDS AI 助手，专业版
简介： 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 版案例
数据库案例
C++数据库
数据库编程
C++编程
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
一米九零小胖子
目录
相关文章
蓝易云
|
11月前
|
数据可视化 关系型数据库 MySQL
嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议数据可视化
通过本文的介绍，我们详细讲解了如何结合嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议，实现数据的采集、传输、存储和可视化。这种架构在物联网项目中非常常见，可以有效地处理和展示实时数据。希望本文能帮助您更好地理解和应用这些技术，构建高效、可靠的数据处理和可视化系统。
蓝易云
673 82
拂去尘世尘
|
安全 程序员 编译器
【实战经验】17个C++编程常见错误及其解决方案
想必不少程序员都有类似的经历：辛苦敲完项目代码，内心满是对作品品质的自信，然而当静态扫描工具登场时，却揭示出诸多隐藏的警告问题。为了让自己的编程之路更加顺畅，也为了持续精进技艺，我想借此机会汇总分享那些常被我们无意间忽视却又导致警告的编程小细节，以此作为对未来的自我警示和提升。
拂去尘世尘
1409 95
拂去尘世尘
|
存储 C++ UED
【实战指南】4步实现C++插件化编程，轻松实现功能定制与扩展
本文介绍了如何通过四步实现C++插件化编程，实现功能定制与扩展。主要内容包括引言、概述、需求分析、设计方案、详细设计、验证和总结。通过动态加载功能模块，实现软件的高度灵活性和可扩展性，支持快速定制和市场变化响应。具体步骤涉及配置文件构建、模块编译、动态库入口实现和主程序加载。验证部分展示了模块加载成功的日志和配置信息。总结中强调了插件化编程的优势及其在多个方面的应用。
拂去尘世尘
1327 164
平凡程序猿~
|
11月前
|
存储 缓存 C++
C++ 容器全面剖析：掌握 STL 的奥秘，从入门到高效编程
C++ 标准模板库（STL）提供了一组功能强大的容器类，用于存储和操作数据集合。不同的容器具有独特的特性和应用场景，因此选择合适的容器对于程序的性能和代码的可读性至关重要。对于刚接触 C++ 的开发者来说，了解这些容器的基础知识以及它们的特点是迈向高效编程的重要一步。本文将详细介绍 C++ 常用的容器，包括序列容器（`std::vector`、`std::array`、`std::list`、`std::deque`）、关联容器（`std::set`、`std::map`）和无序容器（`std::unordered_set`、`std::unordered_map`），全面解析它们的特点、用法
平凡程序猿~
681 1
C++ 容器全面剖析：掌握 STL 的奥秘，从入门到高效编程
羑悻的小杀马特
|
11月前
|
存储 机器学习/深度学习 编译器
【C++终极篇】C++11：编程新纪元的神秘力量揭秘
【C++终极篇】C++11：编程新纪元的神秘力量揭秘
羑悻的小杀马特
199 8
平凡程序猿~
|
11月前
|
存储 算法 C++
深入浅出 C++ STL：解锁高效编程的秘密武器
C++ 标准模板库（STL）是现代 C++ 的核心部分之一，为开发者提供了丰富的预定义数据结构和算法，极大地提升了编程效率和代码的可读性。理解和掌握 STL 对于 C++ 开发者来说至关重要。以下是对 STL 的详细介绍，涵盖其基础知识、发展历史、核心组件、重要性和学习方法。
平凡程序猿~
203 0
平凡程序猿~
|
11月前
|
存储 安全 算法
深入理解C++模板编程：从基础到进阶
在C++编程中，模板是实现泛型编程的关键工具。模板使得代码能够适用于不同的数据类型，极大地提升了代码复用性、灵活性和可维护性。本文将深入探讨模板编程的基础知识，包括函数模板和类模板的定义、使用、以及它们的实例化和匹配规则。
平凡程序猿~
242 0
潇洒洒
|
消息中间件 存储 安全
深入探索C++无锁队列：多线程编程的高效利器
【10月更文挑战第19天】
潇洒洒
1410 6
想飞的雪糕
|
前端开发 JavaScript 数据库
VSCode编程助手工程能力体验报告（一）：通义灵码 - 帮你高效切入新项目、编码和提升质量
我是一位软件工程师，用通义灵码个人版vscode插件的workspace做项目分析和复盘，对比之前没有灵码，现在提效了80%，本文介绍了具体的使用流程。
想飞的雪糕
3842 3