lcov test function

1 files changed, 27 insertions, 4 deletions

diff --git a/src/my/my_result_helper.c b/src/my/my_result_helper.c
index 963e3f618..c0a1dff4d 100644
--- a/src/my/my_result_helper.c
+++ b/src/my/my_result_helper.c
@@ -501,10 +501,11 @@ pre_extract_string (void * cls,
                 unsigned int column,
                 MYSQL_BIND *results)
 {
-  results[0].buffer = (char *)rs->dst;
-  results[0].buffer_length = rs->dst_size;
+  results[0].buffer = NULL;
+  results[0].buffer_length = 0;
   results[0].length = &rs->mysql_bind_output_length;
- 
+  results[0].buffer_type = MYSQL_TYPE_BLOB;
+
   return GNUNET_OK;
 }
 
@@ -528,8 +529,30 @@ post_extract_string (void * cls,
                 unsigned int column,
                 MYSQL_BIND *results)
 {
-  if (rs->dst_size != rs->mysql_bind_output_length)
+  size_t size;
+
+  size = (size_t) rs->mysql_bind_output_length;
+  char buf[size];
+
+  if (rs->mysql_bind_output_length != size)
+    return GNUNET_SYSERR;
+
+  results[0].buffer = buf;
+  results[0].buffer_length = size;
+  results[0].buffer_type = MYSQL_TYPE_BLOB;
+
+  if (0 !=
+      mysql_stmt_fetch_column (stmt,
+                               results,
+                               column,
+                               0))
+  {
+    GNUNET_free (buf);
     return GNUNET_SYSERR;
+  }
+
+  rs->dst = buf;
+
   return GNUNET_OK;
 }