test/dbapi/Connection/conntest11.c

   1 //Update a tuple in a transation and commit it.
   2 // Next scan should display the update tuple.
   3
   4 #include<CSql.h>
   5 #include<NanoTimer.h>
   6 int main()
   7 {
   8
   9     Connection conn;
  10     DbRetVal rv = conn.open("root", "manager");
  11     if (rv != OK)
  12     {
  13        printf("Error during connection %d\n", rv);
  14        return 1;
  15     }
  16
  17
  18     DatabaseManager *dbMgr = conn.getDatabaseManager();
  19     if (dbMgr == NULL) { printf("Auth failed\n"); return 2;}
  20
  21
  22     TableDef tabDef;
  23     tabDef.addField("f1", typeInt);
  24     tabDef.addField("f2", typeString, 196);
  25     rv = dbMgr->createTable("t1", tabDef);
  26     if (rv != OK) { printf("Table creation failed\n"); return 3; }
  27     printf("Table created\n");
  28
  29     Table *table = dbMgr->openTable("t1");
  30     if (table == NULL) { printf("Unable to open table\n"); return 3; }
  31     int id;
  32     char name[200]="PRABA";
  33     table->bindFld("f1", &id);
  34     table->bindFld("f2", name);
  35     int icount = 0;
  36     int i;
  37
  38     conn.startTransaction();
  39     for (i=0;i<10;i++)
  40     {
  41       id=i;
  42       rv=table->insertTuple();
  43       if(rv!=OK)
  44       {
  45          printf("Insertion failed at %d th tuple",i);
  46          dbMgr->closeTable(table);
  47          dbMgr->dropTable("t1");
  48          conn.close();
  49          return 4;
  50       }
  51     }
  52     conn.commit();
  53
  54     conn.startTransaction();
  55     table->setCondition(NULL);
  56     rv = table->execute();
  57     if (rv != OK)
  58     {
  59        dbMgr->closeTable(table);
  60        dbMgr->dropTable("t1");
  61        conn.close();
  62        return 6;
  63     }
  64     printf("Scan before updation\n");
  65     printf("********************\n");
  66     void *fld2ptr, *tuple;
  67     while(true)
  68     {
  69         tuple = (char*)table->fetch() ;
  70         if (tuple == NULL) {break;}
  71         printf("Binded Tuple value is %d %s \n", id, name);
  72
  73     }
  74     conn.commit();
  75     rv=table->closeScan();
  76     if(rv!=OK){ printf("Error in closing the table\n"); return 3;}
  77
  78     Condition p1;
  79     int val1 = 5;
  80     p1.setTerm("f1",OpEquals, &val1);
  81     table->setCondition(&p1);
  82     conn.startTransaction();
  83     rv=table->execute();
  84     if (rv != OK)
  85     {
  86        dbMgr->closeTable(table);
  87        dbMgr->dropTable("t1");
  88        conn.close();
  89        return 4;
  90     }
  91
  92 //    char *tuple;
  93     //printf("Scan After:\n");
  94     while(true)
  95     {
  96         tuple = (char*)table->fetch() ;
  97         if (tuple == NULL) { break; }
  98         strcpy(name,"Kanchana");
  99         table->updateTuple();
 100        printf("    f1=%d f2=%s\n", id, name);
 101        // icount++;
 102     }
 103    conn.commit();
 104    table->closeScan();
 105
 106
 107     conn.startTransaction();
 108
 109     table->setCondition(NULL);
 110     rv = table->execute();
 111     if (rv != OK)
 112     {
 113        dbMgr->closeTable(table);
 114        dbMgr->dropTable("t1");
 115        conn.close();
 116        return 6;
 117     }
 118     printf("Scan After updation\n");
 119     printf("********************\n");
 120     while(true)
 121     {
 122         tuple = (char*)table->fetch() ;
 123         if (tuple == NULL) {break;}
 124         printf("Binded Tuple value is %d %s \n", id, name);
 125
 126     }
 127     conn.commit();
 128
 129     //unset the condtion set as we need to delete all rows
 130     table->setCondition(NULL);
 131     table->closeScan();
 132     dbMgr->closeTable(table);
 133     dbMgr->dropTable("t1");
 134     conn.close();
 135    // printf("Test script passed ");
 136     return 0;
 137 }