example/dbms.mysql/select/main.cpp

   1 #include <string.h>
   2 #include <stdio.h>
   3
   4 #include <mysql/mysql.h>
   5
   6 #define STRING_SIZE 50
   7
   8 #define SELECT_SAMPLE "SELECT xx, yy, zz, tt FROM anna_db_test"
   9
  10 #define MAXCOLUMN 4
  11
  12 MYSQL* mysql;
  13 MYSQL_STMT    *stmt;
  14 MYSQL_BIND    bind[MAXCOLUMN];
  15 MYSQL_RES     *prepare_meta_result;
  16 MYSQL_TIME    ts;
  17 unsigned long length[MAXCOLUMN];
  18 int           param_count, column_count, row_count;
  19 float         float_data;
  20 int           int_data;
  21 char          str_data[STRING_SIZE];
  22 my_bool       is_null[MAXCOLUMN];
  23
  24 /*
  25  * From http://dev.mysql.com/doc/refman/4.1/en/mysql-stmt-fetch.html
  26  */
  27 int main (int argc, const char** argv)
  28 {
  29    if ((mysql = mysql_init (NULL)) == NULL)
  30       exit (-12);
  31
  32    if (mysql_real_connect (mysql, NULL, "sdp", "sdp", "test", 0, NULL, 0L) == NULL) {
  33       fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");
  34       fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  35       exit(0);
  36    }
  37
  38    /* Prepare a SELECT query to fetch data from test_table */
  39    stmt = mysql_stmt_init(mysql);
  40    if (!stmt)
  41    {
  42      fprintf(stderr, " mysql_stmt_init(), out of memory\n");
  43      exit(0);
  44    }
  45
  46    if (mysql_stmt_prepare(stmt, SELECT_SAMPLE, strlen(SELECT_SAMPLE)))
  47    {
  48      fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");
  49      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  50      exit(0);
  51    }
  52    fprintf(stdout, " prepare, SELECT successful\n");
  53
  54    /* Get the parameter count from the statement */
  55    param_count= mysql_stmt_param_count(stmt);
  56    fprintf(stdout, " total parameters in SELECT: %d\n", param_count);
  57
  58    if (param_count != 0) /* validate parameter count */
  59    {
  60      fprintf(stderr, " invalid parameter count returned by MySQL\n");
  61      exit(0);
  62    }
  63
  64    /* Fetch result set meta information */
  65    prepare_meta_result = mysql_stmt_result_metadata(stmt);
  66    if (!prepare_meta_result)
  67    {
  68      fprintf(stderr," mysql_stmt_result_metadata(), returned no meta information\n");
  69      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  70      exit(0);
  71    }
  72
  73    /* Get total columns in the query */
  74    column_count= mysql_num_fields(prepare_meta_result);
  75    fprintf(stdout, " total columns in SELECT statement: %d\n", column_count);
  76
  77    if (column_count != MAXCOLUMN) /* validate column count */
  78    {
  79      fprintf(stderr, " invalid column count returned by MySQL\n");
  80      exit(0);
  81    }
  82
  83    /* Execute the SELECT query */
  84    if (mysql_stmt_execute(stmt))
  85    {
  86      fprintf(stderr, " mysql_stmt_execute(), failed\n");
  87      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
  88      exit(0);
  89    }
  90
  91    /* Bind the result buffers for all 4 columns before fetching them */
  92
  93    memset(bind, 0, sizeof(bind));
  94
  95    /* INTEGER COLUMN */
  96    bind[0].buffer_type= MYSQL_TYPE_LONG;
  97    bind[0].buffer= (char *)&int_data;
  98    bind[0].is_null= &is_null[0];
  99    bind[0].length= &length[0];
 100
 101    /* STRING COLUMN */
 102    bind[1].buffer_type= MYSQL_TYPE_STRING;
 103    bind[1].buffer= (char *)str_data;
 104    bind[1].buffer_length= STRING_SIZE;
 105    bind[1].is_null= &is_null[1];
 106    bind[1].length= &length[1];
 107
 108    /* SMALLINT COLUMN */
 109    bind[2].buffer_type= MYSQL_TYPE_FLOAT;
 110    bind[2].buffer= (char *)&float_data;
 111    bind[2].is_null= &is_null[2];
 112    bind[2].length= &length[2];
 113
 114    /* TIMESTAMP COLUMN */
 115    bind[3].buffer_type= MYSQL_TYPE_TIMESTAMP;
 116    bind[3].buffer= (char *)&ts;
 117    bind[3].is_null= &is_null[3];
 118    bind[3].length= &length[3];
 119
 120    /* Bind the result buffers */
 121    if (mysql_stmt_bind_result(stmt, bind))
 122    {
 123      fprintf(stderr, " mysql_stmt_bind_result() failed\n");
 124      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
 125      exit(0);
 126    }
 127
 128    /* Now buffer all results to client (optional step) */
 129    if (mysql_stmt_store_result(stmt))
 130    {
 131      fprintf(stderr, " mysql_stmt_store_result() failed\n");
 132      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
 133      exit(0);
 134    }
 135
 136    /* Fetch all rows */
 137    row_count= 0;
 138    fprintf(stdout, "Fetching results ...\n");
 139    while (!mysql_stmt_fetch(stmt))
 140    {
 141      row_count++;
 142      fprintf(stdout, "  row %d\n", row_count);
 143
 144      /* column 1 */
 145      fprintf(stdout, "   column1 (integer)  : ");
 146      if (is_null[0])
 147        fprintf(stdout, " NULL\n");
 148      else
 149        fprintf(stdout, " %d(%ld)\n", int_data, length[0]);
 150
 151      /* column 2 */
 152      fprintf(stdout, "   column2 (string)   : ");
 153      if (is_null[1])
 154        fprintf(stdout, " NULL\n");
 155      else
 156        fprintf(stdout, " %s(%ld)\n", str_data, length[1]);
 157
 158      /* column 3 */
 159      fprintf(stdout, "   column3 (float) : ");
 160      if (is_null[2])
 161        fprintf(stdout, " NULL\n");
 162      else
 163        fprintf(stdout, " %f(%ld)\n", float_data, length[2]);
 164
 165      /* column 4 */
 166      fprintf(stdout, "   column4 (timestamp): ");
 167      if (is_null[3])
 168        fprintf(stdout, " NULL\n");
 169      else
 170        fprintf(stdout, " %04d-%02d-%02d %02d:%02d:%02d (%ld)\n",
 171                         ts.year, ts.month, ts.day,
 172                         ts.hour, ts.minute, ts.second,
 173                         length[3]);
 174      fprintf(stdout, "\n");
 175    }
 176
 177    /* Free the prepared result metadata */
 178    mysql_free_result(prepare_meta_result);
 179
 180    /* Close the statement */
 181    if (mysql_stmt_close(stmt))
 182    {
 183      fprintf(stderr, " failed while closing the statement\n");
 184      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
 185      exit(0);
 186    }
 187
 188 }