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

简介: 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);
}


若有帮到你,点个赞,留下你的脚印哦!

相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发,帮助IT从业者们通过“阿里云Web应用上云解决方案”,了解一个企业级Web应用上云的常见架构,了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品:云数据库RDS MySQL 版 阿里云关系型数据库RDS(Relational Database Service)是一种稳定可靠、可弹性伸缩的在线数据库服务,提供容灾、备份、恢复、迁移等方面的全套解决方案,彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
相关文章
|
数据可视化 关系型数据库 MySQL
嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议数据可视化
通过本文的介绍,我们详细讲解了如何结合嵌入式C++、STM32、MySQL、GPS、InfluxDB和MQTT协议,实现数据的采集、传输、存储和可视化。这种架构在物联网项目中非常常见,可以有效地处理和展示实时数据。希望本文能帮助您更好地理解和应用这些技术,构建高效、可靠的数据处理和可视化系统。
922 82
|
Ubuntu Linux 编译器
Linux/Ubuntu下使用VS Code配置C/C++项目环境调用OpenCV
通过以上步骤,您已经成功在Ubuntu系统下的VS Code中配置了C/C++项目环境,并能够调用OpenCV库进行开发。请确保每一步都按照您的系统实际情况进行适当调整。
3365 3
|
Java 关系型数据库 MySQL
【编程基础知识】Eclipse连接MySQL 8.0时的JDK版本和驱动问题全解析
本文详细解析了在使用Eclipse连接MySQL 8.0时常见的JDK版本不兼容、驱动类错误和时区设置问题,并提供了清晰的解决方案。通过正确配置JDK版本、选择合适的驱动类和设置时区,确保Java应用能够顺利连接MySQL 8.0。
1326 1
|
Linux C语言 C++
vsCode远程执行c和c++代码并操控linux服务器完整教程
这篇文章提供了一个完整的教程,介绍如何在Visual Studio Code中配置和使用插件来远程执行C和C++代码,并操控Linux服务器,包括安装VSCode、安装插件、配置插件、配置编译工具、升级glibc和编写代码进行调试的步骤。
4548 0
vsCode远程执行c和c++代码并操控linux服务器完整教程
|
编译器 C++
【C++核心】指针和引用案例详解
这篇文章详细讲解了C++中指针和引用的概念、使用场景和操作技巧,包括指针的定义、指针与数组、指针与函数的关系,以及引用的基本使用、注意事项和作为函数参数和返回值的用法。
459 3
|
C++
【C++案例】一个项目掌握C++基础-通讯录管理系统
这篇文章通过一个通讯录管理系统的C++项目案例,详细介绍了如何使用C++实现添加、显示、删除、查找、修改和清空联系人等功能。
489 3
|
编解码 编译器 C++
VS Code C/C++ MSVC编译器
VS Code C/C++ MSVC编译器
464 2
|
NoSQL 编译器 C语言
VSCode配置配置C++环境
VSCode配置配置C++环境
758 1
|
C语言 C++
vscode——如何在vscode中运行C/C++
vscode——如何在vscode中运行C/C++
363 1
|
JavaScript 前端开发 测试技术
一个google Test文件C++语言案例
这篇文章我们来介绍一下真正的C++语言如何用GTest来实现单元测试。
303 0

热门文章

最新文章

推荐镜像

更多