mysql編程入門之多查詢執(zhí)行的C API處理方法

下文內(nèi)容主要給大家?guī)?a title="mysql" target="_blank" href="http://kemok4.com/mysql/">mysql編程入門之多查詢執(zhí)行的C API處理方法，這里所講到的知識，與書籍略有不同，都是億速云專業(yè)技術(shù)人員在與用戶接觸過程中，總結(jié)出來的，具有一定的經(jīng)驗分享價值，希望給廣大讀者帶來幫助。

多查詢執(zhí)行的C API處理
?支持在單個字符串中指定的多語句的執(zhí)行。要想與給定的連接一起使用該功能，打開連接時，必須將標(biāo)志參數(shù)中的CLIENT_MULTI_STATEMENTS選項指定給mysql_real_connect()。也可以通過調(diào)用mysql_set_server_option(MYSQL_OPTION_MULTI_STATEMENTS_ON)，為已有的連接設(shè)置它

多查詢就幾個點

1. CLIENT_MULTI_STATEMENTS選項指定
2. mysql_next_result
   int mysql_next_result(MYSQL *mysql)

描述

如果存在多個查詢結(jié)果，mysql_next_result()將讀取下一個查詢結(jié)果，并將狀態(tài)返回給應(yīng)用程序。

如果前面的查詢返回了結(jié)果集，必須為其調(diào)用mysql_free_result()。

調(diào)用了mysql_next_result()后，連接狀態(tài)就像你已為下一查詢調(diào)用了mysql_real_query()或mysql_query()時的一樣。這意味著你能調(diào)用mysql_store_result()、mysql_warning_count()、mysql_affected_rows()等等。

如果mysql_next_result()返回錯誤，將不執(zhí)行任何其他語句，也不會獲取任何更多的結(jié)果
返回值
描述

0成功并有多個結(jié)果。

-1
成功但沒有多個結(jié)果。

0出錯

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

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; i<num; i++)
{
    printf("%s\t",  fields[i].name);
}
printf("\n");

//按照行 求內(nèi)容
MYSQL_ROW row = NULL;
while ( row = mysql_fetch_row(result) ) 
{
    for (i=0; i<num; i++)
    {
        printf("%s\t", row[i]);
    }
    printf("\n");
}

return  0;

}

int main()
{
int     ret = 0;
int     status = 0;

MYSQL   *mysql;
MYSQL   *connect = NULL;
MYSQL_RES *result ;

mysql = mysql_init(NULL) ;  
if (mysql == NULL)
{
    ret =  mysql_errno(mysql) ;
    printf("func mysql_init() err \n");
    return ret;
}
printf("func mysql_init() ok \n");

connect = mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, CLIENT_MULTI_STATEMENTS);
if (connect == NULL)
{
    ret =  mysql_errno(mysql) ;
    printf("func mysql_init() err \n");
    return ret; 
}

/* execute multiple statements */
status = mysql_query(mysql,
                    "DROP TABLE IF EXISTS test_table;\
                    CREATE TABLE test_table(id INT);\
                    INSERT INTO test_table VALUES(10);\
                    UPDATE test_table SET id=20 WHERE id=10;\
                    SELECT * FROM test_table;\
                    DROP TABLE test_table");
if (status)
{
    printf("Could not execute statement(s)");
    mysql_close(mysql);
    exit(0);
}
/* process each statement result */
do {
        /* did current statement return data? */
        result = mysql_store_result(mysql);
        if (result)  //select語句
        {
            /* yes; process rows and free the result set */
            //打樁（也可叫占位函數(shù)）
            process_result_set(mysql, result);
            mysql_free_result(result);
        }
        else /* no result set or error */
        {
            if (mysql_field_count(mysql) == 0)//返回作用在連接上的最近查詢的列數(shù)，此為非查詢，故為0
            {
                printf("%lld rows affected\n",
                mysql_affected_rows(mysql));
            }
            else /* some error occurred */
            {
                printf("Could not retrieve result set\n");
                break;
            }
        }
        /* more results? -1 = no, >0 = 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;

}

二進(jìn)制協(xié)議允許你使用MYSQL_TIME結(jié)構(gòu)發(fā)送和接受日期和時間值（DATE、TIME、DATETIME和TIMESTAMP）
要想發(fā)送臨時數(shù)據(jù)值，可使用mysql_stmt_prepare()創(chuàng)建預(yù)處理語句。然后，在調(diào)用mysql_stmt_execute()執(zhí)行語句之前，可采用下述步驟設(shè)置每個臨時參數(shù)：

1. 在與數(shù)據(jù)值相關(guān)的MYSQL_BIND結(jié)構(gòu)中，將buffer_type成員設(shè)置為相應(yīng)的類型，該類型指明了發(fā)送的臨時值類型。對于DATE、TIME、DATETIME或TIMESTAMP值，將buffer_type分別設(shè)置為MYSQL_TYPE_DATE、MYSQL_TYPE_TIME、MYSQL_TYPE_DATETIME或MYSQL_TYPE_TIMESTAMP。

2. 將MYSQL_BIND結(jié)構(gòu)的緩沖成員設(shè)置為用于傳遞臨時值的MYSQL_TIME結(jié)構(gòu)的地址。

3. 填充MYSQL_TIME結(jié)構(gòu)的成員，使之與打算傳遞的臨時支的類型相符。

使用mysql_stmt_bind_param()將參數(shù)數(shù)據(jù)綁定到語句。然后可調(diào)用mysql_stmt_execute()。

要想檢索臨時值，可采用類似的步驟，但應(yīng)將buffer_type成員設(shè)置為打算接受的值的類型，并將緩沖成員設(shè)為應(yīng)將返回值置于其中的MYSQL_TIME結(jié)構(gòu)的地址。調(diào)用mysql_stmt_execute()之后，并在獲取結(jié)果之前，使用mysql_bind_results()將緩沖綁定到語句上。

請看代碼：
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <dlfcn.h>
#include <mysql/mysql.h>

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <termios.h>
#include <mysql/mysql.h>

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;

 //注意：
 // 創(chuàng)建的表語句
 // 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))) //向環(huán)境句柄中添加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;  //設(shè)置綁定變量屬性
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);

對于以上關(guān)于mysql編程入門之多查詢執(zhí)行的C API處理方法，如果大家還有更多需要了解的可以持續(xù)關(guān)注我們億速云的行業(yè)推新，如需獲取專業(yè)解答，可在官網(wǎng)聯(lián)系售前售后的，希望該文章可給大家?guī)硪欢ǖ闹R更新。