当前位置：首页 > news >正文

LinuxC++操作mysql数据库（#include ＜mysql/mysql.h＞的使用）

news 来源：原创 2024/5/23 18:27:44

mysql

安装

1.安装mysql c++库

sudo apt-get install libmysql++-dev
sudo systemctl mysql-server

2.安装mysql

sudo apt-get install mysql-server
sudo apt-get install mysql-client
systemctl status mysql.service #请检是否安装成功

mysql安装
sql语句

使用

进入mysql

sudo mysql -u root -p

创建数据库

CREATE TABLE `users`(`use` VARCHAR(50) NOT NULL COMMENT 'id',`pwd` VARCHAR(50) NOT NULL COMMENT 'passwd',PRIMARY KEY (`use`)
)ENGINE=INNODB DEFAULT CHARSET=utf8INSERT INTO `users`(`use`,`pwd`) VALUES ('aa' , 'bb'),('cc','dd');

常用操作

#include <stdio.h>
#include <list>
#include <mysql/mysql.h>
#include <error.h>
#include <string.h>
#include <iostream>
#include <string>using namespace std;int main()
{MYSQL *con = NULL;con = mysql_init(con);//初始化if (con == NULL){cout << "MySQL Error1";}string url = "localhost";    //主机地址unsigned int Port = 3306;   //数据库端口号string User = "root";   //登陆数据库用户名string PassWord = "123456";  //登陆数据库密码string DBName = "test_databace"; //使用数据库名//链接数据库con = mysql_real_connect(con, url.c_str(), User.c_str(), PassWord.c_str(), DBName.c_str(), Port, NULL, 0);if (con == NULL){cout << "MySQL Error2";}//执行sql语句，如果查询成功，mysql_query()函数会返回0；否则，返回非零值表示发生错误。mysql_query(con , "INSERT INTO `users`(`use`,`pwd`) VALUES ('add' , 'bbb');");mysql_query(con,"select * from users");MYSQL_RES *res;MYSQL_ROW row;//获得执行结果res = mysql_use_result(con);const char * csname = "utf8";mysql_set_character_set(con, csname);//获取字段个数，即查询获得的结果里有几列数据int nums = 0;  nums = mysql_num_fields(res);  //属于表结构的获取cout << nums << endl;MYSQL_FIELD * fields;fields = mysql_fetch_fields(res);  //属于表结构的获取for(int i = 0; i < nums ; i++){cout<<fields[i].name<<"|";}cout<<endl;while( (row = mysql_fetch_row(res)) != nullptr)  //mysql_fetch_row()函数从指定的结果集中获取一行数据返回给row，是数组的形式，即row内部是字符串数组指针（二级指针）{for(int i = 0; i < nums; i++){cout<<row[i]<<"|" ;}cout << endl;}mysql_free_result(res);mysql_close(con);
}

MYSQL_FILED

typedef struct MYSQL_FIELD {/* 列名 */char *name;/* 列的原始名称，如果该列是别名 */char *org_name;/* 如果列是一个字段，则为该字段所在表的名称 */char *table;/* 表的原始名称，如果表是别名 */char *org_table;/* 表所在的数据库名称 */char *db;/* 表所在的目录（在某些数据库系统中使用） */char *catalog;/* 字段的默认值，由mysql_list_fields设置 */char *def;/* 列的宽度（创建时定义的长度） */unsigned long length;/* 所选数据集中列的最大宽度 */unsigned long max_length;/* 列名的长度 */unsigned int name_length;/* 原始列名的长度 */unsigned int org_name_length;/* 表名的长度 */unsigned int table_length;/* 原始表名的长度 */unsigned int org_table_length;/* 数据库名称的长度 */unsigned int db_length;/* 目录名称的长度 */unsigned int catalog_length;/* 默认值的长度 */unsigned int def_length;/* 分区标志位 */unsigned int flags;/* 小数点后的位数，用于表示数字类型的精度 */unsigned int decimals;/* 字符集编号 */unsigned int charsetnr;/* 字段类型，枚举类型，具体类型参照mysql_com.h中的定义 */enum enum_field_types type;/* 扩展字段，可以用于实现特定扩展功能 */void *extension;
} MYSQL_FIELD;

编译

g++ $(mysql_config --cflags) main.cpp -o main $(mysql_config --libs)

cmake

set(CMAKE_CXX_FLAGS "-I/usr/include/mysql")
add_executable(main main.cpp)
target_link_libraries(main -L/usr/lib/x86_64-linux-gnu -lmysqlclient -lzstd -lssl -lcrypto -lresolv -lm)

数据结构

MYSQL

typedef struct MYSQL {/* 存储通信参数的结构体，包含网络连接细节 */NET net;/* SSL连接使用的文件描述符指针 */unsigned char *connector_fd;/* 数据库服务器地址字符串指针 */char *host;/* 数据库用户名字符串指针 */char *user;/* 密码字符串指针 */char *passwd;/* Unix域套接字路径字符串指针 */char *unix_socket;/* 服务器版本信息字符串指针 */char *server_version;/* 主机附加信息字符串指针 */char *host_info;/* 连接额外信息字符串指针 */char *info;/* 当前选中的数据库名称字符串指针 */char *db;/* 当前连接的字符集信息结构体指针 */struct CHARSET_INFO *charset;/* 查询结果字段数组指针 */MYSQL_FIELD *fields;/* 用于存储查询结果字段分配的内存管理器结构体 */struct MEM_ROOT *field_alloc;/* 受影响的行数 */uint64_t affected_rows;/* 最后一次插入操作生成的自动增长ID */uint64_t insert_id;/* 未使用的信息字段 */uint64_t extra_info;/* 服务端为该连接分配的线程ID */unsigned long thread_id;/* 数据包长度 */unsigned long packet_length;/* 数据库服务器端口 */unsigned int port;/* 客户端标志位，记录客户端特性 */unsigned long client_flag;/* 服务器能力标志位，记录服务器支持的功能 */unsigned long server_capabilities;/* 协议版本号 */unsigned int protocol_version;/* 查询结果字段数量 */unsigned int field_count;/* 服务器状态标志 */unsigned int server_status;/* 服务器语言设置 */unsigned int server_language;/* 警告计数 */unsigned int warning_count;/* MySQL连接选项结构体 */struct st_mysql_options options;/* 连接当前状态（如已连接、断开等） */enum mysql_status status;/* 结果集元数据获取方式 */enum enum_resultset_metadata resultset_metadata;/* 标记是否在mysql_close时释放此连接资源 */bool free_me;/* 标记是否启用自动重连功能 */bool reconnect;/* 会话级随机字符串，用于身份验证 */char scramble[SCRAMBLE_LENGTH + 1];/* 包含所有声明过的SQL语句的链表 */LIST *stmts;/* 指向一组用于与MySQL交互的方法的结构体 */const struct MYSQL_METHODS *methods;/* 指向MySQL服务器内部线程对象的指针 */void *thd;/* 指向一个布尔标志，用于指示结果集或语句的所有者是否取消了结果集 */bool *unbuffered_fetch_owner;/* 扩展字段，可以用于实现特定扩展功能 */void *extension;
} MYSQL;

MYSQL_RES

typedef struct MYSQL_RES {/* 结果集中行的数量 */uint64_t row_count;/* 结果集的字段信息数组指针，每个元素是一个MYSQL_FIELD结构体，描述一个字段 */MYSQL_FIELD *fields;/* 结果数据的实际存储结构体指针，包含记录内容 */struct MYSQL_DATA *data;/* 当前游标指向的结果集中当前行的数据指针 */MYSQL_ROWS *data_cursor;/* 当前行中各个字段值的长度数组，用于变长类型字段 */unsigned long *lengths;/* 指向产生此结果集的MYSQL连接句柄，对于非缓冲读取尤为重要 */MYSQL *handle;/* 结果集操作所使用的特定方法集合，如读取、释放等 */const struct MYSQL_METHODS *methods;/* 未缓冲读取时，指向当前行数据的指针 */MYSQL_ROW row;/* 缓存当前正在处理的行的内部缓冲区 */MYSQL_ROW current_row;/* 用于分配结果集中字段结构的空间的内存管理器 */struct MEM_ROOT *field_alloc;/* 结果集中字段总数 */unsigned int field_count;/* 当前指向的字段索引，在遍历结果集时使用 */unsigned int current_field;/* 标记是否已经到达结果集的末尾（eof：end of file） */bool eof;/* 如果mysql_stmt_close()取消了未完成的非缓冲读取，则设置为真 */bool unbuffered_fetch_cancelled;/* 结果集元数据获取方式 */enum enum_resultset_metadata metadata;/* 扩展字段，可以用于实现特定扩展功能 */void *extension;
} MYSQL_RES;

api

mysql_affected_rows() //返回被最新的UPDATE, DELETE或INSERT查询影响的行数。mysql_close() //关闭一个服务器连接。mysql_real_connect() //连接一个MySQL服务器mysql_change_user() //改变在一个打开的连接上的用户和数据库。mysql_create_db() //创建一个数据库。该函数不推荐；而使用SQL命令CREATE DATABASE。mysql_data_seek() //在一个查询结果集合中搜寻一任意行。mysql_debug() //用给定字符串做一个DBUG_PUSH。mysql_drop_db() //抛弃一个数据库。该函数不推荐；而使用SQL命令DROP DATABASE。mysql_dump_debug_info() //让服务器将调试信息写入日志文件。mysql_eof() //确定是否已经读到一个结果集合的最后一行。这功能被反对;
mysql_errno()或mysql_error()可以相反被使用。mysql_errno() //返回最近被调用的MySQL函数的出错编号。mysql_error() //返回最近被调用的MySQL函数的出错消息。mysql_escape_string() //用在SQL语句中的字符串的转义特殊字符。mysql_fetch_field() //返回下一个表字段的类型。mysql_fetch_field_direct() //返回一个表字段的类型，给出一个字段编号。mysql_fetch_fields() //返回一个所有字段结构的数组。mysql_fetch_lengths() //返回当前行中所有列的长度。mysql_fetch_row() //从结果集合中取得下一行。mysql_field_seek() //把列光标放在一个指定的列上。mysql_field_count() //返回最近查询的结果列的数量。mysql_field_tell() //返回用于最后一个mysql_fetch_field()的字段光标的位置。mysql_free_result() //释放一个结果集合使用的内存。mysql_get_client_info() //返回客户版本信息。mysql_get_host_info() //返回一个描述连接的字符串。mysql_get_proto_info() //返回连接使用的协议版本。mysql_get_server_info() //返回服务器版本号。mysql_info() //返回关于最近执行得查询的信息。mysql_init() //获得或初始化一个MYSQL结构。mysql_insert_id() //返回有前一个查询为一个AUTO_INCREMENT列生成的ID。mysql_kill() //杀死一个给定的线程。mysql_list_dbs() //返回匹配一个简单的正则表达式的数据库名。mysql_list_fields() //返回匹配一个简单的正则表达式的列名。mysql_list_processes() //返回当前服务器线程的一张表。mysql_list_tables() //返回匹配一个简单的正则表达式的表名。mysql_num_fields() //返回一个结果集合重的列的数量。mysql_num_rows() //返回一个结果集合中的行的数量。mysql_options() //设置对mysql_connect()的连接选项。
char value = 1;
int iOptions = mysql_options(&this->connObject, MYSQL_OPT_RECONNECT, &value); //解决8小时连接断开问题
if (iOptions != 0) {std::cout << "object mysql_options(MYSQL_OPT_RECONNECT) failed..." << std::endl;
}mysql_ping() //检查对服务器的连接是否正在工作，必要时重新连接。mysql_query() //执行指定为一个空结尾的字符串的SQL查询：
int mysql_query(MYSQL *mysql,const char *query) 返回值：查询成功返回0；查询出现错误返回非0mysql_real_connect() //连接一个MySQL服务器。
if(mysql_real_connect(&conn, "localhost", "mysql_user", "passwd", "database_name", 0, NULL, CLIENT_FOUND_ROWS))
{std::cout << "connect success..." << std::endl;
}mysql_real_query() //执行指定为带计数的字符串的SQL查询。mysql_reload() //告诉服务器重装授权表。mysql_row_seek() //搜索在结果集合中的行，使用从mysql_row_tell()返回的值。mysql_row_tell() //返回行光标位置。mysql_select_db() //连接一个数据库。mysql_shutdown() //关掉数据库服务器。mysql_stat() //返回作为字符串的服务器状态。mysql_store_result() //检索一个完整的结果集合给客户。mysql_thread_id() //返回当前线程的ID。mysql_use_result() //初始化一个一行一行地结果集合的检索。