test/sqlnetwork/Select/selecttest3.c

   1 /*   create table T1 with two fields,
   2  *   insert 10 rows into the table ,
   3  *   select from nonexisting table.
   4
   5  *   Author : Jitendra Lenka
   6  */
   7 #include<SqlNwConnection.h>
   8 #include<SqlNwStatement.h>
   9 #include<SqlFactory.h>
  10
  11 int main()
  12 {
  13   DbRetVal rv = OK;
  14   AbsSqlConnection *con = new SqlNwConnection();
  15   con->setInnerConnection(NULL);
  16   rv  = con->connect("root","manager");
  17   if(rv!=OK)return 1;
  18
  19   AbsSqlStatement *stmt = new SqlNwStatement();
  20   stmt->setInnerStatement(NULL);
  21   stmt->setConnection(con);
  22   char statement[200];
  23
  24   strcpy(statement,"CREATE TABLE T1(F1 INT,F2 CHAR(20));");
  25
  26   int rows=0;
  27   rv = stmt->prepare(statement);
  28   if(rv!=OK)
  29   {
  30     delete stmt;
  31     delete con;
  32     return 1;
  33  }
  34
  35  rv  = stmt->execute(rows);
  36   if(rv!=OK)
  37   {
  38     delete stmt;
  39     delete con;
  40     return 2;
  41  }
  42  printf("Table created\n");
  43
  44  //  insert records
  45
  46  strcpy(statement,"INSERT INTO T1 VALUES(?,?);");
  47
  48  int f1var = 1;
  49  char f2var[21] = "lakshya";
  50
  51
  52  rv = stmt->prepare(statement);
  53  if(rv!=OK)
  54  {
  55    delete stmt;
  56    delete con;
  57    return 3;
  58  }
  59
  60  int count=0;
  61
  62  for(int i=0;i<2;i++)
  63  {
  64
  65    for(int j=0;j<5;j++)
  66     {
  67         f1var = j;
  68         rv = con->beginTrans();
  69         if(rv!=OK)break;
  70
  71
  72         stmt->setIntParam(1,f1var);
  73         stmt->setStringParam(2,f2var);
  74
  75         rv = stmt->execute(rows);
  76         if(rv!=OK)break;
  77         rv = con->commit();
  78         if(rv!=OK)break;
  79         count++;
  80     }
  81     printf("%d rows inserted\n",count);
  82  }
  83
  84 //*******************************************
  85
  86   strcpy(statement,"SELECT * FROM T11;");
  87   rv = stmt->prepare(statement);
  88
  89   if(rv !=OK)
  90   {
  91      printf("test script passed\n");
  92       strcpy(statement,"DROP TABLE T1;");
  93       rv = stmt->prepare(statement);
  94       rv = stmt->execute(rows);
  95       if(rv==OK){printf("Table dropped\n");}
  96      delete stmt;
  97      delete con;
  98      return 0;
  99   }
 100
 101   else if(rv==OK)
 102   {
 103
 104      printf("Test script failed\n");
 105      return 5;
 106   }
 107
 108  else
 109  {
 110   stmt->bindField(1,&f1var);
 111   stmt->bindField(2,f2var);
 112
 113
 114   count = 0;
 115   rv = con->beginTrans();
 116   if(rv!=OK)return 6;
 117   stmt->execute(rows);
 118   while(stmt->fetch()!=NULL)
 119   {
 120      count++;
 121   }
 122
 123   stmt->close();
 124   rv = con->commit();
 125   if(rv!=OK)
 126   {
 127     delete stmt;
 128     delete con;
 129     return 7;
 130   }
 131
 132   printf("Total row fetched=%d\n",count);
 133
 134  }
 135
 136   delete stmt;
 137   delete con;
 138   return 0;
 139 }
 140
 141
 142