test/sqlgw/Select/selecttest2.c

   1 /*   create table T1 with 10 fields,
   2  *   insert 10 rows into the table ,
   3  *   noofprojFields should return 5.
   4  *   getProjFldInfo() for all fields.
   5  *   select with 5 parameters withIwhere clause.(WHERE F1=100)
   6 */
   7
   8 #include "common.h"
   9 int main()
  10 {
  11     DbRetVal rv = OK;
  12     AbsSqlConnection *con = createConnection();
  13     rv  = con->connect("root","manager");
  14     if(rv!=OK)return 1;
  15
  16     AbsSqlStatement *stmt = createStatement();
  17     stmt->setConnection(con);
  18     char statement[200];
  19
  20     int rows=0;
  21
  22    //  insert records
  23
  24     if(strcmp(getenv("DSN"),"oracle")==0){
  25         strcpy(statement,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?);");
  26     }
  27     else if(strcmp(getenv("DSN"),"db2")==0){
  28         strcpy(statement,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?,?)");
  29     } else {
  30         strcpy(statement,"INSERT INTO t1 VALUES(?,?,?,?,?,?,?,?,?,?);");
  31     }
  32
  33     int f1var = 99;
  34     short int f2var = 1;
  35     char f3var[32] = "lakshya";
  36     float f4var = 5.5;
  37     float f5var = 10.50;
  38     Date f6var;
  39     f6var.set(2008,1,21);
  40
  41     Time f7var;
  42     f7var.set(12,29,30);
  43
  44     TimeStamp f8var;
  45     f8var.setDate(2008,1,21);
  46     f8var.setTime(12,29,30);
  47
  48     int f9var = 20;
  49     long long f10var = 12000;
  50
  51     rv = stmt->prepare(statement);
  52     if(rv!=OK) { delete stmt; delete con; return 4; }
  53
  54     int count=0;
  55
  56     for(int i=0;i<2;i++) {
  57         f1var = f1var+i;
  58         for(int j=0;j<5;j++) {
  59             rv = con->beginTrans();
  60             if(rv!=OK)break;
  61             stmt->setIntParam(1,f1var);
  62             stmt->setShortParam(2,f2var);
  63             stmt->setStringParam(3,f3var);
  64                 stmt->setFloatParam(4,f4var);
  65             stmt->setFloatParam(5,f5var);
  66             stmt->setDateParam(6,f6var);
  67             if(strcmp(getenv("DSN"),"oracle")==0){
  68                 stmt->setTimeStampParam(7,f8var);
  69                 stmt->setIntParam(8,f9var);
  70                 stmt->setLongLongParam(9,f10var);
  71             }else{
  72                 stmt->setTimeParam(7,f7var);
  73                 stmt->setTimeStampParam(8,f8var);
  74                 stmt->setIntParam(9,f9var);
  75                 stmt->setLongLongParam(10,f10var);
  76             }
  77                 rv = stmt->execute(rows);
  78             if(rv!=OK)break;
  79             rv = con->commit();
  80             if(rv!=OK)break;
  81             count++;
  82         }
  83
  84     }
  85     printf("%d Rows Inserted\n",count);
  86     stmt->free();
  87
  88 //*******************************************
  89
  90     strcpy(statement,"SELECT f8,f10,f2,f6,f3  FROM t1 WHERE f1=100;");
  91     if(strcmp(getenv("DSN"),"db2")==0)
  92         strcpy(statement,"SELECT f8,f10,f2,f6,f3  FROM t1 WHERE f1=100");
  93     rv = stmt->prepare(statement);
  94
  95     int nop;
  96     nop = stmt->noOfProjFields();
  97     if(nop!=5)return 1;
  98     printf("Total number of projection fields in the select statement=%d\n",nop);
  99
 100    // getParamFldInfo()
 101     FieldInfo *field = new FieldInfo();
 102
 103     char fldName[20];
 104     DataType type;
 105     size_t length;
 106     int offset;
 107     char defaultValueBuf[10];
 108     bool isNull;
 109     bool isDefault;
 110
 111     delete field;
 112
 113     if(rv !=OK) { delete stmt; delete con; return 5; }
 114
 115     stmt->bindField(1,&f8var);
 116     stmt->bindField(2,&f10var);
 117     stmt->bindField(3,&f2var);
 118     stmt->bindField(4,&f6var);
 119     stmt->bindField(5,f3var);
 120     count = 0;
 121     rv = con->beginTrans();
 122     if(rv!=OK)return 6;
 123     stmt->execute(rows);
 124     while(stmt->fetch()!=NULL) {
 125         if(strcmp(getenv("DSN"),"oracle")==0)
 126              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);
 127         else
 128              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);
 129
 130         count++;
 131     }
 132
 133   stmt->close();
 134   rv = con->commit();
 135   if(rv!=OK) { delete stmt; delete con; return 6; }
 136
 137   printf("Total row fetched=%d\n",count);
 138
 139   stmt->free(); delete stmt; delete con; return 0;
 140 }
 141
 142
 143