test/sqlnetwork/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<SqlNwConnection.h>
  10 #include<SqlNwStatement.h>
  11 #include<SqlFactory.h>
  12 #include<Info.h>
  13 int main()
  14 {
  15   DbRetVal rv = OK;
  16   AbsSqlConnection *con = new SqlNwConnection();
  17   con->setInnerConnection(NULL);
  18   rv  = con->connect("root","manager");
  19   if(rv!=OK)return 1;
  20
  21   AbsSqlStatement *stmt = new SqlNwStatement();
  22   stmt->setInnerStatement(NULL);
  23   stmt->setConnection(con);
  24   char statement[200];
  25
  26   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);");
  27
  28   int rows=0;
  29   rv = stmt->prepare(statement);
  30   if(rv!=OK) { delete stmt; delete con; return 2; }
  31
  32  rv  = stmt->execute(rows);
  33   if(rv!=OK) { delete stmt; delete con; return 3; }
  34  printf("'T1'  table created\n");
  35
  36  //  insert records
  37
  38  strcpy(statement,"INSERT INTO T1 VALUES(?,?,?,?,?,?,?,?,?,?);");
  39
  40  int f1var = 99;
  41  short int f2var = 1;
  42  char f3var[31] = "lakshya";
  43  float f4var = 5.5;
  44  float f5var = 10.50;
  45  Date f6var;
  46  f6var.set(2008,1,21);
  47
  48  Time f7var;
  49  f7var.set(12,29,30);
  50
  51  TimeStamp f8var;
  52  f8var.setDate(2008,1,21);
  53  f8var.setTime(12,29,30);
  54
  55  int f9var = 20;
  56  long long f10var = 12000;
  57
  58  rv = stmt->prepare(statement);
  59  if(rv!=OK) { delete stmt; delete con; return 4; }
  60
  61
  62  int count=0;
  63
  64  for(int i=0;i<2;i++)
  65  {
  66    f1var = f1var+i;
  67    for(int j=0;j<5;j++)
  68     {
  69         rv = con->beginTrans();
  70         if(rv!=OK)break;
  71
  72
  73         stmt->setIntParam(1,f1var);
  74         stmt->setShortParam(2,f2var);
  75         stmt->setStringParam(3,f3var);
  76         stmt->setFloatParam(4,f4var);
  77         stmt->setFloatParam(5,f5var);
  78         stmt->setDateParam(6,f6var);
  79         stmt->setTimeParam(7,f7var);
  80         stmt->setTimeStampParam(8,f8var);
  81         stmt->setIntParam(9,f9var);
  82         stmt->setLongLongParam(10,f10var);
  83
  84         rv = stmt->execute(rows);
  85         if(rv!=OK)break;
  86         rv = con->commit();
  87         if(rv!=OK)break;
  88         count++;
  89     }
  90
  91  }
  92   printf("%d Rows Inserted\n",count);
  93
  94 //*******************************************
  95
  96   strcpy(statement,"SELECT * FROM T1 WHERE F1=100;");
  97   rv = stmt->prepare(statement);
  98
  99    int nop;
 100    nop = stmt->noOfProjFields();
 101    printf("noOfProjFields returns=%d\n",nop);
 102
 103    if(rv !=OK) { delete stmt; delete con; return 5; }
 104
 105   stmt->bindField(1,&f1var);
 106   stmt->bindField(2,&f2var);
 107   stmt->bindField(3,f3var);
 108   stmt->bindField(4,&f4var);
 109   stmt->bindField(5,&f5var);
 110   stmt->bindField(6,&f6var);
 111   stmt->bindField(7,&f7var);
 112   stmt->bindField(8,&f8var);
 113   stmt->bindField(9,&f9var);
 114   stmt->bindField(10,&f10var);
 115
 116
 117   count = 0;
 118   rv = con->beginTrans();
 119   if(rv!=OK)return 6;
 120   stmt->execute(rows);
 121   printf("Fetching starts on table 'T1' :\n");
 122   while(stmt->fetch()!=NULL)
 123   {
 124       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);
 125
 126       count++;
 127   }
 128
 129   stmt->close();
 130   rv = con->commit();
 131   if(rv!=OK) { delete stmt; delete con; return 7; }
 132
 133   printf("%d Rows fetched\n",count);
 134
 135
 136  strcpy(statement,"DROP TABLE T1;");
 137  rv = stmt->prepare(statement);
 138  if(rv!=OK) { delete stmt; delete con; return 8; }
 139  rv = stmt->execute(rows);
 140  if(rv!=OK) { delete stmt; delete con; return 9; }
 141  printf("'T1' table dropped\n");
 142
 143  delete stmt;
 144  delete con;
 145  return 0;
 146 }
 147
 148
 149