6.4.26 mysql_stmt_send_long_data()

my_bool
mysql_stmt_send_long_data(MYSQL_STMT *stmt,
                          unsigned int parameter_number,
                          const char *data,
                          unsigned long length)

描述

使应用程序能够将参数数据分段（或“块”）发送到服务器。mysql_stmt_bind_param()在 之后和之前调用此函数 mysql_stmt_execute()。可以多次调用它来发送列的字符或二进制数据值的部分，该列必须是TEXT或 BLOB数据类型之一。

parameter_number指示与数据关联的参数。参数从0开始编号。data是一个指向包含要发送数据的缓冲区的指针，length 指示缓冲区中的字节数。

笔记

下一次 调用将忽略 自上次 或 以来mysql_stmt_execute()使用过的所有参数的绑定缓冲区 。 mysql_stmt_send_long_data()mysql_stmt_execute()mysql_stmt_reset()

要重置/忘记发送的数据，请调用 mysql_stmt_reset()。参见 第 6.4.22 节，“mysql_stmt_reset()”。

max_allowed_packet系统变量控制可以发送的参数值的最大 大小mysql_stmt_send_long_data()。

返回值

零成功。如果发生错误，则非零。

错误

例子

以下示例演示如何以块的形式发送 TEXT列的数据。它将数据值'MySQL - The most popular Open Source database'插入到 text_column列中。该 mysql变量被假定为有效的连接处理程序。 

#define INSERT_QUERY "INSERT INTO \
                      test_long_data(text_column) VALUES(?)"

MYSQL_BIND bind[1];
long       length;

stmt = mysql_stmt_init(mysql);
if (!stmt)
{
  fprintf(stderr, " mysql_stmt_init(), out of memory\n");
  exit(0);
}
if (mysql_stmt_prepare(stmt, INSERT_QUERY, strlen(INSERT_QUERY)))
{
  fprintf(stderr, "\n mysql_stmt_prepare(), INSERT failed");
  fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
  exit(0);
}
 memset(bind, 0, sizeof(bind));
 bind[0].buffer_type= MYSQL_TYPE_STRING;
 bind[0].length= &length;
 bind[0].is_null= 0;

/* Bind the buffers */
if (mysql_stmt_bind_param(stmt, bind))
{
  fprintf(stderr, "\n param bind failed");
  fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
  exit(0);
}

 /* Supply data in chunks to server */
 if (mysql_stmt_send_long_data(stmt,0,"MySQL",5))
{
  fprintf(stderr, "\n send_long_data failed");
  fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
  exit(0);
}

 /* Supply the next piece of data */
 if (mysql_stmt_send_long_data(stmt,0,
           " - The most popular Open Source database",40))
{
  fprintf(stderr, "\n send_long_data failed");
  fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
  exit(0);
}

 /* Now, execute the query */
 if (mysql_stmt_execute(stmt))
{
  fprintf(stderr, "\n mysql_stmt_execute failed");
  fprintf(stderr, "\n %s", mysql_stmt_error(stmt));
  exit(0);
}