/* This file is part of GNUnet Copyright (C) 2016 GNUnet e.V. GNUnet is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 3, or (at your option) any later version. GNUnet is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with GNUnet; see the file COPYING. If not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */ /** * @file my/test_my.c * @brief Tests for convenience MySQL database * @author Christophe Genevey */ #include "platform.h" #include #include "gnunet_my_lib.h" /** * Setup prepared statements. * * @param mysql connection handle to initialize * @return #GNUNET_OK on success #GNUNET_SYSERR on failure */ /** OK **/ static int mysql_prepare (MYSQL * mysql) { MYSQL_STMT *stmt; stmt = mysql_stmt_init (mysql); #define PREPARE(name, sql, size) \ do { \ int ret = mysql_stmt_prepare (stmt, sql, size); \ if (ret ) \ { \ GNUNET_break (0); \ mysql_stmt_free_result (stmt); \ return GNUNET_SYSERR; \ } \ mysql_stmt_free_result (stmt); \ } while (0); char *query1 = "INSERT INTO test_my (" "pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" ") VALUES " "(1, 2, 3, 4, 5, 6," "7, 8, 9);"; PREPARE("test_insert", query1, strlen (query1)); char *query2 = "SELECT" "pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" " FROM test_my" " ORDER BY abs_time DESC" " LIMIT 1;"; PREPARE("test_select", query2, strlen (query2)); return GNUNET_OK; #undef PREPARE } /** * Run actual test queries. * * @param mysql coonection handle to initialize * @return 0 on succes */ /*** FIXE THIS FUNCTION ***/ static int run_queries (MYSQL * mysql) { struct GNUNET_CRYPTO_RsaPublicKey *pub; // struct GNUNET_CRYPTO_RsaPublicKey *pub2 = NULL; struct GNUNET_CRYPTO_RsaSignature *sig; // struct GNUNET_CRYPTO_RsaSignature *sig2 = NULL; struct GNUNET_TIME_Absolute abs_time = GNUNET_TIME_absolute_get () ; // struct GNUNET_TIME_Absolute abs_time2; struct GNUNET_TIME_Absolute forever = GNUNET_TIME_UNIT_FOREVER_ABS; // struct GNUNET_TIME_Absolute forever2; struct GNUNET_HashCode hc; // struct GNUNET_HashCode hc2; // MYSQL_RES * result; // int ret; struct GNUNET_CRYPTO_RsaPrivateKey *priv; const char msg[] = "hello"; // void *msg2; struct GNUNET_HashCode hmsg; // size_t msg2_len; uint16_t u16; // uint16_t u162; uint32_t u32; // uint32_t u322; uint64_t u64; // uint64_t u642; priv = GNUNET_CRYPTO_rsa_private_key_create (1024); pub = GNUNET_CRYPTO_rsa_private_key_get_public (priv); memset (&hmsg, 42, sizeof (hmsg)); sig = GNUNET_CRYPTO_rsa_sign_fdh (priv, &hmsg); u16 = 16; u32 = 32; u64 = 64; // struct GNUNET_CONFIGURATION_Handle * configuration_handle = NULL; // configuration_handle = GNUNET_CONFIGURATION_create(); /* char *query1 = "INSERT INTO test_my (" "pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" ") VALUES " "(1, 2, 3, 4, 5, 6," "7, 8, 9);"; */ /* char *query2 = "SELECT" "pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" " FROM test_my" " ORDER BY abs_time DESC" " LIMIT 1;"; */ struct GNUNET_MYSQL_Context *context_insert = NULL; // context_insert = GNUNET_MYSQL_context_create (configuration_handle, // NULL); struct GNUNET_MYSQL_StatementHandle *statements_handle = NULL; // statements_handle = GNUNET_MYSQL_statement_prepare(context_insert, query1); // { struct GNUNET_MY_QueryParam params_insert[] = { GNUNET_MY_query_param_rsa_public_key (pub), GNUNET_MY_query_param_rsa_signature (sig), GNUNET_MY_query_param_absolute_time (&abs_time), GNUNET_MY_query_param_absolute_time (&forever), GNUNET_MY_query_param_auto_from_type (&hc), GNUNET_MY_query_param_fixed_size (msg, strlen (msg)), GNUNET_MY_query_param_uint16 (&u16), GNUNET_MY_query_param_uint32 (&u32), GNUNET_MY_query_param_uint64 (&u64), GNUNET_MY_query_param_end }; /* struct GNUNET_MY_QueryParam params_select[] = { GNUNET_MY_query_param_end }; struct GNUNET_MY_Context *context_insert[] = { }; struct GNUNET_MY_StatementHandle *statement_insert[] = { }; */ /* struct GNUNET_MY_ResultSpec results_select[] = { GNUNET_MY_result_spec_rsa_public_key (&pub2), GNUNET_MY_result_spec_rsa_signature (&sig2), GNUNET_MY_result_spec_absolute_time (&abs_time2), GNUNET_MY_result_spec_absolute_time (&forever2), GNUNET_MY_result_spec_auto_from_type (&hc2), GNUNET_MY_result_spec_variable_size (&msg2, &msg2_len), GNUNET_MY_result_spec_uint16 (&u162), GNUNET_MY_result_spec_uint32 (&u322), GNUNET_MY_result_spec_uint64 (&u642), GNUNET_MY_result_spec_end }; */ if(GNUNET_MY_exec_prepared ( context_insert, statements_handle, params_insert)); { GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Database failure: \n"); //free result GNUNET_CRYPTO_rsa_signature_free (sig); GNUNET_CRYPTO_rsa_private_key_free (priv); GNUNET_CRYPTO_rsa_public_key_free (pub); return 1; } //free result /* result = GNUNET_MY_exec_prepared (mysql, "test_select", params_select); if(1 != mysql_fetch_length (result)) { GNUNET_break (0); GNUNET_CRYPTO_rsa_signature_free (sig); GNUNET_CRYPTO_rsa_private_key_free (priv); GNUNET_CRYPTO_rsa_public_key_free (pub); return 1; } if (GNUNET_MY_exec_prepared (mysql , "test_select" , params_select)) { GNUNET_break (0); GNUNET_CRYPTO_rsa_signature_free (sig); GNUNET_CRYPTO_rsa_private_key_free (priv); GNUNET_CRYPTO_rsa_public_key_free (pub); return 1; } ret = GNUNET_MY_extract_result (result, results_select, 0); GNUNET_break (GNUNET_YES == ret); GNUNET_break (abs_time.abs_value_us == abs_time2.abs_value_us); GNUNET_break (forever.abs_value_us == forever2.abs_value_us); GNUNET_break (0 == memcmp (&hc, &hc2, sizeof (struct GNUNET_HashCode))); GNUNET_break (0 == GNUNET_CRYPTO_rsa_signature_cmp (sig, sig2)); GNUNET_break (0 == GNUNET_CRYPTO_rsa_public_key_cmp (pub, pub2)); GNUNET_break (strlen (msg) == msg2_len); GNUNET_break (0 == strncmp (msg, msg2, msg2_len)); GNUNET_break (16 == u162); GNUNET_break (32 == u322); GNUNET_break (64 == u642); } GNUNET_CRYPTO_rsa_signature_free (sig); GNUNET_CRYPTO_rsa_private_key_free (priv); GNUNET_CRYPTO_rsa_public_key_free (pub); if (GNUNET_OK != ret) return 1; */ return 0; } /** REWRITTEN THIS FUNCTION **/ int main (int argc, const char * const argv[]) { //CREATE A CONTEXTE struct GNUNET_DATASTORE_PluginEnvironment *env; struct GNUNET_MYSQL_Context *context; GNUNET_log_setup ( "test-my", "WARNING", NULL); context = GNUNET_MYSQL_context_create (NULL /* TO FIXE ***/, "datastore-mysql"); struct GNUNET_MYSQL_StatementHandle *statements_handle; statements_handle = GNUNET_MYSQL_statement_prepare (context, "CREATE TABLE test_my(" "pub INT" ", sig INT" ", abs_time BIGINT" ", forever BIGINT" ", hash INT" ", vsize VARCHAR" ", u16 SMALLINT" ", u32 INT" ", u64 BIGINT" ")"); //USE GNUNET_MY_exec_prepared GNUNET_MY_exec_prepared(context, statements_handle, NULL); if (GNUNET_OK != GNUNET_MYSQL_context_destroy (context)) { //ERROR } return GNUNET_OK; /* NEW VERSION TO FIXE if (GNUNET_OK != mysql_prepare (&mysql)) { GNUNET_break (0) ; mysql_close (&mysql); return 1; } int ret; ret = run_queries (&mysql); if (mysql_query (&mysql, "DROP TABLE test_my;")) { fprintf (stderr, "Failed to drop table : %s\n", mysql_error (&mysql)); mysql_close (&mysql); return 1; } */ /* OLD VERSION (use SQL basic function) ret = run_queries (); MYSQL mysql ; MYSQL_RES *result; int ret; char *hote = ""; char *pseudo = ""; char *mdp = ""; char *database = ""; mysql_init (&mysql); mysql_options (&mysql, MYSQL_READ_DEFAULT_GROUP, NULL); GNUNET_log_setup ( "test-my", "WARNING", NULL); if ( mysql_real_connect (&mysql ,hote ,pseudo ,mdp,database ,0 ,NULL ,0 )) { fprintf( stderr, "Cannot run test, database connection failed : %s\n", mysql_error (&mysql)); GNUNET_break (0); return 0; } if (mysql_query (&mysql, "CREATE TABLE test_my(" "pub INT" ", sig INT" ", abs_time BIGINT" ", forever BIGINT" ", hash INT" ", vsize VARCHAR" ", u16 SMALLINT" ", u32 INT" ", u64 BIGINT" ")")) { fprintf (stderr, "Failed to create table : %s\n", mysql_error (&mysql)); mysql_close (&mysql); return 1; } if (GNUNET_OK != mysql_prepare (&mysql)) { GNUNET_break (0) ; mysql_close (&mysql); return 1; } ret = run_queries (&mysql); if (mysql_query (&mysql, "DROP TABLE test_my;")) { fprintf (stderr, "Failed to drop table : %s\n", mysql_error (&mysql)); mysql_close (&mysql); return 1; } mysql_close (&mysql); return ret; */ }