test/dbapi/DataType/doubletest.c

   1 #include<CSql.h>
   2
   3 double  id = 0;
   4 char name[196] = "PRABAKARAN";
   5 int select(Table *table, ComparisionOp op)
   6 {
   7     printf("Operator test for %d\n", op);
   8     Condition p1;
   9     double val1 = 1.3;
  10     p1.setTerm("f1", op, &val1);
  11     table->setCondition(&p1);
  12     table->execute();
  13     void *tuple;
  14     while ((tuple = (char*) table->fetch())) {
  15         printf("tuple value is %g %s \n", id, name);
  16     }
  17     table->close();
  18     return 0;
  19 }
  20
  21 int main()
  22 {
  23
  24     Connection conn;
  25     DbRetVal rv = conn.open("praba", "manager");
  26     if (rv != OK)
  27     {
  28        printf("Error during connection %d\n", rv);
  29        return 1;
  30     }
  31     DatabaseManager *dbMgr = conn.getDatabaseManager();
  32     if (dbMgr == NULL) { printf("Auth failed\n"); return 2;}
  33     TableDef tabDef;
  34     tabDef.addField("f1", typeFloat, 0, NULL, true, true );
  35     tabDef.addField("f2", typeString, 196);
  36     rv = dbMgr->createTable("t1", tabDef);
  37     if (rv != OK) { printf("Table creation failed\n"); return 3; }
  38     printf("Table created\n");
  39 #ifdef WITHINDEX
  40     HashIndexInitInfo *idxInfo = new HashIndexInitInfo();
  41     strcpy(idxInfo->tableName, "t1");
  42     idxInfo->list.append("f1");
  43     idxInfo->indType = hashIndex;
  44     rv = dbMgr->createIndex("indx1", idxInfo);
  45     if (rv != OK) { printf("Index creation failed\n"); return -1; }
  46     printf("Index created\n");
  47 #endif
  48
  49     Table *table = dbMgr->openTable("t1");
  50     if (table == NULL) { printf("Unable to open table\n"); return 4; }
  51     table->bindFld("f1", &id);
  52     table->bindFld("f2", name);
  53     char *tuple;
  54     int ret;
  55     double i;
  56     rv =conn.startTransaction();
  57     for(i = 1.0; i< 1.5; i = i + 0.1)
  58     {
  59         if (rv != OK) exit(5);
  60         id= i;
  61         strcpy(name, "PRABAKARAN0123456750590");
  62         ret = table->insertTuple();
  63         if (ret != 0) break;
  64         printf("Tuple inserted %g\n", i);
  65     }
  66     conn.commit();
  67
  68     conn.startTransaction();
  69     select(table, OpEquals);
  70     conn.commit();
  71
  72     conn.startTransaction();
  73     select(table, OpNotEquals);
  74     conn.commit();
  75
  76     conn.startTransaction();
  77     select(table, OpLessThan);
  78     conn.commit();
  79
  80     conn.startTransaction();
  81     select( table, OpLessThanEquals);
  82     conn.commit();
  83
  84     conn.startTransaction();
  85     select( table, OpGreaterThan);
  86     conn.commit();
  87
  88     conn.startTransaction();
  89     select( table, OpGreaterThanEquals);
  90     conn.commit();
  91
  92     Condition p1;
  93     double val1 = 0;
  94     p1.setTerm("f1", OpEquals, &val1);
  95     table->setCondition(&p1);
  96     rv  = conn.startTransaction();
  97     for(i = 1.0; i< 1.5; i = i +0.1)
  98     {
  99         if (rv != OK) exit (1);
 100         val1 = i;
 101         table->execute();
 102         tuple = (char*)table->fetch() ;
 103         if (tuple == NULL) {printf("loop break in %d\n", i);table->close();break;}
 104         strcpy(name, "PRABAKARAN0950576543210");
 105         table->updateTuple();
 106         table->close();
 107     }
 108     conn.commit();
 109     rv = conn.startTransaction();
 110     for(i = 1; i< 1.5; i++)
 111     {
 112         if (rv != OK) exit (1);
 113         val1 = i;
 114         table->execute();
 115         tuple = (char*)table->fetch() ;
 116         if (tuple == NULL) {printf("loop break in %d\n", i);table->close();break;}
 117         printf("deleting tuple %g %s \n", id, name);
 118         table->deleteTuple();
 119         table->close();
 120     }
 121     conn.commit();
 122
 123     table->setCondition(NULL);
 124     rv = conn.startTransaction();
 125     table->execute();
 126     while ((tuple = (char*) table->fetch())) {
 127         printf("after delete tuple present. Its  value is %g %s \n", id, name);
 128     }
 129     table->close();
 130     conn.commit();
 131
 132     dbMgr->closeTable(table);
 133     dbMgr->dropTable("t1");
 134
 135     conn.close();
 136     return 0;
 137 }