fixing insert query

1 files changed, 9 insertions, 10 deletions

diff --git a/src/my/my_query_helper.c b/src/my/my_query_helper.c
index a8a9ce7b6..4ea1b4ffe 100644
--- a/src/my/my_query_helper.c
+++ b/src/my/my_query_helper.c
@@ -43,9 +43,8 @@ my_conv_fixed_size (void *cls,
 
   qbind->buffer = (void *) qp->data;
   qbind->buffer_length = qp->data_len;
-  qbind->buffer_type = 1;
+  qbind->buffer_type = MYSQL_TYPE_BLOB;
 
-  //return 0;
   return 1;
 }
 
@@ -100,18 +99,18 @@ my_conv_uint16 (void *cls,
   const uint16_t *u_hbo = qp->data;
   uint16_t *u_nbo;
 
-  fprintf(stderr, "input data : %u\n", (unsigned)u_hbo);
-  
   GNUNET_assert (1 == qp->num_params);
 
 
   u_nbo = GNUNET_new (uint16_t);
+  if (NULL == u_nbo)
+    return -1;
+
   *u_nbo = htons (*u_hbo);
   
-  fprintf(stderr, "output data : %u\n", (unsigned)u_nbo);
   qbind->buffer = (void *) u_nbo;
   qbind->buffer_length = sizeof(uint16_t);
-  qbind->buffer_type = 1;
+  qbind->buffer_type = MYSQL_TYPE_SHORT;
 
   return 1;
 }
@@ -158,7 +157,7 @@ my_conv_uint32 (void *cls,
 
   qbind->buffer = (void *) u_nbo;
   qbind->buffer_length = sizeof(uint32_t);
-  qbind->buffer_type = 1;
+  qbind->buffer_type = MYSQL_TYPE_LONG;
 
   return 1;
 }
@@ -205,7 +204,7 @@ my_conv_uint64 (void *cls,
 
   qbind->buffer = (void *) u_nbo;
   qbind->buffer_length = sizeof (uint64_t);
-  qbind->buffer_type = 1;
+  qbind->buffer_type = MYSQL_TYPE_LONGLONG;
 
   return 1;  
 }
@@ -252,7 +251,7 @@ my_conv_rsa_public_key (void *cls,
 
     qbind->buffer = (void *)buf;
     qbind->buffer_length = buf_size - 1;
-    qbind->buffer_type = 1;
+    qbind->buffer_type = MYSQL_TYPE_LONG;
 
     return 1;
   }
@@ -302,7 +301,7 @@ my_conv_rsa_signature (void *cls,
 
   qbind->buffer = (void *)buf;
   qbind->buffer_length = buf_size - 1;
-  qbind->buffer_type = 1;
+  qbind->buffer_type = MYSQL_TYPE_LONG;
 
   return 1;
 }