2 This file is part of GNUnet
3 Copyright (C) 2016 GNUnet e.V.
5 GNUnet is free software; you can redistribute it and/or modify
6 it under the terms of the GNU General Public License as published
7 by the Free Software Foundation; either version 3, or (at your
8 option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 General Public License for more details.
15 You should have received a copy of the GNU General Public License
16 along with GNUnet; see the file COPYING. If not, write to the
17 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
18 Boston, MA 02110-1301, USA.
22 * @brief Tests for convenience MySQL database
23 * @author Christophe Genevey
26 #include <mysql/mysql.h>
27 #include "gnunet_my_lib.h"
28 #include "gnunet_mysql_lib.h"
29 #include "gnunet_util_lib.h"
32 * Run actual test queries.
34 * @param contexte the current context of mysql
38 run_queries (struct GNUNET_MYSQL_Context *context)
40 struct GNUNET_CRYPTO_RsaPublicKey *pub;
41 // struct GNUNET_CRYPTO_RsaPublicKey *pub2 = NULL;
42 struct GNUNET_CRYPTO_RsaSignature *sig;
43 // struct GNUNET_CRYPTO_RsaSignature *sig2 = NULL;
44 struct GNUNET_TIME_Absolute abs_time = GNUNET_TIME_absolute_get ();
45 // struct GNUNET_TIME_Absolute abs_time2;
46 struct GNUNET_TIME_Absolute forever = GNUNET_TIME_UNIT_FOREVER_ABS;
47 // struct GNUNET_TIME_Absolute forever2;
48 struct GNUNET_HashCode hc;
49 // struct GNUNET_HashCode hc2;
50 const char msg[] = "hello";
62 msg_len = sizeof(msg);
66 struct GNUNET_MYSQL_StatementHandle *statements_handle_insert;
68 // struct GNUNET_MYSQL_StatementHandle *statements_handle_select;
70 struct GNUNET_CRYPTO_RsaPrivateKey *priv;
71 struct GNUNET_HashCode hmsg;
73 priv = GNUNET_CRYPTO_rsa_private_key_create (1024);
74 pub = GNUNET_CRYPTO_rsa_private_key_get_public (priv);
75 memset (&hmsg, 42, sizeof(hmsg));
76 sig = GNUNET_CRYPTO_rsa_sign_fdh (priv,
82 statements_handle_insert = GNUNET_MYSQL_statement_prepare (context,
83 "INSERT INTO test_my ("
94 "( ?, ?, ?, ?, ?, ?, ?, ?, ?)");
96 if (NULL == statements_handle_insert)
98 fprintf (stderr, "Failed to prepared statement INSERT\n");
102 struct GNUNET_MY_QueryParam params_insert[] = {
103 GNUNET_MY_query_param_rsa_public_key (pub),
104 GNUNET_MY_query_param_rsa_signature (sig),
105 GNUNET_MY_query_param_absolute_time (&abs_time),
106 GNUNET_MY_query_param_absolute_time (&forever),
107 GNUNET_MY_query_param_auto_from_type (&hc),
108 GNUNET_MY_query_param_fixed_size (msg, strlen (msg)),
109 GNUNET_MY_query_param_uint16 (&u16),
110 GNUNET_MY_query_param_uint32 (&u32),
111 GNUNET_MY_query_param_uint64 (&u64),
112 GNUNET_MY_query_param_end
115 if (GNUNET_OK != GNUNET_MY_exec_prepared(context,
116 statements_handle_insert,
119 fprintf (stderr, "Failed to execute prepared statement INSERT\n");
125 /* statements_handle_select = GNUNET_MYSQL_statement_prepare (context,
137 " ORDER BY abs_time DESC "
140 if (NULL == statements_handle_select)
142 fprintf(stderr, "Failed to prepared statement SELECT\n");
146 struct GNUNET_MY_QueryParam params_select[] = {
147 GNUNET_MY_query_param_end
150 if (GNUNET_OK != GNUNET_MY_exec_prepared (context,
151 statements_handle_select,
154 fprintf (stderr, "Failed to execute prepared statement SELECT\n");
159 struct GNUNET_MY_ResultSpec results_select[] = {
160 GNUNET_MY_result_spec_rsa_public_key (&pub2),
161 GNUNET_MY_result_spec_rsa_signature (&sig2),
162 GNUNET_MY_result_spec_absolute_time (&abs_time2),
163 GNUNET_MY_result_spec_absolute_time (&forever2),
164 GNUNET_MY_result_spec_auto_from_type (&hc2),
165 GNUNET_MY_result_spec_variable_size (&msg2, &msg2_len),
166 GNUNET_MY_result_spec_uint16 (&u162),
167 GNUNET_MY_result_spec_uint32 (&u322),
168 GNUNET_MY_result_spec_uint64 (&u642),
169 GNUNET_MY_result_spec_end
172 ret = GNUNET_MY_extract_result (statements_handle_select,
176 if (GNUNET_OK != ret)
178 fprintf(stderr, "Failed to extract result\n");
187 main (int argc, const char * const argv[])
189 struct GNUNET_CONFIGURATION_Handle *config;
190 struct GNUNET_MYSQL_Context *context;
194 GNUNET_log_setup ( "test-my",
198 config = GNUNET_CONFIGURATION_create ();
201 fprintf (stderr, "Failed to create a configuration\n");
205 if (GNUNET_OK != GNUNET_CONFIGURATION_parse (config, "test_my.conf"))
207 fprintf (stderr, "Failed to parse configuaration\n");
211 context = GNUNET_MYSQL_context_create (config,
215 fprintf(stderr, "Failed to connect to database\n");
219 if (GNUNET_OK != GNUNET_MYSQL_statement_run (context,
220 "CREATE TABLE test_my("
223 ", abs_time BIGINT NOT NULL"
224 ", forever BIGINT NOT NULL"
225 ", hash VARCHAR(32) NOT NULL CHECK(LENGTH(hash)=64)"
226 ", vsize VARCHAR(32) NOT NULL"
227 ", u16 SMALLINT NOT NULL"
229 ", u64 BIGINT NOT NULL"
233 "Failed to create table \n");
234 GNUNET_MYSQL_statements_invalidate (context);
235 GNUNET_MYSQL_context_destroy (context);
240 ret = run_queries (context);
242 /* if(GNUNET_OK != GNUNET_MYSQL_statement_run (context,
243 "DROP TABLE test_my"))
245 fprintf (stderr, "Failed to drop table test_my\n");
246 GNUNET_MYSQL_statements_invalidate (context);
249 GNUNET_MYSQL_context_destroy (context);