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) に注目してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
