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