test/durability/redologs/stmtTest5.c

   1 #include <SqlFactory.h>
   2
   3 int main(int argc, char **argv)
   4 {
   5     DbRetVal rv = OK;
   6     struct timeval timeout;
   7     struct timeval timeStamp;
   8     AbsSqlConnection *con = SqlFactory::createConnection(CSql);
   9     rv = con->connect("root","manager");
  10     if(rv!=OK)return 1;
  11     AbsSqlStatement *stmt = SqlFactory::createStatement(CSql);
  12     stmt->setConnection(con);
  13     char statement[200];
  14     int rows =0;
  15
  16     // insert into table
  17     strcpy(statement,"INSERT INTO t1 VALUES(1234,?);");
  18     rv = stmt->prepare(statement);
  19     if(rv!=OK) { delete stmt; delete con; return 4; }
  20     int rnd = 0;
  21     rv = con->beginTrans();
  22     stmt->setIntParam(1, 100);
  23     rv = stmt->execute(rows);
  24     stmt->setIntParam(1, 200);
  25     rv = stmt->execute(rows);
  26     if (rv != OK) {
  27         printError(rv, "Insert failed with ret val %d", rv);
  28     }
  29     con->commit();
  30     stmt->free();
  31
  32     strcpy(statement, "create index idx on t1 (f2) primary hash;");
  33     rv = stmt->prepare(statement);
  34     if(rv!=OK) { delete stmt; delete con; return 4; }
  35     rv = stmt->execute(rows);
  36     if (rv != OK) {
  37         printError(rv, "create idx failed with ret val %d", rv);
  38     }
  39     stmt->free();
  40
  41     strcpy(statement,"INSERT INTO t1 VALUES(1234,?);");
  42     rv = stmt->prepare(statement);
  43     stmt->setIntParam(1, 100);
  44     if(rv!=OK) { delete stmt; delete con; return 4; }
  45     rv = con->beginTrans();
  46     rv = stmt->execute(rows);
  47     if (rv != OK) {
  48         printError(rv, "insert failed with ret val %d", rv);
  49     }
  50     con->commit();
  51     stmt->free();
  52
  53     strcpy(statement,"drop index idx;");
  54     rv = stmt->prepare(statement);
  55     if(rv!=OK) { delete stmt; delete con; return 4; }
  56     rv = stmt->execute(rows);
  57     if (rv != OK) {
  58         printError(rv, "drop idx failed with ret val %d", rv);
  59     }
  60     stmt->free();
  61
  62     strcpy(statement,"INSERT INTO t1 VALUES(1234,?);");
  63     rv = stmt->prepare(statement);
  64     stmt->setIntParam(1, 100);
  65     if(rv!=OK) { delete stmt; delete con; return 4; }
  66     rv = con->beginTrans();
  67     int val =0;
  68     rv = stmt->execute(rows);
  69     con->commit();
  70     stmt->free();
  71
  72     con->disconnect();
  73     delete stmt;
  74     delete con;
  75 }