/**
* @file my/my.c
* @brief library to help with access to a MySQL database
+ * @author Christophe Genevey
* @author Christian Grothoff
*/
#include "platform.h"
#include <mysql/mysql.h>
#include "gnunet_my_lib.h"
-
+#define STRING_SIZE 50
/**
* Run a prepared SELECT statement.
* @param mc mysql context
* @param sh handle to SELECT statment
* @param params parameters to the statement
- * @return mysql result
+ * @return
+ #GNUNET_YES if we can prepare all statement
+ #GNUNET_SYSERR if we can't prepare all statement
*/
- /***** FIXE THIS FUNCTION *****/
int
GNUNET_MY_exec_prepared (struct GNUNET_MYSQL_Context *mc,
struct GNUNET_MYSQL_StatementHandle *sh,
GNUNET_MYSQL_statements_invalidate (mc);
return GNUNET_SYSERR;
}
+
}
if (mysql_stmt_execute (stmt))
{
GNUNET_MYSQL_statements_invalidate (mc);
return GNUNET_SYSERR;
}
+
return GNUNET_OK;
}
/**
- * Extract results from a query result according
- * to the given specification. If colums are NULL,
- * the destination is not modified, and #GNUNET_NO is returned4
+ * Extract results from a query result according to the given
+ * specification. Always fetches the next row.
*
*
- * @param result
- * @param row, the row from the result to extract
- * @param result specificatio to extract for
+ * @param sh statement that returned results
+ * @param rs specification to extract for
* @return
- #GNUNET_YES if all results could be extracted
- #GNUNET_NO if at least one result was NULL
- #GNUNET_SYSERR if a result was invalid
-*/
+ * #GNUNET_YES if all results could be extracted
+ * #GNUNET_NO if there is no more data in the result set
+ * #GNUNET_SYSERR if a result was invalid
+ */
int
-GNUNET_MY_extract_result (MYSQL_BIND * result,
- struct GNUNET_MY_QueryParam *qp,
- struct GNUNET_MY_ResultSpec *rs,
- int row)
+GNUNET_MY_extract_result (struct GNUNET_MYSQL_StatementHandle *sh,
+ struct GNUNET_MY_ResultSpec *rs)
{
+ unsigned int num_fields;
unsigned int i;
- int had_null = GNUNET_NO;
int ret;
+ MYSQL_STMT *stmt;
- for (i = 0 ; NULL != rs[i].conv ; i++)
+ stmt = GNUNET_MYSQL_statement_get_stmt (NULL /* FIXME */, sh);
+ if (NULL == stmt)
{
- struct GNUNET_MY_ResultSpec *spec;
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, "mysql",
+ ("`%s' failed at %s:%d with error: %s\n"),
+ "mysql_stmt_bind_result", __FILE__, __LINE__,
+ mysql_stmt_error (stmt));
+ return GNUNET_SYSERR;
+ }
- spec = &rs[i];
- ret = spec->conv (spec->conv_cls,
- qp,
- result);
+ num_fields = 0;
+ for (i=0;NULL != rs[i].pre_conv;i++)
+ num_fields += rs[i].num_fields;
- if (GNUNET_SYSERR == ret)
+ if (mysql_stmt_field_count (stmt) != num_fields)
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Number of fields missmatch between SQL result and result specification\n");
+ return GNUNET_SYSERR;
+ }
+
+ {
+ MYSQL_BIND result[num_fields];
+ unsigned int field_off;
+
+ memset (result, 0, sizeof (MYSQL_BIND) * num_fields);
+ field_off = 0;
+ for (i=0;NULL != rs[i].pre_conv;i++)
{
- //GNUNET_MY_cleanup_result(rs);
+ struct GNUNET_MY_ResultSpec *rp = &rs[i];
+
+ if (GNUNET_OK !=
+ rp->pre_conv (rp->conv_cls,
+ rp,
+ stmt,
+ field_off,
+ &result[field_off]))
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Pre-conversion for MySQL result failed at offset %u\n",
+ i);
+ GNUNET_MY_cleanup_result (rs);
+ return GNUNET_SYSERR;
+ }
+ field_off += rp->num_fields;
+ }
+ if (mysql_stmt_bind_result (stmt, result))
+ {
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
+ "my",
+ _("`%s' failed at %s:%d with error: %s\n"),
+ "mysql_stmt_bind_result", __FILE__, __LINE__,
+ mysql_stmt_error (stmt));
return GNUNET_SYSERR;
}
- if (NULL != spec->result_size)
- *spec->result_size = spec->dst_size;
+ ret = mysql_stmt_fetch (stmt);
+
+ if (MYSQL_DATA_TRUNCATED == ret)
+ {
+ fprintf(stderr, "Data truncated with error %d \n", ret);
+ fprintf(stderr, "nontruncated length of the parameter values : %d\n", rs[0].mysql_bind_output_length);
+ return GNUNET_SYSERR;
+ }
+
+ if (MYSQL_NO_DATA == ret)
+ return GNUNET_NO;
+ if (0 != ret)
+ {
+ GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR,
+ "my",
+ _("mysql_stmt_fetch failed at %s:%d with error: %s\n"),
+ __FILE__, __LINE__,
+ mysql_stmt_error (stmt));
+ return GNUNET_SYSERR;
+ }
+ field_off = 0;
+ for (i=0;NULL != rs[i].post_conv;i++)
+ {
+ struct GNUNET_MY_ResultSpec *rp = &rs[i];
+
+ if (NULL != rp->post_conv)
+ if (GNUNET_OK !=
+ rp->post_conv (rp->conv_cls,
+ rp,
+ stmt,
+ field_off,
+ &result[field_off]))
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Post-conversion for MySQL result failed at offset %u\n",
+ i);
+ GNUNET_MY_cleanup_result (rs);
+ return GNUNET_SYSERR;
+ }
+ field_off += rp->num_fields;
+ }
}
+ return GNUNET_OK;
+}
- if (GNUNET_YES == had_null)
- return GNUNET_NO;
- return GNUNET_OK;
+/**
+ * Free all memory that was allocated in @a rs during
+ * #GNUNET_MY_extract_result().
+ *
+ * @param rs reult specification to clean up
+ */
+void
+GNUNET_MY_cleanup_result (struct GNUNET_MY_ResultSpec *rs)
+{
+ unsigned int i;
+
+ for (i=0;NULL != rs[i].cleaner;i++)
+ rs[i].cleaner (rs[i].conv_cls,
+ &rs[i]);
}
+
/* end of my.c */
projects / oweals / gnunet.git / blobdiff