[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r37198 - gnunet/src/my
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r37198 - gnunet/src/my |
|
Date: |
Tue, 24 May 2016 18:16:42 +0200 |
Author: christophe.genevey
Date: 2016-05-24 18:16:41 +0200 (Tue, 24 May 2016)
New Revision: 37198
Added:
gnunet/src/my/test_my.c
Log:
test case for mysql
Added: gnunet/src/my/test_my.c
===================================================================
--- gnunet/src/my/test_my.c (rev 0)
+++ gnunet/src/my/test_my.c 2016-05-24 16:16:41 UTC (rev 37198)
@@ -0,0 +1,327 @@
+/*
+ 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 <mysql/mysql.h>
+#include "gnunet_my_lib.h"
+
+/**
+ * Setup prepared statements.
+ *
+ * @param mysql connection handle to initialize
+ * @return
+ #GNUNET_OK on success
+ #GNUNET_SYSERR on failure
+ */
+static int
+mysql_prepare (MYSQL * mysql)
+{
+ MYSQL_RES *result;
+ MYSQL_STMT *stmt;
+
+ stmt = mysql_stmt_init (mysql);
+#define PREPARE (name, sql, ...)
+ do
+ {
+ result = mysql_stmt_prepare(stmt, name, sql, __VA_ARGS__);
+ if (result)
+ {
+ GNUNET_break (0);
+ mysql_stmt_free_result (stmt);
+ result = NULL;
+ return GNUNET_SYSERR;
+ }
+ mysql_stmt_free_result (stmt);
+ result = NULL;
+ } while (0);
+
+ PREPARE ("test_insert",
+ "INSERT INTO test_my ("
+ "pub"
+ ",sig"
+ ",abs_time"
+ ",forever"
+ ",hash"
+ ",vsize"
+ ",u16"
+ ",u32"
+ ",u64"
+ ") VALUES "
+ "($1, $2, $3, $4, $5, $6,
+ $7, $8, $9);",
+ 9, NULL);
+
+ PREPARE ("test_select",
+ "SELECT"
+ "pub"
+ ",sig"
+ ",abs_time"
+ ",forever"
+ ",hash"
+ ",vsize"
+ ",u16"
+ ",u32"
+ ",u64"
+ " FROM test_my"
+ " ORDER BY abs_time DESC"
+ " LIMIT 1;",
+ 0, NULL);
+ return GNUNET_OK;
+#undef PREPARE
+}
+
+/**
+ * Run actual test queries.
+ *
+ * @param mysql coonection handle to initialize
+ * @return 0 on succes
+ */
+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_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_ResultSpec results_select[] = {
+ GNUNET_MY_result_spec_rsa_public_key ("pub", &pub2),
+ GNUNET_MY_result_spec_rsa_signature ("sig", &sig2),
+ GNUNET_MY_result_spec_absolute_time ("abs_time", &abs_time2),
+ GNUNET_MY_result_spec_absolute_time ("forever", &forever2),
+ GNUNET_MY_result_spec_auto_from_type ("hash", &hc2),
+ GNUNET_MY_result_spec_variable_size ("vsize", &msg2, &msg2_len),
+ GNUNET_MY_result_spec_uint16 ("u16", &u162),
+ GNUNET_MY_result_spec_uint32 ("u32", &u322),
+ GNUNET_MY_result_spec_uint64 ("u64", &u642),
+ GNUNET_MY_result_epc_end
+ };
+
+ if(GNUNET_MY_exec_prepared ( mysql,
+ "test_insert",
+ 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_CYPTO_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;
+}
+
+
+int
+main (int argc, const char * const argv[])
+{
+
+ 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;
+}
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r37198 - gnunet/src/my,
gnunet <=