mysql 的预编译功能,是为了那些频繁执行的语法不变的 sql 语句而准备的,每次 sql 语句执行都要经过数据库的编译,这个过程比较耗时,一条两条或十几条可能没什么感觉,如果是上千条效率会明显的有变化。mysql 提供的机制是可以让一个结构不变的 sql 语句预先在数据库中编译,我们只需要将可变的参数每次传递给它执行就可以了,这样就省去了编译的步骤,效率提高非常明显。下面就是预编译的一个小例子。
代码实现
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <mysql.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 argc, char* argv[]) { unsigned int err; // 初始化 mysql 句柄 MYSQL* mysql; mysql = mysql_init(NULL); if (mysql == NULL) { err = mysql_errno(mysql); printf("mysql_init error, code = %d\n", err); return err; } // 连接服务器 mysql = mysql_real_connect(mysql, "127.0.0.1", "root", "******", "mydb61", 0, NULL, 0); if (NULL == mysql) { err = mysql_errno(mysql); printf("mysql_real_connect error, code = %d\n", err); return err; } // ------------------------------------------ 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; // 处理 null 的变量,为1则插入null,为0则根据传递的值插入 // 在操作前先把已经有的表删除 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); } // 初始化预编译功能句柄 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))) { fprintf(stderr, " mysql_stmt_prepare(), INSERT failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } fprintf(stdout, " prepare, INSERT successful\n"); // 获取预处理语句有多少个需要绑定的变量 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)); // 与第一个要插入的数据绑定的结构体初始化 bind[0].buffer_type= MYSQL_TYPE_LONG; // 插入的数据类型 bind[0].buffer= (char *)&int_data; // 插入数据的变量地址,可以在后面再给这个变量赋值 bind[0].is_null= 0; // 插入数据是否为 null,为0则根据上面的参数插入数据 bind[0].length= 0; // 插入数据的长度,除了 string 类型外,这个都不需要设置 // 与第而个要插入的数据绑定的结构体初始化 bind[1].buffer_type= MYSQL_TYPE_STRING;// 插入的数据类型,string bind[1].buffer= (char *)str_data; // 字符串的首地址,先绑定,可以在后面修改它的值 bind[1].buffer_length= STRING_SIZE; // 设定 buffer 的长度 bind[1].is_null= 0; // 是否为 null bind[1].length= &str_length; // 字符串的长度 // 与第三个要插入的数据绑定的结构体初始化 bind[2].buffer_type= MYSQL_TYPE_SHORT; // 插入的数据类型 short bind[2].buffer= (char *)&small_data; // 插入的数据地址,先绑定,可以在后面修改它的值 bind[2].is_null= &is_null; // 是否为 null ,先绑定,可以在后面修改它的值 bind[2].length= 0; // 无需设置长度 // 绑定变量 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); } // 给绑定变量的各个数据赋值 int_data= 10; /* integer */ strncpy(str_data, "MySQL", STRING_SIZE); /* string */ str_length= strlen(str_data); // 设置 is_null 的值为1,这样第三个参数插入的就是 null 了 is_null= 1; // 执行已经编译的查询语句 if (mysql_stmt_execute(stmt)) { fprintf(stderr, " mysql_stmt_execute(), 1 failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } // 查询语句结果的列数 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); } // 再次给绑定变量赋予其他的值 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 */ // 再次执行预编译的语句 if (mysql_stmt_execute(stmt)) { fprintf(stderr, " mysql_stmt_execute, 2 failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } // 获取结果中的列数 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); } // 关闭 if (mysql_stmt_close(stmt)) { fprintf(stderr, " failed while closing the statement\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } // 关闭 mysql 句柄 mysql_close(mysql); return 0; }
编译程序
编译语句:gcc 03_mysql_stmt.c -o 03_mysql_stmt -I /usr/include/mysql -L /usr/lib64/mysql -l mysqlclient -l stdc++ -l pthread -l dl -l rt
执行效果
代码分两个阶段,分别对已经绑定的 sql 语句传递了两次不同的数据,让其再执行,执行的结果是一条 sql 语句只编译一次,却产生了两个结果。
这是程序执行的结果,下面是其执行后创建的表和表中的内容