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=utf8
INSERT 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；查询出现错误返回非0
mysql_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() //初始化一个一行一行地结果集合的检索。
from