ホームページ >データベース >mysql チュートリアル >MySQL 入門: 準備済みステートメントの使用
MySQL クライアント/サーバー プロトコルはプリペアド ステートメントを提供します。この関数は、mysql_stmt_init() 初期化関数によって返される MYSQL_STMT ステートメント ハンドラー データ構造を使用します。複数回実行されるステートメントの場合、前処理された実行が効果的な方法です。まず、ステートメントが解析されて実行の準備が行われます。次に、初期化関数によって返されたステートメント ハンドルを使用して、後で 1 回以上実行します。
複数回実行されるステートメントの場合、前処理の実行は直接実行よりも高速です。主な理由は、クエリに対して実行される解析操作が 1 回だけであるためです。直接実行の場合、クエリはステートメントが実行されるたびに実行されます。さらに、準備されたステートメントが実行されるたびにパラメータ データのみが送信されるため、ネットワーク トラフィックが削減されます。
プリペアド ステートメントのもう 1 つの利点は、バイナリ プロトコルを使用するため、クライアントとサーバー間のデータ送信がより効率的になることです。
Oracleのプレースホルダーの概念に似ています! !
一般的な手順:
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 中国語 Web サイト (www.php.cn) に注目してください。