MySQL入門之預處理語句的使用

　　MySQL客戶端/伺服器協定提供了預處理語句。此功能採用了由mysql_stmt_init()初始化函數傳回的MYSQL_STMT語句處理程序資料結構。對於多次執行的語句，預處理執行是一種有效的方式。首先對語句進行解析，為執行作好準備。接下來，在以後使用初始化函數傳回的語句句柄執行一次或多次。

　　對於多次執行的語句，預處理執行比直接執行快，主要原因在於，僅對查詢執行一次解析操作。在直接執行的情況下，每次執行語句時，均會進行查詢。此外，由於每次執行預處理語句時僅需發送參數的數據，從而減少了網路通訊量。 
　　預處理語句的另一個優點是，它採用了二進位協議，從而使得客戶端和伺服器之間的資料傳輸更有效率。

　　類似Ｏｒａｃｌｅ裡面的佔位符概念！ ！ 
　　 
一般步驟：

用mysql_stmt_init()建立預處理語句句柄。若要在伺服器上準備預處理語句，可呼叫mysql_stmt_prepare()，並為其傳遞包含SQL語句的字串 如果語句產生了結果集，請呼叫mysql_stmt_result_metadata()以獲得結果集元資料。雖然與包含查詢傳回列的結果集不同，但該元資料本身也採用了結果集的形式。元資料結果集指明了結果中包含多少列，並包含每一列的資訊。 使用mysql_stmt_bind_param()設定任何參數的值。必須設定所有參數。否則，語句執行將傳回錯誤，或產生無法預料的結果。 呼叫mysql_stmt_execute()執行語句。 如果語句產生了結果集，捆綁資料緩衝，透過呼叫mysql_stmt_bind_result()，檢索行值。 透過重複呼叫mysql_stmt_fetch()，按行將資料提取到緩衝區，直到未發現更多行為止。 透過更改參數值並再次執行語句，重複步驟3到步驟6。

具體看程式碼

#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>
#include <termios.h>
#define STRING_SIZE 50
#define DROP_SAMPLE_TABLE "DROP TABLE IF EXISTS test_table"
#define CREATE_SAMPLE_TABLE "CREATE TABLE test_table(col1 INT,\
                                                 col2 VARCHAR(40),\
                                                 col3 SMALLINT,\
                                                 col4 TIMESTAMP)"
#define INSERT_SAMPLE "INSERT INTO test_table(col1,col2,col3) VALUES(?,?,?)" 
int main(int arg, char *args[])
{
    int             ret = 0, i=0;
    MYSQL           *mysql;
    MYSQL           *connect;
    MYSQL_RES       *result;
    MYSQL_ROW       row;
    MYSQL_FIELD     *fields;
    unsigned int    num_fields;
    //if (arg < 4)
    //{
    //  printf("please enter: %s localhost user password dbname\n", args[0]);
    //  return -1;
    //}
    mysql = mysql_init(NULL);
    //连接到mysql server
    //connect = mysql_real_connect(mysql, args[1], args[2], args[3], args[4],0, 0, 0);
    //connect = mysql_real_connect(mysql, "localhost", "root", a, args[4],0, 0, 0);
    connect = mysql_real_connect(mysql, "localhost", "root", "123456", "mydb2", 0, NULL, 0 );
    if (connect == NULL)
    {
        printf("connect error, %s\n", mysql_error(mysql));
        return -1;
    }
    ret = mysql_query(connect, "SET NAMES utf8");       //设置字符集为UTF8
    if (ret != 0)
    {
        printf("设置字符集错误, %s\n", mysql_error(mysql));
        return ret;
    }
    MYSQL_STMT    *stmt;
    MYSQL_BIND    bind[3];
    my_ulonglong  affected_rows;
    int           param_count;
    short         small_data;
    int           int_data;
    char          str_data[STRING_SIZE];
    unsigned long str_length;
    my_bool       is_null;
    if (mysql_query(mysql, DROP_SAMPLE_TABLE))
    {
      fprintf(stderr, " DROP TABLE failed\n");
      fprintf(stderr, " %s\n", mysql_error(mysql));
      exit(0);
    }
    if (mysql_query(mysql, CREATE_SAMPLE_TABLE))
    {
      fprintf(stderr, " CREATE TABLE failed\n");
      fprintf(stderr, " %s\n", mysql_error(mysql));
      exit(0);
    }
    /* Prepare an INSERT query with 3 parameters */
    /* (the TIMESTAMP column is not named; the server */
    /*  sets it to the current date and time) */
    stmt = mysql_stmt_init(mysql); //初始化 预处理环境 生成一个预处理句柄
    if (!stmt)
    {
      fprintf(stderr, " mysql_stmt_init(), out of memory\n");
      exit(0);
    }
    if (mysql_stmt_prepare(stmt, INSERT_SAMPLE, strlen(INSERT_SAMPLE))) //预处理环境中 准备sql
    {
      fprintf(stderr, " mysql_stmt_prepare(), INSERT failed\n");
      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
      exit(0);
    }
    fprintf(stdout, " prepare, INSERT successful\n");
    /* Get the parameter count from the statement */
    param_count= mysql_stmt_param_count(stmt);   //预处理环境中 求绑定变量的个数
    fprintf(stdout, " total parameters in INSERT: %d\n", param_count);
    if (param_count != 3) /* validate parameter count */
    {
      fprintf(stderr, " invalid parameter count returned by MySQL\n");
      exit(0);
    }
    /* Bind the data for all 3 parameters */
    memset(bind, 0, sizeof(bind));
    /* INTEGER PARAM */   
    /* This is a number type, so there is no need to specify buffer_length */
    bind[0].buffer_type= MYSQL_TYPE_LONG;  //为第一个绑定变量设置类型和 输入变量的内存首地址
    bind[0].buffer= (char *)&int_data;
    bind[0].is_null= 0;
    bind[0].length= 0;
    /* STRING PARAM */
    bind[1].buffer_type= MYSQL_TYPE_STRING; //为第2个绑定变量设置类型和 输入变量的内存首地址
    bind[1].buffer= (char *)str_data;
    bind[1].buffer_length= STRING_SIZE;
    bind[1].is_null= 0;
    bind[1].length= &str_length;
    /* SMALLINT PARAM */
    bind[2].buffer_type= MYSQL_TYPE_SHORT; //为第3个绑定变量设置类型和 输入变量的内存首地址
    bind[2].buffer= (char *)&small_data;
    bind[2].is_null= &is_null;
    bind[2].length= 0;
    /* Bind the buffers */
    if (mysql_stmt_bind_param(stmt, bind)) //把绑定变量设置到 预处理环境中
    {
      fprintf(stderr, " mysql_stmt_bind_param() failed\n");
      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
      exit(0);
    }
    /* Specify the data values for the first row */ //插入第一条记录
    int_data= 10;             /* integer */
    strncpy(str_data, "MySQL", STRING_SIZE); /* string  */
    str_length= strlen(str_data);
    /* INSERT SMALLINT data as NULL */
    is_null= 1;
    /* Execute the INSERT statement - 1*/
    if (mysql_stmt_execute(stmt))
    {
      fprintf(stderr, " mysql_stmt_execute(), 1 failed\n");
      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
      exit(0);
    }
    /* Get the total number of affected rows */
    affected_rows= mysql_stmt_affected_rows(stmt);
    fprintf(stdout, " total affected rows(insert 1): %lu\n",
                    (unsigned long) affected_rows);
    if (affected_rows != 1) /* validate affected rows */
    {
      fprintf(stderr, " invalid affected rows by MySQL\n");
      exit(0);
    }
    /* Specify data values for second row, then re-execute the statement */
    int_data= 1000;   //插入第一条记录
    strncpy(str_data, "The most popular Open Source database", STRING_SIZE);
    str_length= strlen(str_data);
    small_data= 1000;         /* smallint */
    is_null= 0;               /* reset */
    /* Execute the INSERT statement - 2*/
    if (mysql_stmt_execute(stmt))
    {
      fprintf(stderr, " mysql_stmt_execute, 2 failed\n");
      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
      exit(0);
    }
    /* Get the total rows affected */
    affected_rows= mysql_stmt_affected_rows(stmt);
    fprintf(stdout, " total affected rows(insert 2): %lu\n",
                    (unsigned long) affected_rows);
    if (affected_rows != 1) /* validate affected rows */
    {
      fprintf(stderr, " invalid affected rows by MySQL\n");
      exit(0);
    }
    /* 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(connect);      //断开与SQL server的连接
}

以上就是MySQL入門之預處理語句的使用的內容，更多相關內容請關注PHP中文網（www.php.cn）！