test/dbapi/Predicate/predicate1.c

   1 /*
   2 a. f1=10
   3 b. f1!= 10
   4 c. f1<10
   5 d. f1<=10
   6 e. f1>10
   7 f. f1>=10
   8 */
   9 #include<CSql.h>
  10 int id=0;
  11 char name[100];//="NIHAR";
  12 int select(Table *table, ComparisionOp op)
  13 {
  14     printf("Operator Test for %d\n",op);
  15     Condition p1;
  16     int val1=10;
  17     p1.setTerm("f1",op,&val1);
  18     table->setCondition(&p1);
  19     table->execute();
  20     void *tuple;
  21     while((tuple=(char*) table->fetch()))
  22     {
  23         printf("Tuple is %d %s \n",id,name);
  24     }
  25     table->close();
  26     return 0;
  27 }
  28
  29 int main()
  30 {
  31     Connection conn;
  32     DbRetVal rv=conn.open("root","manager");
  33     if (rv != OK)
  34     {
  35        printf("Error during connection %d\n", rv);
  36        return 1;
  37     }
  38     DatabaseManager *dbMgr = conn.getDatabaseManager();
  39     if (dbMgr == NULL) { printf("Auth failed\n"); return 2;}
  40     TableDef tabDef;
  41     tabDef.addField("f1", typeInt, 0, NULL, true );
  42     tabDef.addField("f2", typeString, 100);
  43     rv = dbMgr->createTable("t1", tabDef);
  44     if (rv != OK) { printf("Table creation failed\n"); return 3; }
  45     printf("Table created\n");
  46 #ifdef WITHINDEX
  47     HashIndexInitInfo *idxInfo = new HashIndexInitInfo();
  48     strcpy(idxInfo->tableName, "t1");
  49     idxInfo->list.append("f1");
  50     idxInfo->indType = hashIndex;
  51     rv = dbMgr->createIndex("indx1", idxInfo);
  52     if (rv != OK) { printf("Index creation failed\n"); return -1; }
  53     printf("Index created\n");
  54     delete idxInfo;
  55 #endif
  56     Table *table = dbMgr->openTable("t1");
  57     if (table == NULL) { printf("Unable to open table\n"); return 4; }
  58     table->bindFld("f1", &id);
  59     table->bindFld("f2", name);
  60     char *tuple;
  61     int ret;
  62     int i;
  63     char nam[100];
  64     rv =conn.startTransaction();
  65     for(i = 6; i< 12; i++)
  66     {
  67         if (rv != OK) exit(5);
  68         id= i;
  69         sprintf(nam,"%s%d","NIHAR",i);
  70         strcpy(name, nam);
  71         ret = table->insertTuple();
  72         if (ret != 0) break;
  73     }
  74     conn.commit();
  75     conn.startTransaction();
  76     select(table, OpEquals);
  77     conn.commit();
  78
  79     conn.startTransaction();
  80     select(table, OpNotEquals);
  81     conn.commit();
  82
  83     conn.startTransaction();
  84     select(table, OpLessThan);
  85     conn.commit();
  86
  87     conn.startTransaction();
  88     select( table, OpLessThanEquals);
  89     conn.commit();
  90
  91     conn.startTransaction();
  92     select( table, OpGreaterThan);
  93     conn.commit();
  94
  95     conn.startTransaction();
  96     select( table, OpGreaterThanEquals);
  97     conn.commit();
  98
  99     dbMgr->closeTable(table);
 100     dbMgr->dropTable("t1");
 101
 102     conn.close();
 103     return 0;
 104 }
 105