Linux高级系统编程-MySQL，使用C语言操作MySQL

发布时间：2023年12月18日

API

初始化

所需头文件
????????#include <mysql/mysql.h>
函数 :
????????MYSQL *mysql_init(MYSQL *mysql)
描述：
????????分配或初始化与mysql_real_connect() 相适应的 MYSQL 对象
参数：
????????mysql:MYSQL*句柄
返回值：
????????初始化的MYSQL* 句柄。如果无足够内存以分配新的对象，返回 NULL 。

设置编码

函数 :
????????int mysql_set_character_set(MYSQL *mysql, const char *csname);
参数 :
????????mysql:MYSQL*句柄
????????csname:编码格式
如 :
????????mysql_set_character_set(&mysql,"utf8");

获取连接

所需头文件
????????#include <mysql/mysql.h>
函数 :
????????MYSQL *mysql_real_connect(MYSQL *mysql,
????????????????const char *host,
????????????????const char *user,
????????????????const char *passwd,
????????????????const char *db,
????????????????unsigned int port,
????????????????const char *unix_socket,
????????????????unsigned long client_flag)
描述 :
????????mysql_real_connect()尝试与运行在主机上的 MySQL 数据库引擎建立连接。
参数 :
????????mysql:MySQL句柄
????????host:“host”的值必须是主机名或 IP 地址 . 如果 “host” 是 NULL 或字符 串"localhost" 、 ”127.0.0.1” ，连接将被视为与本地主机的连接 .
????????user:MySQL登录的用户名
????????passwd: MySQL登录的密码
????????db:数据库名称
????????port:MySQL服务器监听客户端连接到来的端口号（默认： 3306 ）
????????unix_socket：如果 unix_socket 不是 NULL ，该字符串描述了应使用的套接字或命名管 道（默认为NULL ）
????????client_flag: 通常为 0 ，可以更改其值，以允许特定功能（详情见手册）
返回值：
????????如果连接成功，返回MYSQL* 连接句柄。返回值与第 1 个参数的值相同。
????????如果连接失败，返回NULL 。

执行SQL语句

无操作结果:如建库,建表,增加,删除,修改等语句

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????int mysql_real_query(MYSQL *mysql,const char * query,unsigned long length)
描述 :
????????执行由“query” 指向的 SQL 查询 , 它应是字符串长度字节 “long”. 正常情况下 , 字符 串必须包含1 条 SQL 语句 , 而且不应为语句添加终结分号（ ‘;’ ）或 “\g”. 如果允许多语句 执行, 字符串可包含由分号隔开的多条语句 .
参数 :
????????mysql:MySQL句柄
????????query:需要执行的 MySQL 语句
????????length:需要执行的 MySQL 语句的长度
返回值 :
????????如果查询成功，返回0 。
????????如果查询失败，返回非0 值

有操作结果:如查询语句

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????MYSQL_RES *mysql_store_result(MYSQL *mysql)
描述：
????????对于成功检索了数据的每个查询（SELECT 、 SHOW 、 DESCRIBE 、 EXPLAIN 、 CHECK TABLE等），必须调 用 mysql_store_result() 或 mysql_use_result() 。 对于其他查询，不需要调用mysql_store_result() 或 mysql_use_result() ，但是如果在任何 情况下均调用 了mysql_store_result() ，它也不会导致任何伤害或性能降低。通过检查mysql_store_result() 是否返回 0 ，可检测查询 是否没有结果集（以后会更多）
参数 :
????????Mysql:MySQL句柄
返回值 :
????????成功 返回具有多个结果的MYSQL_RES 结果集合。
????????失败 返回NULL

查询结果集

获取结果集中的列数

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????unsigned int mysql_num_fields(MYSQL_RES *result)
描述 :
????????返回结果集中的列数
参数 :
????????result:MYSQL_RES结果集句柄
返回值 :
????????表示结果集中行数的无符号整数

获取结果集中的行数

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????my_ulonglong mysql_num_rows(MYSQL_RES *result)
描述 :
????????返回结果集中的行数
参数 :
????????result:MYSQL_RES结果集句柄
返回值 :
????????结果集中的行数

获取结果集中的列名称

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????MYSQL_FIELD * mysql_fetch_field(MYSQL_RES *result)
描述 :
????????返回采用MYSQL_FIELD 结构的结果集的列。重复调用该函数，以检索关于结果集中 所有列的信息。未剩余字段时，mysql_fetch_field() 返回 NULL 。
参数 :
????????result:MYSQL_RES结果集句柄
返回值 :
????????当前列的MYSQL_FIELD 结构。如果未剩余任何列，返回 NULL

获取结果集中的每列数据（重要）

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)
描述 :
????????检索结果集的下一行。在mysql_store_result() 之后使用时，如果没有要检索的 行，mysql_fetch_row() 返回 NULL
参数 :
????????MYSQL_RES结果集句柄
返回值 :
????????下一行的MYSQL_ROW 结构。如果没有更多要检索的行或出现了错误，返回 NULL

释放资源

释放结果集

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????void mysql_free_result(MYSQL_RES *result)
描述 :
????????释放由mysql_store_result() 、 mysql_use_result() 、 mysql_list_dbs() 等 为结果集分配的内存。完成对结果集的操作后，必须调用mysql_free_result() 释放结 果集使用的内存
参数 :
????????MYSQL_RES结果集句柄
返回值 :
????????无

释放MySQL句柄

所需头文件 :
????????#include <mysql/mysql.h>
函数 :
????????void mysql_close(MYSQL *mysql)
描述 :
????????关闭前面打开的连接。如果句柄是由mysql_init() 或 mysql_connect() 自动分配 的，mysql_close() 还将解除分配由 mysql 指向的连接句柄
参数 :
????????MySQL连接句柄
返回值 :
????????无

示例

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <mysql/mysql.h>
int main(int argc, char const *argv[])
{
    MYSQL mysql, *sock;
    //初始化数据库环境
    mysql_init(&mysql);
    //设置编码格式
    mysql_set_character_set(&mysql,"utf8");
    //连接数据库
    sock = mysql_real_connect(&mysql, "192.168.0.120", "root", "123456",
    "mytest", 3306, NULL, 0);
    if (sock == NULL)
    {
        perror("连接失败\n");
        return 0;
    }
    printf("连接成功\n");
    // // 执行MySQL语句
    // char *sql_str = "insert into person (pname,psex,pclass)
    values('bob','男','class_A')";
    // int ret = mysql_real_query(&mysql, sql_str, strlen(sql_str));
    // if (ret != 0)
    // {
        // perror("mysql_query");
        // return 0;
    // }
    //获取MySQL执行语句的结果
    char *sql_str = "select * from person";
    mysql_query(&mysql,sql_str);
    MYSQL_RES *res = mysql_store_result(&mysql);
    if (res == NULL)
    {
        printf("为空");
        return 0;
    }
    //获取结果集中的列数(字段数)
    //获取结果集中的行数、列数
    int column = mysql_num_fields(res);
    int row = mysql_num_rows(res);
    for(int i = 0; i < row; i++)
    {
        MYSQL_ROW row_data = mysql_fetch_row(res);
        for(int j = 0; j < column; j++)
        {
            printf("%s\t",row_data[j]);
        }
        printf("\n");
    }
    //释放结果
    mysql_free_result(res);
    //关闭连接
    mysql_close(sock);
    return 0;
}

文章来源:https://blog.csdn.net/weixin_50963877/article/details/135071739
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
最新文章