MySQL5.6 mysql_stmt

23.8.11.11 mysql_stmt_fetch()

int mysql_stmt_fetch(MYSQL_STMT *stmt)

설명

mysql_stmt_fetch() 는 결과 집합에서 다음 행을 돌려줍니다. 그것은 결과 세트가 존재하는 동안 만 호출 할 수 있습니다. 즉, 결과 세트를 생성하는 SELECT 등의 문에 대한 mysql_stmt_execute() 에 대한 호출 후입니다.

mysql_stmt_fetch() 는 mysql_stmt_bind_result() 에 의해 구속 된 버퍼를 사용하여 행 데이터를 반환합니다. 그것은 현재의 행 세트 내의 모든 열에 대해 그 버퍼의 데이터를 반환 길이가 length 포인터에 반환됩니다. 응용 프로그램은 mysql_stmt_fetch() 를 호출하기 전에 모든 열을 바인드해야합니다.

기본적으로 결과 집합은 서버에서 한 번에 행을 버퍼되지 않고 페치됩니다. 클라이언트에서 전체 결과 집합을 버퍼하려면 데이터 버퍼를 바인딩 한 뒤의 mysql_stmt_fetch() 를 호출하기 전에 mysql_stmt_store_result() 를 호출합니다.

페치 된 데이터 값이 NULL 값인 경우 해당 MYSQL_BIND 구조 *is_null 값은 TRUE (1)가 포함되어 있습니다. 그렇지 않으면 데이터와 길이가 애플리케이션에 의해 지정된 버퍼의 형태에 따라 *buffer 및 *length 요소로 반환됩니다. 다음 표와 같이 각 수치 및 시간 형식은 고정 길이를가집니다. data_length 에 도시 된 바와 같이, 문자열의 길이는 실제 데이터 값의 길이에 따라 다릅니다.

Type	Length
`MYSQL_TYPE_TINY`	1
`MYSQL_TYPE_SHORT`	2
`MYSQL_TYPE_LONG`	4
`MYSQL_TYPE_LONGLONG`	8
`MYSQL_TYPE_FLOAT`	4
`MYSQL_TYPE_DOUBLE`	8
`MYSQL_TYPE_TIME`	`sizeof(MYSQL_TIME)`
`MYSQL_TYPE_DATE`	`sizeof(MYSQL_TIME)`
`MYSQL_TYPE_DATETIME`	`sizeof(MYSQL_TIME)`
`MYSQL_TYPE_STRING`	`data length`
`MYSQL_TYPE_BLOB`	`data_length`

경우에 따라 mysql_stmt_fetch() 에서 컬럼 값을 페치하기 전에 그 길이를 판단하고 싶다고 생각할 수 있습니다. 예를 들어, 값이 할당해야하는 공간의 양을 알고 싶다 긴 문자열이나 BLOB 값 인 경우가 있습니다. 이를 실현하기 위해서는 이러한 전략을 사용할 수 있습니다.

mysql_stmt_fetch() 를 호출하여 각 행을 취득하기 전에 STMT_ATTR_UPDATE_MAX_LENGTH 을 mysql_stmt_attr_set() 에 전달하고, mysql_stmt_store_result() 를 호출하여 클라이언트 측에서 결과 세트 전체를 버퍼합니다. STMT_ATTR_UPDATE_MAX_LENGTH 속성을 설정하면 컬럼 값의 최대 길이가 mysql_stmt_result_metadata() 에 의해 반환 된 결과 집합 메타 데이터 max_length 로 표시됩니다.

문제의 컬럼에 대해 제로의 길이의 버퍼 mysql_stmt_fetch() 를 호출하면 실제 길이의 포인터를 저장할 수 있습니다. 그 후, mysql_stmt_fetch_column() 에서 실제 길이를 사용합니다.

real_length= 0;

bind[0].buffer= 0;
bind[0].buffer_length= 0;
bind[0].length= &real_length
mysql_stmt_bind_result(stmt, bind);

mysql_stmt_fetch(stmt);
if (real_length > 0)
{
  data= malloc(real_length);
  bind[0].buffer= data;
  bind[0].buffer_length= real_length;
  mysql_stmt_fetch_column(stmt, bind, 0, 0);
}

반환 값

반환 값	설명
0	성공 데이터가 어플리케이션 데이터 버퍼에 반입되었습니다.
1	오류가 발생했습니다. 오류 코드 및 오류 메시지는 `mysql_stmt_errno()` 및 `mysql_stmt_error()` 를 호출함으로써 얻을 수 있습니다.
`MYSQL_NO_DATA`	그 이상의 행 / 데이터가 존재하지 않습니다
`MYSQL_DATA_TRUNCATED`	데이터 잘림이 발생했습니다

잘린 보고서가 활성화되어있는 경우 MYSQL_DATA_TRUNCATED 가 반환됩니다. 이 값이 반환 될 때 어떤 컬럼 값이 잘린 여부를 결정하려면 값을 가져 오기 위해 사용 된 MYSQL_BIND 구조의 error 멤버를 검사합니다. 잘린 보고서는 기본적으로 활성화되어 있지만 MYSQL_REPORT_DATA_TRUNCATION 옵션을 사용하여 mysql_options() 를 호출하여 제어 할 수 있습니다.

오류

CR_COMMANDS_OUT_OF_SYNC

명령이 잘못된 순서로 실행되었습니다.
CR_OUT_OF_MEMORY

메모리 부족.
CR_SERVER_GONE_ERROR

MySQL 서버가 존재하지 않습니다.
CR_SERVER_LOST

서버에 대한 연결이 쿼리 중에 손실되었습니다.
CR_UNKNOWN_ERROR

알 수없는 오류가 발생했습니다.
CR_UNSUPPORTED_PARAM_TYPE

버퍼 형은 MYSQL_TYPE_DATE , MYSQL_TYPE_TIME , MYSQL_TYPE_DATETIME , MYSQL_TYPE_TIMESTAMP 이지만, 데이터 형은 DATE , TIME , DATETIME 또는 TIMESTAMP 가 없습니다.
지원되지 않는 다른 모든 변환 오류는 mysql_stmt_bind_result() 에서 반환됩니다.

Example

다음의 예는 mysql_stmt_result_metadata() , mysql_stmt_bind_result() 및 mysql_stmt_fetch() 를 사용하여 테이블에서 데이터를 가져 오는 방법을 보여줍니다. (이 예는 섹션 23.8.11.10 "mysql_stmt_execute ()" 에 나타내는 예에 의해 삽입 된 두 행을 얻을 것으로 기대하고 있습니다). mysql 변수는 유효한 접속 핸들로 간주됩니다.

#define STRING_SIZE 50

#define SELECT_SAMPLE "SELECT col1, col2, col3, col4 \
                       FROM test_table"

MYSQL_STMT    *stmt;
MYSQL_BIND    bind[4];
MYSQL_RES     *prepare_meta_result;
MYSQL_TIME    ts;
unsigned long length[4];
int           param_count, column_count, row_count;
short         small_data;
int           int_data;
char          str_data[STRING_SIZE];
my_bool       is_null[4];
my_bool       error[4];

/* Prepare a SELECT query to fetch data from test_table */
stmt = mysql_stmt_init(mysql);
if (!stmt)
{
  fprintf(stderr, " mysql_stmt_init(), out of memory\n");
  exit(0);
}
if (mysql_stmt_prepare(stmt, SELECT_SAMPLE, strlen(SELECT_SAMPLE)))
{
  fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");
  fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  exit(0);
}
fprintf(stdout, " prepare, SELECT successful\n");

/* Get the parameter count from the statement */
param_count= mysql_stmt_param_count(stmt);
fprintf(stdout, " total parameters in SELECT: %d\n", param_count);

if (param_count != 0) /* validate parameter count */
{
  fprintf(stderr, " invalid parameter count returned by MySQL\n");
  exit(0);
}

/* Fetch result set meta information */
prepare_meta_result = mysql_stmt_result_metadata(stmt);
if (!prepare_meta_result)
{
  fprintf(stderr,
         " mysql_stmt_result_metadata(), \
           returned no meta information\n");
  fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  exit(0);
}

/* Get total columns in the query */
column_count= mysql_num_fields(prepare_meta_result);
fprintf(stdout,
        " total columns in SELECT statement: %d\n",
        column_count);

if (column_count != 4) /* validate column count */
{
  fprintf(stderr, " invalid column count returned by MySQL\n");
  exit(0);
}

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

/* Bind the result buffers for all 4 columns before fetching them */

memset(bind, 0, sizeof(bind));

/* INTEGER COLUMN */
bind[0].buffer_type= MYSQL_TYPE_LONG;
bind[0].buffer= (char *)&int_data;
bind[0].is_null= &is_null[0];
bind[0].length= &length[0];
bind[0].error= &error[0];

/* STRING COLUMN */
bind[1].buffer_type= MYSQL_TYPE_STRING;
bind[1].buffer= (char *)str_data;
bind[1].buffer_length= STRING_SIZE;
bind[1].is_null= &is_null[1];
bind[1].length= &length[1];
bind[1].error= &error[1];

/* SMALLINT COLUMN */
bind[2].buffer_type= MYSQL_TYPE_SHORT;
bind[2].buffer= (char *)&small_data;
bind[2].is_null= &is_null[2];
bind[2].length= &length[2];
bind[2].error= &error[2];

/* TIMESTAMP COLUMN */
bind[3].buffer_type= MYSQL_TYPE_TIMESTAMP;
bind[3].buffer= (char *)&ts;
bind[3].is_null= &is_null[3];
bind[3].length= &length[3];
bind[3].error= &error[3];

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

/* Now buffer all results to client (optional step) */
if (mysql_stmt_store_result(stmt))
{
  fprintf(stderr, " mysql_stmt_store_result() failed\n");
  fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  exit(0);
}

/* Fetch all rows */
row_count= 0;
fprintf(stdout, "Fetching results ...\n");
while (!mysql_stmt_fetch(stmt))
{
  row_count++;
  fprintf(stdout, "  row %d\n", row_count);

  /* column 1 */
  fprintf(stdout, "   column1 (integer)  : ");
  if (is_null[0])
    fprintf(stdout, " NULL\n");
  else
    fprintf(stdout, " %d(%ld)\n", int_data, length[0]);

  /* column 2 */
  fprintf(stdout, "   column2 (string)   : ");
  if (is_null[1])
    fprintf(stdout, " NULL\n");
  else
    fprintf(stdout, " %s(%ld)\n", str_data, length[1]);

  /* column 3 */
  fprintf(stdout, "   column3 (smallint) : ");
  if (is_null[2])
    fprintf(stdout, " NULL\n");
  else
    fprintf(stdout, " %d(%ld)\n", small_data, length[2]);

  /* column 4 */
  fprintf(stdout, "   column4 (timestamp): ");
  if (is_null[3])
    fprintf(stdout, " NULL\n");
  else
    fprintf(stdout, " %04d-%02d-%02d %02d:%02d:%02d (%ld)\n",
                     ts.year, ts.month, ts.day,
                     ts.hour, ts.minute, ts.second,
                     length[3]);
  fprintf(stdout, "\n");
}

/* Validate rows fetched */
fprintf(stdout, " total rows fetched: %d\n", row_count);
if (row_count != 2)
{
  fprintf(stderr, " MySQL failed to return all rows\n");
  exit(0);
}

/* Free the prepared result metadata */
mysql_free_result(prepare_meta_result);


/* Close the statement */
if (mysql_stmt_close(stmt))
{
  fprintf(stderr, " failed while closing the statement\n");
  fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  exit(0);
}