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
   8 #include<AbsSqlStatement.h>
   9 #include<SqlFactory.h>
  10 int main()
  11 {
  12    DbRetVal rv = OK;
  13    AbsSqlConnection *con = SqlFactory::createConnection(CSql);
  14    rv = con->connect("root","manager");
  15    if(rv !=OK)return 1;
  16    printf("Connection opened\n");
  17
  18    AbsSqlStatement *stmt = SqlFactory::createStatement(CSql);
  19    stmt->setConnection(con);
  20    char statement[200];
  21    strcpy(statement,"CREATE TABLE T1(F1 INT,F2 INT);");
  22
  23    int rows = 0;
  24    rv = stmt->prepare(statement);
  25    if(rv!=OK) { delete stmt; delete con; return 2; }
  26
  27    rv = stmt->execute(rows);
  28    if(rv!=OK) { delete stmt; delete con; return 3; }
  29    stmt->free();
  30    printf("Table T1 CREATED\n");
  31
  32    // insert into statement
  33    strcpy(statement,"INSERT INTO T1 VALUES(1,1);");
  34    rv = stmt->prepare(statement);
  35    if(rv!=OK) { delete stmt; delete con; return 4; }
  36
  37    rv = con->beginTrans();
  38    if(rv!=OK) { delete stmt; delete con; return 5; }
  39
  40    rv = stmt->execute(rows); if(rv!=OK) return 6;
  41    stmt->free();
  42    printf("One record inserted\n");
  43
  44    // update statement
  45
  46    printf("update T1 set F2=100\n");
  47    strcpy(statement,"UPDATE T1 SET F2=100;");
  48
  49    rv = stmt->prepare(statement);
  50    if(rv !=OK) { delete stmt; delete con; return 7; }
  51
  52
  53     rv = stmt->execute(rows);
  54     if(rv!=OK){ printf ("Hello\n"); return 8; }
  55     rv  = con->commit(); if(rv!=OK)return 9;
  56     printf("One row updated\n");
  57
  58
  59     strcpy(statement,"SELECT F2 FROM T1 ;");
  60     rv = stmt->prepare(statement);
  61     if(rv!=OK) { delete stmt; delete con; return 10; }
  62
  63     int id=10;
  64     stmt->bindField(1,&id);
  65     rv = con->beginTrans();
  66     if(rv!=OK)return 11;
  67     stmt->execute(rows);
  68     int count=0;
  69     while(stmt->fetch()!=NULL)
  70     {
  71       printf("F2= %d\n",id);
  72       count++;
  73     }
  74     stmt->close();
  75     rv = con->commit();
  76     if(rv!=OK)return 12;
  77     printf("Total reccord fetchec=%d\n",count);
  78     stmt->free();
  79
  80     strcpy(statement,"DROP TABLE T1;");
  81     rv = stmt->prepare(statement);
  82     if(rv!=OK) { delete stmt; delete con; return 13; }
  83
  84     rv = stmt->execute(rows);
  85     if(rv!=OK) { delete stmt; delete con; return 14; }
  86
  87     printf("TABLE T1 DROPPED SUCCESSFULLY\n");
  88     stmt->free();
  89     delete stmt;
  90     delete con;
  91     printf("Connection closed successfully\n");
  92     return 0;
  93 }
  94