Remove hint which has no sense
[anna.git] / example / dbms.mysql / insert / main.cpp
1 #include <stdlib.h>
2 #include <string.h>
3 #include <stdio.h>
4
5 #include <mysql/mysql.h>
6
7 #define STRING_SIZE 50
8
9 #define INSERT_SAMPLE "insert into anna_db_test (xx, yy, zz, tt) values (?,?,?,?)"
10
11
12 #define MAXCOLUMN 4
13
14 MYSQL* mysql;
15 MYSQL_STMT    *stmt;
16 MYSQL_BIND    bind[MAXCOLUMN];
17 MYSQL_TIME    ts;
18 unsigned long length[MAXCOLUMN];
19 int           param_count, column_count, row_count;
20 float         float_data;
21 int           int_data;
22 char          str_data[STRING_SIZE];
23 my_bool       is_null[MAXCOLUMN];
24
25 /*
26  * From http://dev.mysql.com/doc/refman/4.1/en/mysql-stmt-fetch.html
27  */
28 int main (int argc, const char** argv)
29 {
30    if ((mysql = mysql_init (NULL)) == NULL)
31       exit(-12);
32    
33    if (mysql_real_connect (mysql, NULL, "sdp", "sdp", "test", 0, NULL, 0L) == NULL) {
34       fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n");
35       fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
36       exit(0);
37    }   
38    
39    /* Prepare a SELECT query to fetch data from test_table */
40    stmt = mysql_stmt_init(mysql);
41    if (!stmt)
42    {
43      fprintf(stderr, " mysql_stmt_init(), out of memory\n");
44      exit(0);
45    }
46    
47    if (mysql_stmt_prepare(stmt, INSERT_SAMPLE, strlen(INSERT_SAMPLE)))
48    {
49      fprintf(stderr, " mysql_stmt_prepare(), INSERT failed\n");
50      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
51      exit(0);
52    }
53    fprintf(stdout, " prepare, INSERT successful\n");
54
55    /* Get the parameter count from the statement */
56    param_count= mysql_stmt_param_count(stmt);
57    fprintf(stdout, " total parameters in INSERT: %d\n", param_count);
58
59    if (param_count != MAXCOLUMN) /* validate parameter count */
60    {
61      fprintf(stderr, " invalid parameter count returned by MySQL\n");
62      exit(0);
63    }
64
65    /* Bind the result buffers for all 3 columns before fetching them */
66
67    memset(bind, 0, sizeof(bind));
68
69    /* INTEGER COLUMN */
70    bind[0].buffer_type= MYSQL_TYPE_LONG;
71    bind[0].buffer= (char *)&int_data;
72    bind[0].is_null= &is_null[0];
73    bind[0].length= &length[0];
74
75    /* STRING COLUMN */
76    bind[1].buffer_type= MYSQL_TYPE_STRING;
77    bind[1].buffer= (char *)str_data;
78    bind[1].buffer_length= STRING_SIZE;
79    bind[1].is_null= &is_null[1];
80    bind[1].length= &length [1];
81
82    /* FLOAT COLUMN */
83    bind[2].buffer_type= MYSQL_TYPE_FLOAT;
84    bind[2].buffer= (char *)&float_data;
85    bind[2].is_null= &is_null[2];
86    bind[2].length= &length[2];
87
88    /* TIME COLUMN */
89    bind[3].buffer_type= MYSQL_TYPE_DATETIME;
90    bind[3].buffer= (char *)&ts;
91    bind[3].is_null= &is_null[2];
92    bind[3].length= &length[2];
93    
94    /* Bind the result buffers */
95    if (mysql_stmt_bind_param (stmt, bind))
96    {
97      fprintf(stderr, " mysql_stmt_bind_param() failed\n");
98      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
99      exit(0);
100    }
101    
102    int_data = 99;
103    strcpy (str_data, "insert: 99");
104    length [1] = strlen (str_data);
105    float_data = 0.99;
106    ts.year = 1996; ts.month = 2; ts.day = 11; 
107    ts.hour = 19; ts.minute = 22; ts.second = 0;
108    
109    /* Execute the INSERT query */
110    if (mysql_stmt_execute(stmt))
111    {
112      fprintf(stderr, " mysql_stmt_execute(), failed\n");
113      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
114      exit(0);   
115    }
116
117    is_null [0] = 1;
118    strcpy (str_data, "insert: <null>");
119    length [1] = strlen (str_data);
120    float_data = 0.98;
121    ts.year = 1999; ts.month = 8; ts.day = 7; 
122    ts.hour = 19; ts.minute = 18; ts.second = 17;
123
124    /* Execute the INSERT query */
125    if (mysql_stmt_execute(stmt))
126    {
127      fprintf(stderr, " mysql_stmt_execute(), failed\n");
128      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
129      exit(0);   
130    }
131
132    /* Close the statement */
133    if (mysql_stmt_close(stmt))
134    {
135      fprintf(stderr, " failed while closing the statement\n");
136      fprintf(stderr, " %s\n", mysql_stmt_error(stmt));
137      exit(0);
138    }
139
140   return 0;
141 }