mysql 预编译 sql 实现代码

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 语句只编译一次，却产生了两个结果。

这是程序执行的结果，下面是其执行后创建的表和表中的内容