c语言连接MySQL

安装开发c/c++的库：apt install libmysqlclient-dev

1. 连接数据库使用的头文件和库文件

#include <mysql/mysql.h>
有些也在 #include <mysql.h>
程序中使用了访问mysql的有关函数接口，需要在链接时指定库名: linux平台为 -lmysqlclient

2、初始化连接句柄

MYSQL *mysql_init(MYSQL *mysql);
该方法用来初始化一个连接句柄，如果参数为空，则返回一个指向新分配的连接句柄的指针。如果传递一个已
有的结构，它将被重新初始化。出错时返回为NULL。

3. 连接数据库

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 clientflag);
参数介绍，其中
mysql是上一步mysql_init方法初始化后返回的指针，
host是主机名，或者连接的服务器IP地址，本地可以使用"localhost"，或"127.0.0.1"或""，或
NULL
user是用户名，数据库中添加的用户，管理员是"root"，
passwd 是用户的密码,
db 是数据库的名字，
port 是数据库的端口 3306，也可直接写0，意味着使用mysql默认端口，
unix_socket 一般为NULL,表示不使用unix套接字或者管道
clientflag 标志位，一般给0
返回值，失败为NULL,成功与第一个参数值相同。

4. 关闭连接

void mysql_close(MYSQL *mysql);
在不使用时，可以用该方法关闭连接。

5. 执行sql语句

int mysql_query(MYSQL *mysql, const char *q);
参数: mysql 是之前连接后返回的指针，
	  q 是要执行的sql语句，末尾可以没有分号，这个在命令工具中使用不同。
返回值：成功返回0。
注意:如果sql语句中有二进制数据，则应该使用mysql_real_query();

6. 提取结果

MYSQL_RES *mysql_store_result(MYSQL *mysql); 一次性提取所有数据
//MYSQL_RES *mysql_use_result(MYSQL *mysql);一次提取一行数据q

该方法，是在执行 mysql_query()成功之后调用的，可以立刻保存在客户端中收到的所有数据。
它返回一个指向结果集结构的指针。如果失败返回NULL;

7. 获取结果集中有多少行

uint64_t mysql_num_rows(MYSQL_RES *res);
只有执行了 mysql_store_result()之后,才可以调用该方法，获取结果集中的行数。如果没有返回行，则为0;

8. 取出结果集中的一行记录

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
从结果集中取出一行，并把它存放到一个行结构中。当数据用完或者出错时，返回为NULL，通常该方法需要循环调用。

9. 查看记录行的列数

unsigned int mysql_field_count(MYSQL *mysql);

10. 释放结果集占用的内存

void mysql_free_result(MYSQL_RES *result);
执行完sql语句，得到返回的结果集，处理完数据后，需要调用该方法释放存放结果集的内存空间。

11. 获取错误信息

unsigned int mysql_errno(MYSQL *mysql); 返回错误码
const char *mysql_error(MYSQL *mysql); 返回错误信息描述

12. 连接测试程序

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

int main(){
    MYSQL connect;//mysql连接对象
    mysql_init(&connect);
    //连接到mysql
    if(mysql_real_connect(&connect,"localhost","root","root","test",3306,NULL,0)){   
        printf("连接mysql成功\n");
    }else{
        printf("err:%s\n",mysql_error(&connect));
        printf("连接mysql失败\n");
    }
    //关闭mysql连接
    mysql_close(&connect);
    return 0;
}

增加、修改、删除的程序

仅仅是SQL语句不同

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <mysql/mysql.h>

int main(){
    MYSQL* conn = mysql_init(NULL);

    if(NULL == conn){
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }

    //连接到mysql
	if(mysql_real_connect(conn,"localhost","root","root","testdb",3306,NULL,0)){   
        printf("连接mysql成功\n");
    }else{
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }

    char sql[128] = {0};
    // sprintf(sql, "insert into stu values(%s, %d)", "\"小李\"", 23);
    // sprintf(sql, "update stu set age = %d where name = %s", 30, "\'小张\'");
    sprintf(sql, "delete from stu where name = %s", "\'小张\'");
    
    int res = mysql_query(conn, sql);
    if(0 != res){
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }
    printf("sql执行成功\n");

    //关闭mysql连接
    mysql_close(conn);
    return 0;
}

查询的程序

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <mysql/mysql.h>

int main(){
    MYSQL* conn = mysql_init(NULL);

    if(NULL == conn){
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }

    //连接到mysql
    if(mysql_real_connect(conn,"localhost","root","root","testdb",3306,NULL,0)){   
        printf("连接mysql成功\n");
    }else{
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }

    char sql[128] = {0};
    sprintf(sql, "select * from stu");
    int res = mysql_query(conn, sql);

    if(0 != res){
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }
    printf("sql执行成功\n");

    // 获取结果集
    MYSQL_RES* mysql_res = mysql_store_result(conn);
    if(NULL == mysql_res){
        printf("err:%s\n",mysql_error(conn));
        exit(0);
    }

    // 获取记录条数以及属性个数
    int num = mysql_num_rows(mysql_res);
    int column = mysql_field_count(conn);
    if(0 ==  num){
        printf("没有查询到信息\n");
        exit(0);
    }
    printf("查询到%d条信息， 每条信息有%d个属性\n", num, column);
    
    // 循环打印获取的记录
    for(int i = 0; i < num; i++){
        MYSQL_ROW mysql_row = mysql_fetch_row(mysql_res);
        if(NULL == mysql_row){
            printf("数据处理完成\n");
        }
        for(int j = 0; j < column; j++){
            printf("%s ", mysql_row[j]);
        }
        printf("\n");
    }
    // 释放结果集
    mysql_free_result(mysql_res);
    //关闭mysql连接
    mysql_close(conn);
    return 0;
}