mysql api---从一个小例子开始mysql编程入门（5）

qqwe

　　多查询执行的C API处理
　　支持在单个字符串中指定的多语句的执行。要想与给定的连接一起使用该功能，打开连接时，必须将标志参数中的CLIENT_MULTI_STATEMENTS选项指定给mysql_real_connect()。也可以通过调用mysql_set_server_option(MYSQL_OPTION_MULTI_STATEMENTS_ON)，为已有的连接设置它
　　多查询就几个点

• CLIENT_MULTI_STATEMENTS选项指定
  
• mysql_next_result　　int mysql_next_result(MYSQL *mysql)
  
  

　　描述
　　如果存在多个查询结果，mysql_next_result()将读取下一个查询结果，并将状态返回给应用程序。
　　如果前面的查询返回了结果集，必须为其调用mysql_free_result()。
　　调用了mysql_next_result()后，连接状态就像你已为下一查询调用了mysql_real_query()或mysql_query()时的一样。这意味着你能调用mysql_store_result()、mysql_warning_count()、mysql_affected_rows()等等。
　　如果mysql_next_result()返回错误，将不执行任何其他语句，也不会获取任何更多的结果
　　返回值
　　描述
　　0成功并有多个结果。
　　-1
　　成功但没有多个结果。

　　0出错

　　#include
　　#include
　　#include
　　#include
　　int process_result_set(MYSQL mysql, MYSQL_RES result)
　　{
　　int     ret = 0, i = 0;
　　unsigned int  num = 0;
　　

if (mysql==NULL || result==NULL)　　
{
　　ret = 0;
　　printf("func process_result_set() err:%d, check  if (mysql==NULL || result==NULL) \n", ret);
　　return ret;
　　
}
　　
num = mysql_field_count(mysql) ;
　　

　　
//求表头
　　
MYSQL_FIELD  *fields = mysql_fetch_fields(result);
　　
for (i = 0; i0 = error, 0 = yes (keep looping) */
　　if ((status = mysql_next_result(mysql)) > 0)
　　printf("Could not execute statement\n");
　　
} while (status == 0);
　　

　　mysql_close(connect);
　　

　　
printf("hello...\n");
　　
return ret;
　　

　　}
　　二进制协议允许你使用MYSQL_TIME结构发送和接受日期和时间值（DATE、TIME、DATETIME和TIMESTAMP）
　　要想发送临时数据值，可使用mysql_stmt_prepare()创建预处理语句。然后，在调用mysql_stmt_execute()执行语句之前，可采用下述步骤设置每个临时参数：

• 　　在与数据值相关的MYSQL_BIND结构中，将buffer_type成员设置为相应的类型，该类型指明了发送的临时值类型。对于DATE、TIME、DATETIME或TIMESTAMP值，将buffer_type分别设置为MYSQL_TYPE_DATE、MYSQL_TYPE_TIME、MYSQL_TYPE_DATETIME或MYSQL_TYPE_TIMESTAMP。
  
  
• 　　将MYSQL_BIND结构的缓冲成员设置为用于传递临时值的MYSQL_TIME结构的地址。
  
  
• 填充MYSQL_TIME结构的成员，使之与打算传递的临时支的类型相符。
  

　　使用mysql_stmt_bind_param()将参数数据绑定到语句。然后可调用mysql_stmt_execute()。
　　要想检索临时值，可采用类似的步骤，但应将buffer_type成员设置为打算接受的值的类型，并将缓冲成员设为应将返回值置于其中的MYSQL_TIME结构的地址。调用mysql_stmt_execute()之后，并在获取结果之前，使用mysql_bind_results()将缓冲绑定到语句上。
　　请看代码：
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　#include
　　int main()
　　{
　　int         ret = 0, status = 0;
　　MYSQL       mysql;
　　MYSQL_RES   result;
　　

mysql =mysql_init(NULL);　　
mysql =mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, CLIENT_MULTI_STATEMENTS );
　　
if (mysql == NULL)
　　
{
　　ret = mysql_errno(mysql);
　　printf("%s", mysql_error(mysql));
　　printf("func mysql_real_connect() err :%d\n", ret);
　　return ret;
　　
}
　　
else
　　
{
　　printf(" ok......\n");
　　
}
　　

　　
MYSQL_TIME  ts;
　　
MYSQL_BIND  bind[3];
　　
MYSQL_STMT  *stmt;
　　

　　//注意：
　　// 创建的表语句
　　// create table test_table (date_field date,  time_field time,  timestamp_field timestamp );
　　
char query[1024] = "INSERT INTO test_table(date_field, time_field, timestamp_field) VALUES(?,?,?)";
　　

　　
stmt = mysql_stmt_init(mysql);
　　
if (!stmt)
　　
{
　　fprintf(stderr, " mysql_stmt_init(), out of memory\n");
　　exit(0);
　　
}
　　
if (mysql_stmt_prepare(stmt, query, strlen(query))) //向环境句柄中添加sql语言  带有占位符
　　
{
　　fprintf(stderr, "\n mysql_stmt_prepare(), INSERT failed");
　　fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
　　exit(0);
　　
}
　　

　　
/* set up input buffers for all 3 parameters */
　　
bind[0].buffer_type= MYSQL_TYPE_DATE;  //设置绑定变量属性
　　
bind[0].buffer= (char *)&ts;
　　
bind[0].is_null= 0;
　　
bind[0].length= 0;
　　
//
　　
bind[1]= bind[2]= bind[0];
　　
//...
　　

　　
mysql_stmt_bind_param(stmt, bind);
　　

　　
/* supply the data to be sent in the ts structure */
　　
ts.year= 2002;
　　
ts.month= 02;
　　
ts.day= 03;
　　

　　
ts.hour= 10;
　　
ts.minute= 45;
　　
ts.second= 20;
　　

　　
mysql_stmt_execute(stmt);
　　

　　
// Close the statement //
　　
if (mysql_stmt_close(stmt))
　　
{
　　fprintf(stderr, " failed while closing the statement\n");
　　fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
　　exit(0);
　　
}
　　

　　
mysql_close(mysql);
　　

　　}
　　啊，终于到最后一节了：
　　事务
　　mysql api---从一个小例子开始mysql编程入门（6）