API介绍:
1.MYSQL *mysql_init(MYSQL *mysql)
描述:
分配或初始化与mysql_real_connect()相适应的MYSQL对象。
如果mysql是NULL指针,该函数将分配、初始化、并返回新对象。
否则,将初始化对象,并返回对象的地址。
如果mysql_init()分配了新的对象,当调用mysql_close()来关闭连接时。将释放该对象。
返回值:初始化的MYSQL*句柄;也可以将MYSQL的实例地址给这个函数,直接让它初始化实例。
2.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数据库;
第一个参数是MYSQL*类型的指针,这个参数必须是经过mysql_init()初始化过的。
第二个参数是数据库地址,如果是NULL或者localhost 则连接本地数据库;
第三个参数是数据库用户名;
第四个参数是数据库密码;
第五个参数是数据库名称(具体要操作的数据库名称);
第六个参数是数据库端口号;
第七个参数描述的是套接字或者命名管道, 如果使用TCP/IP协议链接数据库,则此参数为NULL
第八个参数通常为0;
返回值:
如果连接成功,返回MYSQL*连接句柄。如果连接失败,返回NULL。对于成功的连接,返回值与第1个参数的值相同。
3.int mysql_query(MYSQL *mysql, const char *query)
描述:执行由“Null终结的字符串”查询指向的SQL查询。正常情况下,字符串必须包含1条SQL语句,而且不应为语句添加终结分号(‘;’)或“\g”。
如果允许多语句执行,字符串可包含多条由分号隔开的语句。
第一个参数是mysql实例的地址,
第二个参数是要执行的sql语句,select,update,delete,insert ...
返回值:
如果查询成功,返回0。如果出现错误,返回非0值。
4. 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_RES结果集合。如果出现错误,返回NULL
5.my_ulonglong mysql_num_rows(MYSQL_RES *result)
描述:
返回结果集中的行数。
描述:
返回结果集中的列数。
7.MYSQL_ROW mysql_fetch_row(MYSQL_RES *result)
描述:
遍历结果集中的行数据,每执行一次便会检索出查询出的一行数据
检索结果集的下一行。在mysql_store_result()之后使用时,如果没有要检索的行,mysql_fetch_row()返回NULL
返回值:
下一行的MYSQL_ROW结构。如果没有更多要检索的行或出现了错误,返回NULL。
8.my_ulonglong mysql_affected_rows(MYSQL *mysql)
描述:
返回上次UPDATE更改的行数,上次DELETE删除的行数,或上次INSERT语句插入的行数。对于UPDATE、DELETE或INSERT语句,
可在mysql_query()后立刻调用。对于SELECT语句,mysql_affected_rows()的工作方式与mysql_num_rows()类似。
演示代码:
#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
#include <string.h>
#define SELECT "select * from test where flag =0"
#define INSERT "insert into test (flag,type,f_index) values('1','test_9','4')"
#define DELETE "delete from test where f_index=4"
#define UPDATE "update test set type='test_33' where f_index=4"
void err(char *p)
{
perror(p);
exit(-1);
}
int main()
{
MYSQL mysql;//mysql 实例
MYSQL_ROW row;//查询结果
mysql_init(&mysql);//初始化mysql实例
//链接mysql
if(!mysql_real_connect(&mysql,"12.23.0.3","sum","sum","test",3306,NULL,0)) err("mysql_real_connect");
//执行查询语句
if(mysql_query(&mysql,SELECT) != 0) err("mysql_query");
//存储结果集
MYSQL_RES *res=mysql_store_result(&mysql);
//返回结果集中的行数
int r_count=mysql_num_rows(res);
//返回结果集中的列数;
int f_count=mysql_num_fields(res);
while(row=mysql_fetch_row(res))
{
int i=0;
for(i;i<f_count;i++){
printf("%s ",row[i]);
}
printf("\n");
}
//执行插入语句
if(mysql_query(&mysql,INSERT) !=0 ) err("mysql_query : insert");
//返回上一次执行update delete insert 时所影响的行数;
printf("affected row = %d \n",mysql_affected_rows(&mysql));
//执行更新语句
if(mysql_query(&mysql,UPDATE) !=0 ) err("mysql_query :update");
printf("affected row = %d \n",mysql_affected_rows(&mysql));
//执行删除语句
if(mysql_query(&mysql,DELETE) !=0 ) err("mysql_query: delete");
printf("affected row = %d \n",mysql_affected_rows(&mysql));
}
编译过程:gcc mysql.c -l mysqlclient
表原始数据内容:
运行结果:
程序运行完 表中的数据没有变化;增加修改的数据最后都删掉了。