test/adapter/Select/selecttest7.c

   1 /*   create table t1 with two fields,
   2  *   insert 10 rows into the table ,
   3  *   call fetch without call execute,it returns NULL.
   4 */
   5
   6 #include "common.h"
   7 int main()
   8 {
   9   DbRetVal rv = OK;
  10   AbsSqlConnection *con = createConnection();
  11   rv  = con->connect("root","manager");
  12   if(rv!=OK)return 1;
  13
  14   AbsSqlStatement *stmt = createStatement();
  15   stmt->setConnection(con);
  16   char statement[200];
  17
  18   strcpy(statement,"CREATE TABLE t1(f1 INT,f2 CHAR(20));");
  19   if(strcmp(getenv("DSN"),"db2")==0)
  20       strcpy(statement,"CREATE TABLE t1(f1 INT,f2 CHAR(20))");
  21
  22   int rows=0;
  23   rv = stmt->prepare(statement);
  24   if(rv!=OK)
  25   {
  26     delete stmt;
  27     delete con;
  28     return 1;
  29  }
  30
  31  rv  = stmt->execute(rows);
  32   if(rv!=OK)
  33   {
  34     delete stmt;
  35     delete con;
  36     return 2;
  37  }
  38  stmt->free();
  39  con->commit();
  40  printf("Table created\n");
  41
  42  //  insert records
  43
  44  strcpy(statement,"INSERT INTO t1 VALUES(?,?);");
  45  if(strcmp(getenv("DSN"),"db2")==0)
  46      strcpy(statement,"INSERT INTO t1 VALUES(?,?)");
  47
  48  int f1var = 1;
  49  char f2var[20] = "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  stmt->free();
  84
  85 //*******************************************
  86
  87   strcpy(statement,"SELECT * FROM t1;");
  88   if(strcmp(getenv("DSN"),"db2")==0)
  89       strcpy(statement,"SELECT * FROM t1");
  90   rv = stmt->prepare(statement);
  91
  92   if(rv !=OK)
  93   {
  94      delete stmt;
  95      delete con;
  96      return 4;
  97   }
  98
  99
 100   stmt->bindField(1,&f1var);
 101   stmt->bindField(2,f2var);
 102
 103   void *ret;
 104   count = 0;
 105   rv = con->beginTrans();
 106   if(rv!=OK)return 5;
 107   //stmt->execute(rows);
 108   while(1)
 109   {
 110
 111       ret = ((char*)stmt->fetch());
 112       if(ret==NULL)
 113       {
 114         printf("Fetch failed without call execute\n");
 115         if(strcmp(getenv("DSN"),"sybase")==0){
 116             stmt->free();
 117             con->commit();
 118         }
 119         strcpy(statement,"DROP TABLE t1;");
 120         if(strcmp(getenv("DSN"),"db2")==0)
 121             strcpy(statement,"DROP TABLE t1");
 122         rv = stmt->prepare(statement);
 123         rv = stmt->execute(rows);
 124         if(rv==OK){ printf("Table dropped successfully\n"); }
 125         stmt->free();
 126         con->commit();
 127         delete stmt;
 128         delete con;
 129         return 0;
 130       }
 131       printf("Test script failed\n");
 132
 133
 134
 135    }
 136
 137   stmt->free();
 138   con->commit();
 139   delete stmt;
 140   delete con;
 141   return 7;
 142 }
 143