mysql_init()
MYSQL *
mysql_init(MYSQL *mysql)
分配或初始化一个 MYSQL 对象,用于 mysql_real_connect() 。
如果 mysql 为 NULL 则分配对象。否则初始化 mysql。
成功则返回 MYSQL 对象的地址。失败返回 NULL。
mysql_real_connect()
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)
host 主机名或 IP 地址
db 数据库名
port 如果为 0,则其值像 tcp 连接的端口号
unix_socket 通常为 NULL
client_flag 通常为 0
成功执行,返回 0
mysql_close()
void mysql_close(MYSQL *mysql)
关闭连接。如果之前使用 mysql_init 分配了 MYSQL 对象,就释放它
mysql_query()
int mysql_query(MYSQL *mysql, const char *stmt_str)
执行 stmt_str 字符串上的 sql 语句,成功执行返回 0
mysql_store_result()
MYSQL_RES *
mysql_store_result(MYSQL *mysql)
void
mysql_free_result(MYSQL_RES *result)
返回一个包含结果的结构体指针
如果 sql 语句不返回数据或有错误,则 mysql_store_result 返回 NULL
使用 mysql_free_resule 释放结构体
mysql_fetch_fields()
MYSQL_FIELD *
mysql_fetch_fields(MYSQL_RES *result)
Example
unsigned int num_fields;
unsigned int i;
MYSQL_FIELD *fields;
num_fields = mysql_num_fields(result);
fields = mysql_fetch_fields(result);
for(i = 0; i < num_fields; i++)
{
printf("Field %u is %s\n", i, fields[i].name);
}
返回一个 MYSQL_FIELD 结构体数组,一个 MYSQL_FIELD 对应一列的名字
如果结果集里面没有数据则返回 NULL
##fetch 是拿来的意思。可以把 field 认为是列名##
##貌似不用释放 MYSQL_FIELD 指针##
mysql_fetch_row()
MYSQL_ROW
mysql_fetch_row(MYSQL_RES *result)
Example
MYSQL_ROW row;
unsigned int num_fields;
unsigned int i;
num_fields = mysql_num_fields(result);
while ((row = mysql_fetch_row(result)))
{
unsigned long *lengths;
lengths = mysql_fetch_lengths(result);
for(i = 0; i < num_fields; i++)
{
printf("[%.*s] ", (int) lengths[i],
row[i] ? row[i] : "NULL");
}
printf("\n");
}
mysql_fetch_row() 检索结果集的下一行
当在 mysql_store_result() 或 mysql_store_result_nonblocking() 之后使用时,如果没有更多的行需要检索,mysql_fetch_row() 将返回 NULL
如果有数据,则存储在 MYSQL_ROW 结构体中
##因为是自动变量,随意不需要释放##
简单实例
#include <stdio.h> #include <mysql.h> #include <string.h> int Query(MYSQL *mysql) { MYSQL_RES * result; MYSQL_ROW row; MYSQL_FIELD * fields; unsigned int num_fields; const char *mquery = "select * from customers";; if(mysql_query(mysql, mquery)) { fprintf(stderr, "%s\n\n", mysql_error(mysql)); return -1; } result = mysql_store_result(mysql); if(result == NULL) { fprintf(stderr, "%s\n", mysql_error(mysql)); return -1; } num_fields = mysql_num_fields(result); fields = mysql_fetch_fields(result); for(int i = 0; i < num_fields; i++) printf("%s ", fields[i].name); printf("\n"); while((row = mysql_fetch_row(result))){ for(int i = 0; i < num_fields; i++) printf("%s ",row[i] ? row[i] : "NULL"); printf("\n"); } mysql_free_result(result); return 0; } int main() { MYSQL mysql; mysql_init(&mysql); if(!mysql_real_connect(&mysql,"localhost","niko","123456","anwei",0,NULL,0)) { fprintf(stderr, "Failed to connect to database: Error: %s\n", mysql_error(&mysql)); return -1; } Query(&mysql); mysql_close(&mysql); return 0; }