MySQL :: MySQL 8.4 C API 开发者指南 :: 6.4.27 mysql_stmt_send_long_data()

版本 8.4

MySQL 8.4 C API 开发者指南 / ... / mysql_stmt_send_long_data()

6.4.27 mysql_stmt_send_long_data()

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_bind_named_param() 之后以及调用 mysql_stmt_execute() 之前调用此函数。可以多次调用它来发送一列的字符或二进制数据值的部分，该列必须是 TEXT 或 BLOB 数据类型之一。

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

注意

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

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

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

返回值

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

错误

CR_INVALID_BUFFER_USE

该参数没有字符串或二进制类型。
CR_INVALID_PARAMETER_NO

无效的参数编号。
CR_COMMANDS_OUT_OF_SYNC

命令执行顺序不正确。
CR_SERVER_GONE_ERROR

MySQL 服务器已断开连接。
CR_OUT_OF_MEMORY

内存不足。
CR_UNKNOWN_ERROR

发生未知错误。

示例

以下示例演示如何分块发送 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_named_param(stmt, bind, 1, NULL))
{
  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);
}