test/sqlapi/Select/selecttest1.c

   1 /*   create table T1 with 10 fields,
   2  *   insert 10 rows into the table ,
   3  *   noofprojFields shoul dreturn 10.
   4  *   call fetch and count the record.
   5
   6  *   Author : Jitendra Lenka
   7  */
   8
   9 #include<AbsSqlStatement.h>
  10 #include<SqlFactory.h>
  11 #include<Info.h>
  12 int main()
  13 {
  14   DbRetVal rv = OK;
  15   AbsSqlConnection *con = SqlFactory :: createConnection(CSql);
  16   rv  = con->connect("root","manager");
  17   if(rv!=OK)return 1;
  18
  19   AbsSqlStatement *stmt = SqlFactory :: createStatement(CSql);
  20   stmt->setConnection(con);
  21   char statement[200];
  22
  23   strcpy(statement,"CREATE TABLE T1(F1 INT,F2 SMALLINT,F3 CHAR(30),F4 FLOAT,F5 FLOAT,F6 DATE,F7 TIME,F8 TIMESTAMP,F9 INT,F10 BIGINT);");
  24
  25   int rows=0;
  26   rv = stmt->prepare(statement);
  27   if(rv!=OK)
  28   {
  29     delete stmt;
  30     delete con;
  31     return 2;
  32  }
  33
  34  rv  = stmt->execute(rows);
  35   if(rv!=OK)
  36   {
  37     delete stmt;
  38     delete con;
  39     return 3;
  40  }
  41  stmt->free();
  42  printf("'T1'  table created\n");
  43
  44  //  insert records
  45
  46  strcpy(statement,"INSERT INTO T1 VALUES(?,?,?,?,?,?,?,?,?,?);");
  47
  48  int f1var = 99;
  49  short int f2var = 1;
  50  char f3var[32] = "lakshya";
  51  float f4var = 5.5;
  52  float f5var = 10.50;
  53  Date f6var;
  54  f6var.set(2008,1,21);
  55
  56  Time f7var;
  57  f7var.set(12,29,30);
  58
  59  TimeStamp f8var;
  60  f8var.setDate(2008,1,21);
  61  f8var.setTime(12,29,30);
  62
  63  int f9var = 20;
  64  long long f10var = 12000;
  65
  66  rv = stmt->prepare(statement);
  67  if(rv!=OK)
  68  {
  69    delete stmt;
  70    delete con;
  71    return 4;
  72  }
  73
  74
  75  int count=0;
  76
  77  for(int i=0;i<2;i++)
  78  {
  79    f1var = f1var+i;
  80    for(int j=0;j<5;j++)
  81     {
  82         rv = con->beginTrans();
  83         if(rv!=OK)break;
  84
  85
  86         stmt->setIntParam(1,f1var);
  87         stmt->setShortParam(2,f2var);
  88         stmt->setStringParam(3,f3var);
  89         stmt->setFloatParam(4,f4var);
  90         stmt->setFloatParam(5,f5var);
  91         stmt->setDateParam(6,f6var);
  92         stmt->setTimeParam(7,f7var);
  93         stmt->setTimeStampParam(8,f8var);
  94         stmt->setIntParam(9,f9var);
  95         stmt->setLongLongParam(10,f10var);
  96
  97         rv = stmt->execute(rows);
  98         if(rv!=OK)break;
  99         rv = con->commit();
 100         if(rv!=OK)break;
 101         count++;
 102     }
 103
 104  }
 105   printf("%d Rows Inserted\n",count);
 106   stmt->free();
 107
 108 //*******************************************
 109
 110   strcpy(statement,"SELECT * FROM T1 WHERE F1=100;");
 111   rv = stmt->prepare(statement);
 112
 113    int nop;
 114    nop = stmt->noOfProjFields();
 115    printf("noOfProjFields returns=%d\n",nop);
 116
 117    if(rv !=OK)
 118   {
 119      delete stmt;
 120      delete con;
 121      return 5;
 122   }
 123
 124   stmt->bindField(1,&f1var);
 125   stmt->bindField(2,&f2var);
 126   stmt->bindField(3,f3var);
 127   stmt->bindField(4,&f4var);
 128   stmt->bindField(5,&f5var);
 129   stmt->bindField(6,&f6var);
 130   stmt->bindField(7,&f7var);
 131   stmt->bindField(8,&f8var);
 132   stmt->bindField(9,&f9var);
 133   stmt->bindField(10,&f10var);
 134
 135
 136   count = 0;
 137   rv = con->beginTrans();
 138   if(rv!=OK)return 6;
 139   stmt->execute(rows);
 140   printf("Fetching starts on table 'T1' :\n");
 141   while(stmt->fetch()!=NULL)
 142   {
 143       printf("F1=%d | F2=%hd | F3=%s | F4=%f | F5=%f | DATE=%d-%d-%d | TIME=%d:%d:%d | TIMESTAMP=%d-%d-%d %d:%d:%d | F9=%d | F10=%lld  \n",f1var,f2var,f3var,f4var,f5var,f6var.year(),f6var.month(),f6var.dayOfMonth(),f7var.hours(),f7var.minutes(),f7var.seconds(),f8var.year(),f8var.month(),f8var.dayOfMonth(),f8var.hours(),f8var.minutes(),f8var.seconds(),f9var,f10var);
 144
 145       count++;
 146   }
 147
 148   stmt->close();
 149   rv = con->commit();
 150   if(rv!=OK)
 151   {
 152     delete stmt;
 153     delete con;
 154     return 7;
 155   }
 156
 157   printf("%d Rows fetched\n",count);
 158
 159   stmt->free();
 160
 161  strcpy(statement,"DROP TABLE T1;");
 162  rv = stmt->prepare(statement);
 163  if(rv!=OK)
 164  {
 165    delete stmt;
 166    delete con;
 167    return 8;
 168  }
 169  rv = stmt->execute(rows);
 170  if(rv!=OK)
 171  {
 172    delete stmt;
 173    delete con;
 174    return 9;
 175  }
 176  stmt->free();
 177  printf("'T1' table dropped\n");
 178
 179  delete stmt;
 180  delete con;
 181  return 0;
 182 }
 183
 184
 185