4 #include <mysql/mysql.h>
8 #define SELECT_SAMPLE "SELECT xx, yy, zz, tt FROM anna_db_test"
14 MYSQL_BIND bind[MAXCOLUMN];
15 MYSQL_RES *prepare_meta_result;
17 unsigned long length[MAXCOLUMN];
18 int param_count, column_count, row_count;
21 char str_data[STRING_SIZE];
22 my_bool is_null[MAXCOLUMN];
25 * From http://dev.mysql.com/doc/refman/4.1/en/mysql-stmt-fetch.html
29 if ((mysql = mysql_init (NULL)) == NULL)
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));
38 /* Prepare a SELECT query to fetch data from test_table */
39 stmt = mysql_stmt_init(mysql);
42 fprintf(stderr, " mysql_stmt_init(), out of memory\n");
46 if (mysql_stmt_prepare(stmt, SELECT_SAMPLE, strlen(SELECT_SAMPLE)))
48 fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");
49 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
52 fprintf(stdout, " prepare, SELECT successful\n");
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);
58 if (param_count != 0) /* validate parameter count */
60 fprintf(stderr, " invalid parameter count returned by MySQL\n");
64 /* Fetch result set meta information */
65 prepare_meta_result = mysql_stmt_result_metadata(stmt);
66 if (!prepare_meta_result)
68 fprintf(stderr," mysql_stmt_result_metadata(), returned no meta information\n");
69 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
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);
77 if (column_count != MAXCOLUMN) /* validate column count */
79 fprintf(stderr, " invalid column count returned by MySQL\n");
83 /* Execute the SELECT query */
84 if (mysql_stmt_execute(stmt))
86 fprintf(stderr, " mysql_stmt_execute(), failed\n");
87 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
91 /* Bind the result buffers for all 4 columns before fetching them */
93 memset(bind, 0, sizeof(bind));
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];
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];
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];
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];
120 /* Bind the result buffers */
121 if (mysql_stmt_bind_result(stmt, bind))
123 fprintf(stderr, " mysql_stmt_bind_result() failed\n");
124 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
128 /* Now buffer all results to client (optional step) */
129 if (mysql_stmt_store_result(stmt))
131 fprintf(stderr, " mysql_stmt_store_result() failed\n");
132 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
138 fprintf(stdout, "Fetching results ...\n");
139 while (!mysql_stmt_fetch(stmt))
142 fprintf(stdout, " row %d\n", row_count);
145 fprintf(stdout, " column1 (integer) : ");
147 fprintf(stdout, " NULL\n");
149 fprintf(stdout, " %d(%ld)\n", int_data, length[0]);
152 fprintf(stdout, " column2 (string) : ");
154 fprintf(stdout, " NULL\n");
156 fprintf(stdout, " %s(%ld)\n", str_data, length[1]);
159 fprintf(stdout, " column3 (float) : ");
161 fprintf(stdout, " NULL\n");
163 fprintf(stdout, " %f(%ld)\n", float_data, length[2]);
166 fprintf(stdout, " column4 (timestamp): ");
168 fprintf(stdout, " NULL\n");
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,
174 fprintf(stdout, "\n");
177 /* Free the prepared result metadata */
178 mysql_free_result(prepare_meta_result);
180 /* Close the statement */
181 if (mysql_stmt_close(stmt))
183 fprintf(stderr, " failed while closing the statement\n");
184 fprintf(stderr, " %s\n", mysql_stmt_error(stmt));