=== modified file 'src/main.c'
--- src/main.c  2012-09-09 18:35:09 +0000
+++ src/main.c  2014-09-27 22:04:19 +0000
@@ -392,10 +392,10 @@

   /* EXEC SQL WHENEVER SQLERROR GOTO sqlerr; */

-  for( i=0; i < num_conn; i++ ){
+/*  for( i=0; i < num_conn; i++ ){
     ctx[i] = mysql_init(NULL);
     if(!ctx[i]) goto sqlerr;
-  }
+  }*/

   for( t_num=0; t_num < num_conn; t_num++ ){
     thd_arg[t_num].port= port;
@@ -662,7 +662,7 @@
   int r,i;

   char *db_string_ptr;
-  MYSQL* resp;
+  MYSQL* resp=NULL;

   db_string_ptr = db_string;

@@ -671,13 +671,21 @@
   if(num_node > 0){ /* RAC mode */
     db_string_ptr = node_string[((num_node * t_num)/num_conn)];
   }
-
+  ctx[t_num]= mysql_init(NULL);
   if(is_local==1){
     /* exec sql connect :connect_string; */
-    resp = mysql_real_connect(ctx[t_num], "localhost", db_user, db_password, db_string, port, NULL, 0);
+    if(!(resp = mysql_real_connect(ctx[t_num], "localhost", db_user, db_password, db_string, port, NULL, 0)))
+       {
+               fprintf(stderr,"cannot connect!\n");
+               goto sqlerr;
+       }
   }else{
     /* exec sql connect :connect_string USING :db_string; */
-    resp = mysql_real_connect(ctx[t_num], connect_string, db_user, db_password, db_string, port, NULL, 0);
+    if(!(resp = mysql_real_connect(ctx[t_num], connect_string, db_user, db_password, db_string, port, NULL, 0)))
+       {
+               fprintf(stderr,"cannot connect!!\n");
+               goto sqlerr;
+       }
   }

   if(resp) {