int mysql_stmt_execute(mysql_stmt * stmt)
mysql_stmt_execute()
执行与语句处理程序关联的准备查询。当前绑定的参数标记值在此呼叫期间发送到服务器,服务器将标记用此新提供的数据替换。
声明处理后面mysql_stmt_execute()
取决于语句的类型:
为
更新
那删除
, 或者插
,可以通过调用来找到更改,删除或插入行的数量mysql_stmt_affected_rows()
。对于诸如
选择
生成结果集,您必须呼叫mysql_stmt_fetch()
在调用导致查询处理的任何其他功能之前获取数据。有关如何获取结果的更多信息,请参阅第6.4.11节“mysql_stmt_fetch()”。不要遵循调用
mysql_stmt_execute()
打电话mysql_store_result()
或mysql_use_result()
。这些功能不适用于从准备好的陈述处理结果。
对于生成结果集的语句,您可以请求mysql_stmt_execute()
通过致电打开声明的光标mysql_stmt_attr_set ()
在执行该声明之前。如果您多次执行语句,mysql_stmt_execute()
在打开一个新的一个之前关闭任何打开的光标。
检测到由准备语句引用的表或视图的元数据更改,并在下次执行时对语句自动进行自动重置。有关更多信息,请参阅缓存准备的陈述和存储的程序。
命令以不正当的顺序执行。
内存不足。
MySQL Server已经消失了。
查询期间与服务器的连接丢失。
出现未知错误。
以下示例演示如何使用和填充表mysql_stmt_init()
那mysql_stmt_prepare ()
那mysql_stmt_param_count()
那mysql_stmt_bind_param()
那mysql_stmt_execute()
, 和mysql_stmt_affected_rows()
。这mysql.
变量被认为是有效的连接处理程序。有关显示如何检索数据的示例,请参阅第6.4.11节“mysql_stmt_fetch()”。
#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(?,?,?)MYSQL_STMT *支撑;MYSQL_BIND绑定[3];my_ulonglong affected_rows;int param_count;短small_data;int int_data;char str_data [STRING_SIZE];无符号长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))) { 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; 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; 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 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)) { /* mysql_stmt_close() invalidates stmt, so call */ /* mysql_error(mysql) rather than mysql_stmt_error(stmt) */ fprintf(stderr, " failed while closing the statement\n"); fprintf(stderr, " %s\n", mysql_error(mysql)); exit(0); }
有关使用准备的语句函数的完整示例,请参阅该文件测试/ mysql_client_test.c
。该文件可以从MySQL源分发或从源存储库获得(参见从源代码安装MySQL)。