/* 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" #include "gnunet_mysql_lib.h" #include "gnunet_util_lib.h" /** * Run actual test queries. * * @param contexte the current context of mysql * @return 0 on succes */ static int run_queries (struct GNUNET_MYSQL_Context *context) { 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; const char msg[] = "hello"; void *msg2; size_t msg2_len; uint16_t u16; uint16_t u162; uint32_t u32; uint32_t u322; uint64_t u64; uint64_t u642; int ret; struct GNUNET_MYSQL_StatementHandle *statements_handle_insert; struct GNUNET_MYSQL_StatementHandle *statements_handle_select; struct GNUNET_CRYPTO_RsaPrivateKey *priv; struct GNUNET_HashCode hmsg; 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; statements_handle_insert = GNUNET_MYSQL_statement_prepare (context, "INSERT INTO test_my2 (" " pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" ") VALUES " "( ?, ?, ?, ?, ?, ?, ?, ?, ?)"); if (NULL == statements_handle_insert) { fprintf (stderr, "Failed to prepared statement INSERT\n"); return 1; } 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 }; /* statements_handle_insert = GNUNET_MYSQL_statement_prepare (context, "INSERT INTO test_my2 (" " abs_time" ",forever" ",hash" ",u16" ",u32" ",u64" ") VALUES " "( ?, ?, ?, ?, ?, ?)"); struct GNUNET_MY_QueryParam params_insert[] = { 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_uint16 (&u16), GNUNET_MY_query_param_uint32 (&u32), GNUNET_MY_query_param_uint64 (&u64), GNUNET_MY_query_param_end }; */ if (GNUNET_OK != GNUNET_MY_exec_prepared(context, statements_handle_insert, params_insert)) { fprintf (stderr, "Failed to execute prepared statement INSERT\n"); return 1; } /* statements_handle_select = GNUNET_MYSQL_statement_prepare (context, "SELECT" " pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" " FROM test_my" " ORDER BY abs_time DESC " " LIMIT 1;"); */ statements_handle_select = GNUNET_MYSQL_statement_prepare (context, "SELECT" " pub" ",sig" ",abs_time" ",forever" ",hash" ",vsize" ",u16" ",u32" ",u64" " FROM test_my2"); if (NULL == statements_handle_select) { fprintf(stderr, "Failed to prepared statement SELECT\n"); return 1; } struct GNUNET_MY_QueryParam params_select[] = { GNUNET_MY_query_param_end }; if (GNUNET_OK != GNUNET_MY_exec_prepared (context, statements_handle_select, params_select)) { fprintf (stderr, "Failed to execute prepared statement SELECT\n"); return 1; } /* 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 }; */ 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 }; ret = GNUNET_MY_extract_result (statements_handle_select, results_select); 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 (strlen (msg) == msg2_len); GNUNET_break (0 == strncmp (msg, msg2, msg2_len)); fprintf(stderr, "msg2 : %d\n", strlen(msg2)); GNUNET_break (16 == u162); GNUNET_break (32 == u322); GNUNET_break (64 == u642); if (GNUNET_OK != ret) { fprintf(stderr, "Failed to extract result\n"); return 1; } return 0; } int main (int argc, const char * const argv[]) { struct GNUNET_CONFIGURATION_Handle *config; struct GNUNET_MYSQL_Context *context; int ret; GNUNET_log_setup ( "test-my", "WARNING", NULL); config = GNUNET_CONFIGURATION_create (); if (GNUNET_OK != GNUNET_CONFIGURATION_parse (config, "test_my.conf")) { fprintf (stderr, "Failed to parse configuaration\n"); return 1; } context = GNUNET_MYSQL_context_create (config, "datastore-mysql"); if (NULL == context) { fprintf(stderr, "Failed to connect to database\n"); return 77; } (void) GNUNET_MYSQL_statement_run (context, "DROP TABLE test_my2;"); if (GNUNET_OK != GNUNET_MYSQL_statement_run (context, "CREATE TABLE IF NOT EXISTS test_my2(" " pub BLOB NOT NULL" ",sig BLOB NOT NULL" ",abs_time BIGINT NOT NULL" ",forever BIGINT NOT NULL" ",hash BLOB NOT NULL CHECK(LENGTH(hash)=64)" ",vsize BLOB NOT NULL" ",u16 SMALLINT NOT NULL" ",u32 INT NOT NULL" ",u64 BIGINT NOT NULL" ")")) { fprintf (stderr, "Failed to create table \n"); GNUNET_MYSQL_statements_invalidate (context); GNUNET_MYSQL_context_destroy (context); return 1; } /* if (GNUNET_OK != GNUNET_MYSQL_statement_run (context, "CREATE TABLE test_my2(" " abs_time BIGINT NOT NULL" ", forever BIGINT NOT NULL" ", hash VARCHAR(32) NOT NULL CHECK(LENGTH(hash)=64)" ", u16 SMALLINT NOT NULL" ", u32 INT NOT NULL" ", u64 BIGINT NOT NULL" ")")) { fprintf (stderr, "Failed to create table \n"); GNUNET_MYSQL_statements_invalidate (context); GNUNET_MYSQL_context_destroy (context); return 1; } */ ret = run_queries (context); /* if(GNUNET_OK != GNUNET_MYSQL_statement_run (context, "DROP TABLE test_my2")) { fprintf (stderr, "Failed to drop table test_my\n"); GNUNET_MYSQL_statements_invalidate (context); } GNUNET_MYSQL_context_destroy (context); */ return ret; }