test/sqlnetwork/Connect/conntest10.c

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