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;
}