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

【C++】开源：MySQL数据库安装与使用_c++ mysql

作者：不正经 | 2024-03-28 10:51:09

赞

踩

c++ mysql

文章目录

1. MySQL介绍

MySQL是一种开源的关系型数据库管理系统（RDBMS），广泛应用于各种规模和类型的应用程序中。以下是MySQL的一些主要特点和功能：

1.开源性：MySQL是开源软件，可以免费使用和修改，具有强大的社区支持。
2.可扩展性：MySQL支持高度可扩展的架构，适用于小型应用到大型企业级应用。
3.跨平台支持：MySQL可以在多个操作系统上运行，包括Windows、Linux、macOS等。
4.高性能：MySQL具有出色的性能和处理能力，能够处理大量的并发请求，并提供高效的查询和数据操作。
5.安全性：MySQL提供了多种安全机制来确保数据的机密性和完整性，包括用户身份验证、访问控制等。
6.支持标准SQL语言：MySQL遵循SQL标准，并提供了广泛的SQL功能，包括数据查询、更新、事务处理等。
7.多种存储引擎：MySQL支持多种存储引擎，如InnoDB、MyISAM等，每种引擎都有不同的特点和适用场景。
8.数据复制和高可用性：MySQL提供了复制功能，可以将数据复制到多个服务器以实现高可用性和数据备份。
9.数据库管理工具：MySQL提供了命令行工具和图形化管理工具（如Navicat、phpMyAdmin等），方便用户管理和监控数据库。

无论是小型网站还是大型企业应用，MySQL都是一个强大而可靠的选择。它广泛用于Web开发、数据分析、电子商务、日志存储等各种应用场景，被许多开发者和组织所采用和信赖。

2. Windows端

环境安装

安装mysql不再赘述。

windows下环境为：VS2017+mysql8.0.31

新建工程，然后将编译器配置为Release x64；

添加包含目录：

在这里插入图片描述

添加库目录：

在这里插入图片描述

添加附加依赖项（静态库）：

在这里插入图片描述

将libmysql.dll复制到工程所在目录：

在这里插入图片描述

测试程序：

#include <iostream>
#include "mysql.h"

using namespace std;

int main(int argc, char *argv[])
{
	///< 创建数据库句柄
	MYSQL mysql;
	//MYSQL *mysql = mysql_init(nullptr);

	///< 初始化句柄
	mysql_init(&mysql);

	///< 连接的数据库（句柄、主机名、用户名、密码、数据库名、端口号、socket指针、标记）
	if (!mysql_real_connect(&mysql, "localhost", "root", "root", "test_mysql", 3306, nullptr, 0))
	{
		cout << "数据库连接失败" << mysql_errno(&mysql) << endl;
		return -1;
	}

	cout << "数据库连接成功" << endl << endl;

	///< 创建数据库回应结构体
	MYSQL_RES *res = nullptr;
	///< 创建存放结果的结构体
	MYSQL_ROW row;

	char sql[1024]{ 0 };
	sprintf_s(sql, 1024, "select * from user_info");

	///< 调用查询接口
	if (mysql_real_query(&mysql, sql, (unsigned int)strlen(sql)))
	{
		cout << "查询失败" << ": " << mysql_errno(&mysql) << endl;
	}
	else
	{
		cout << "查询成功" << endl << endl;

		///< 装载结果集
		res = mysql_store_result(&mysql);

		if (nullptr == res)
		{
			cout << "装载数据失败" << ": " << mysql_errno(&mysql) << endl;
		}
		else
		{
			///< 取出结果集中内容
			while (row = mysql_fetch_row(res))
			{
				cout << row[0] << "  " << row[1] << endl;
			}
		}
	}

	///< 释放结果集
	mysql_free_result(res);

	///< 关闭数据库连接
	mysql_close(&mysql);

	system("pause");

	return 0;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67

数据库的基本操作

插入数据：

void insert(MYSQL* conn, int ID, char name[20], int age, float score)
//插入数据
{
	char str[64] = "INSERT INTO student VALUES( ";
	char buffer[128] = { 0 };
	char str2[4] = ",'";
	char str3[4] = "',";
	char str4[2] = ",";
	char str5[2] = ")";
	int len = sprintf_s(buffer, "%s%d%s%s%s%d%s%f%s", str, ID, str2, name, str3, age, str4, score, str5);
	mysql_query(&mysql, buffer);
	if (len < 0)
		cout << "存档失败！" << endl;
	if (len > 0)
		cout << "存档成功！" << endl;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16

删除数据：

void delete(char str2[])
//删除数据
{
	char str1[64] = "DELETE FROM student WHERE name='";
	char str3[10] = "'";
	char buffer[1024];
	int len = sprintf_s(buffer, "%s%s%s", str1, str2, str3);
	mysql_query(&mysql, buffer);
	if (len < 0)
		cout << "删除失败！" << endl;
	else
		cout << "删除成功！" << endl;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13

查询所有数据：

#include <mysql.h> // mysql文件
#include <iostream>
#include <cstring>
#include <stdio.h>
 
using namespace std;
 
MYSQL mysql;    //数据库句柄
MYSQL_RES* res; //查询结果集
MYSQL_ROW row;  //记录结构体
 
//查询全部数据并输出
void display()
{
	//查询数据
	int ret = mysql_query(&mysql, "select * from student;");
 
	//获取结果集
	res = mysql_store_result(&mysql);
 
	cout << "ID " << "name " << "age " << "score" << endl;
    //给ROW赋值，判断ROW是否为空，不为空就打印数据。
	while (row = mysql_fetch_row(res))
	{
		cout << row[0] << "  ";//打印ID
		cout << row[1] << "  ";//打印name
		cout << row[2] << "  ";//打印age
		cout << row[3] << endl;//打印score
	}
	//释放结果集
	mysql_free_result(res);
 
	//关闭数据库
	mysql_close(&mysql);
}
 
int main()
{
	//初始化数据库
	mysql_init(&mysql);
 
	//设置字符编码
	mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "gbk");
 
	//连接数据库
	if (mysql_real_connect(&mysql, "localhost", "root", "root", "student", 3306, NULL, 0) == NULL) 
    //localhost为服务器，root为用户名和密码，school为数据库名，3306为端口
    {
		printf("错误原因： %s\n", mysql_error(&mysql));
		printf("连接失败！\n");
		exit(-1);
	}
 
 	// 显示数据库
    display();
 
    //关闭数据库
	mysql_close(&mysql);
	return 0;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60

查询指定数据并转换为int或float类型：

//查询特定数据
void select(int& ID, char str[], int& age, float& score)
{
	char str1[64] = "SELECT * FROM student WHERE NAME='";
	char str2[2] = "'";
	char buffer[1024];//缓冲区数组
 
	sprintf_s(buffer, "%s%s%s", str1, str, str2);
	mysql_query(&mysql, buffer);
	res = mysql_store_result(&mysql);
	//给ROW赋值，判断ROW是否为空，不为空就打印数据。
	while (row = mysql_fetch_row(res))
	{
		ID = atoi(row[0]);
		age = atoi(row[2]);
		score = atof(row[3]);
		cout <<"ID=" << ID << " name=" << row[1] <<  " age=" << age << " score=" << score << endl;
	}
	//释放结果集
	mysql_free_result(res);
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21

更新数据：

void update(MYSQL* conn, int ID, char name[20], int age, float score)
//更新数据
{
	char str[64] = "UPDATE student SET ID=";
	char buffer[128] = { 0 };
	char str2[16] = ",age=";
	char str3[16] = ",score=";
	char str4[32] = " WHERE name='";
	char str5[10] = "'";
	int len = sprintf_s(buffer, "%s%d%s%d%s%f%s%s%s", str, ID, str2, age, str3, score, str4, name, str5);
	mysql_query(&mysql, buffer);
	if (len < 0)
		cout << "修改失败！" << endl;
	if (len > 0)
		cout << "修改成功！" << endl;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16

3. Ubuntu端

环境安装

安装mysql：sudo apt install mysql-server

验证安装成功：sudo systemctl status mysql 或 mysql -V

# 管理员进入mysql
sudo mysql
# 给root用户设置密码
ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'new_password';
FLUSH PRIVILEGES;	# 刷新
EXIT;	# 退出
# 允许任意host访问（如果只允许某个ip访问，则可以改成相应的ip）
mysql -uroot -p
use mysql;
update user set host = '%' where user = 'root';
select host, user from user;
flush privileges;
exit;

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13

然后就可以用navicat连接ubuntu端的mysql了（配置ssh和mysql信息）：

在这里插入图片描述
在这里插入图片描述
Navicat可以方便地对数据库进行可视化操作，例如从excel导入数据到表，运行sql语句增删查改等。

在这里插入图片描述

安装c++支持库：sudo apt-get install libmysqlclient-dev libmysqlcppconn-dev

测试程序：

#include <mysql_connection.h>
#include <mysql_driver.h>
#include <cppconn/driver.h>

using namespace sql;
using namespace std;

#define DBHOST "tcp://127.0.0.1:3306"
#define USER "root"
#define PASSWORD "xxx"

int main()
{
    Driver *driver;
    Connection *conn;
    driver = get_driver_instance();
    conn = driver->connect(DBHOST, USER, PASSWORD);
    cout << "DataBase connection autocommit mode = " << conn->getAutoCommit() << endl;
    delete conn;
    driver = NULL;
    conn = NULL;
    return 0;
}

  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

编译运行：

g++ -o main main.cpp -lmysqlcppconn
# DataBase connection autocommit mode = 1

  • 1
  • 2

数据库的基本操作

#include <iostream>
#include <mysql/mysql.h>

using namespace std;

// sql_create 创建数据库
int sql_create()
{
    MYSQL mysql;
    mysql_init(&mysql);
    if (!mysql_real_connect(&mysql, "localhost", "root", "wangzf123", 0, 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(&mysql) << " "
             << mysql_errno(&mysql) << endl;
        return -1;
    }

    // run mysql sentence
    string str = "create database school;";
    mysql_real_query(&mysql, str.c_str(), str.size());

    str = "alter database school charset=utf8mb4;";
    mysql_real_query(&mysql, str.c_str(), str.size());

    str = "create table school.students(id int(10) primary key auto_increment, name varchar(20) not null, age int(3) not null);";
    mysql_real_query(&mysql, str.c_str(), str.size());

    mysql_close(&mysql);
    return 0;
}

// sql_add 增加数据
int sql_add()
{
    MYSQL mysql;
    mysql_init(&mysql);
    mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "utf8mb4");
    mysql_options(&mysql, MYSQL_INIT_COMMAND, "SET NAMES utf8mb4");

    if (!mysql_real_connect(&mysql, "localhost", "root", "wangzf123", "school", 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(&mysql) << " "
             << mysql_errno(&mysql);
        return -1;
    }

    string str = "insert into students(id, name, age) values(null, \'小明\', 30)";
    mysql_real_query(&mysql, str.c_str(), str.size());
    str = "insert into students(id, name, age) values(null, \'小红\', 28)";
    mysql_real_query(&mysql, str.c_str(), str.size());
    str = "insert into students(id, name, age) values(null, \'小白\', 33)";
    mysql_real_query(&mysql, str.c_str(), str.size());
    str = "insert into students(id, name, age) values(null, \'小黑\', 29)";
    mysql_real_query(&mysql, str.c_str(), str.size());
    str = "insert into students(id, name, age) values(null, \'小黄（哥）\', 29)";
    mysql_real_query(&mysql, str.c_str(), str.size());

    mysql_close(&mysql);
    return 0;
}

// sql_modify 修改数据
int sql_modify()
{
    MYSQL mysql;
    mysql_init(&mysql);
    mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "utf8mb4");
    mysql_options(&mysql, MYSQL_INIT_COMMAND, "SET NAMES utf8mb4");

    if (!mysql_real_connect(&mysql, "localhost", "root", "wangzf123", "school", 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(&mysql) << " "
             << mysql_errno(&mysql);
        return -1;
    }

    string str = "update students set age = 35 where name = \'小明\'";
    mysql_real_query(&mysql, str.c_str(), str.size());

    mysql_close(&mysql);
    return 0;
}

// sql_delete 删除数据
int sql_delete()
{
    MYSQL mysql;
    mysql_init(&mysql);
    mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "utf8mb4");
    mysql_options(&mysql, MYSQL_INIT_COMMAND, "SET NAMES utf8mb4");

    if (!mysql_real_connect(&mysql, "localhost", "root", "wangzf123", "school", 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(&mysql) << " "
             << mysql_errno(&mysql);
        return -1;
    }

    string str = "delete from students where name = \'小明\'";
    mysql_real_query(&mysql, str.c_str(), str.size());

    mysql_close(&mysql);
    return 0;
}

// sql_query1 查询数据1
int sql_query1()
{
    MYSQL mysql;
    mysql_init(&mysql);
    mysql_options(&mysql, MYSQL_SET_CHARSET_NAME, "utf8mb4");
    mysql_options(&mysql, MYSQL_INIT_COMMAND, "SET NAMES utf8mb4");

    if (!mysql_real_connect(&mysql, "localhost", "root", "wangzf123", "school", 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(&mysql) << " "
             << mysql_errno(&mysql);
        return -1;
    }

    string str = "select * from students;";
    mysql_real_query(&mysql, str.c_str(), str.size());
    MYSQL_RES *result = mysql_store_result(&mysql);

    MYSQL_ROW row;
    while (row = mysql_fetch_row(result))
    {
        cout << "id: " << row[0] << " name: " << row[1] << " age: " << row[2]
             << endl;
    }

    mysql_free_result(result);
    mysql_close(&mysql);
    return 0;
}

// sql_query2 查询数据2
int sql_query2()
{
    MYSQL *conn = mysql_init(NULL);
    mysql_options(conn, MYSQL_SET_CHARSET_NAME, "utf8mb4");
    mysql_options(conn, MYSQL_INIT_COMMAND, "SET NAMES utf8mb4");

    if (!mysql_real_connect(conn, "localhost", "root", "wangzf123", "school", 3306,
                            NULL, 0))
    {
        cout << "mysql connect error: " << mysql_error(conn) << " "
             << mysql_errno(conn);
        return -1;
    }

    char sql[1024];
    int cool = 30;
    sprintf(sql, "select * from students where age < %d", cool);
    if (mysql_query(conn, sql))
    {
        cout << "mysql connect error: " << mysql_error(conn) << " "
             << mysql_errno(conn);
        mysql_close(conn);
        return -1;
    }

    MYSQL_RES *result = mysql_store_result(conn);

    MYSQL_ROW row;
    while (row = mysql_fetch_row(result))
    {
        cout << "id: " << row[0] << " name: " << row[1] << " age: " << row[2]
             << endl;
    }

    mysql_free_result(result);
    mysql_close(conn);
    return 0;
}

int main()
{
    cout << "创建数据库..." << endl;
    sql_create();
    cout << "添加数据..." << endl;
    sql_add();
    cout << "查询数据..." << endl;
    sql_query1();
    cout << "修改数据..." << endl;
    sql_modify();
    cout << "查询数据..." << endl;
    sql_query1();
    cout << "删除数据..." << endl;
    sql_delete();
    cout << "查询数据..." << endl;
    sql_query1();
    cout << "条件查询数据..." << endl;
    sql_query2();

    return 0;
}


  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78
  • 79
  • 80
  • 81
  • 82
  • 83
  • 84
  • 85
  • 86
  • 87
  • 88
  • 89
  • 90
  • 91
  • 92
  • 93
  • 94
  • 95
  • 96
  • 97
  • 98
  • 99
  • 100
  • 101
  • 102
  • 103
  • 104
  • 105
  • 106
  • 107
  • 108
  • 109
  • 110
  • 111
  • 112
  • 113
  • 114
  • 115
  • 116
  • 117
  • 118
  • 119
  • 120
  • 121
  • 122
  • 123
  • 124
  • 125
  • 126
  • 127
  • 128
  • 129
  • 130
  • 131
  • 132
  • 133
  • 134
  • 135
  • 136
  • 137
  • 138
  • 139
  • 140
  • 141
  • 142
  • 143
  • 144
  • 145
  • 146
  • 147
  • 148
  • 149
  • 150
  • 151
  • 152
  • 153
  • 154
  • 155
  • 156
  • 157
  • 158
  • 159
  • 160
  • 161
  • 162
  • 163
  • 164
  • 165
  • 166
  • 167
  • 168
  • 169
  • 170
  • 171
  • 172
  • 173
  • 174
  • 175
  • 176
  • 177
  • 178
  • 179
  • 180
  • 181
  • 182
  • 183
  • 184
  • 185
  • 186
  • 187
  • 188
  • 189
  • 190
  • 191
  • 192
  • 193
  • 194
  • 195
  • 196
  • 197
  • 198
  • 199
  • 200
  • 201
  • 202
  • 203

编译运行：

g++ -o main main.cpp -lmysqlclient
./main

  • 1
  • 2

在这里插入图片描述

以上。

本文内容由网友自发贡献，转载请注明出处：https://www.wpsshop.cn/w/不正经/article/detail/329679
推荐阅读
相关标签

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

  

闽ICP备14008679号