test/sqlapi/Connect/conntest10.c

   1 /*  create table T1 ,ISERT ,UPDATE AND COMMIT.
   2  *  FETCH UPDATED RECORDS.
   3
   4  *  Author : Jitendra Lenka
   5  */
   6
   7 #include"common.h"
   8
   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     printf("Connection opened\n");
  16     AbsSqlStatement *stmt = createStatement();
  17     stmt->setConnection(con);
  18     char statement[200];
  19     strcpy(statement,"CREATE TABLE T1(F1 INT,F2 INT);");
  20     int rows = 0;
  21     rv = stmt->prepare(statement);
  22     if(rv!=OK) { delete stmt; delete con; return 2; }
  23     rv = stmt->execute(rows);
  24     if(rv!=OK) { delete stmt; delete con; return 3; }
  25     stmt->free();
  26     printf("Table T1 CREATED\n");
  27     // insert into statement
  28     strcpy(statement,"INSERT INTO T1 VALUES(1,1);");
  29     rv = stmt->prepare(statement);
  30     if(rv!=OK) { delete stmt; delete con; return 4; }
  31     rv = con->beginTrans();
  32     if(rv!=OK) { delete stmt; delete con; return 5; }
  33     rv = stmt->execute(rows); if(rv!=OK) return 6;
  34     stmt->free();
  35     printf("One record inserted\n");
  36     // update statement
  37     printf("update T1 set F2=100\n");
  38     strcpy(statement,"UPDATE T1 SET F2=100;");
  39     rv = stmt->prepare(statement);
  40     if(rv !=OK) { delete stmt; delete con; return 7; }
  41     rv = stmt->execute(rows);
  42     if(rv!=OK){ printf ("Hello\n"); return 8; }
  43     rv  = con->commit(); if(rv!=OK)return 9;
  44     printf("One row updated\n");
  45     strcpy(statement,"SELECT F2 FROM T1 ;");
  46     rv = stmt->prepare(statement);
  47     if(rv!=OK) { delete stmt; delete con; return 10; }
  48     int id=10;
  49     stmt->bindField(1,&id);
  50     rv = con->beginTrans();
  51     if(rv!=OK)return 11;
  52     stmt->execute(rows);
  53     int count=0;
  54     while(stmt->fetch()!=NULL) {
  55         printf("F2= %d\n",id);
  56         count++;
  57     }
  58     stmt->close();
  59     rv = con->commit();
  60     if(rv!=OK)return 12;
  61     printf("Total record fetched=%d\n",count);
  62     stmt->free();
  63     strcpy(statement,"DROP TABLE T1;");
  64     rv = stmt->prepare(statement);
  65     if(rv!=OK) { delete stmt; delete con; return 13; }
  66     rv = stmt->execute(rows);
  67     if(rv!=OK) { delete stmt; delete con; return 14; }
  68     printf("TABLE T1 DROPPED SUCCESSFULLY\n");
  69     stmt->free(); delete stmt; delete con;
  70     printf("Connection closed successfully\n");
  71     return 0;
  72 }