test/sqlnetwork/Connect/conntest5.c

   1 /*  create table T1 ,Insert some records in it.
   2  *  Close the connection, Fetch should fail.
   3
   4  *  Author : Jitendra Lenka
   5  */
   6
   7 # include <SqlNwConnection.h>
   8 # include <SqlNwStatement.h>
   9 #include<SqlFactory.h>
  10 int main()
  11 {
  12    DbRetVal rv = OK;
  13    AbsSqlConnection *con = new SqlNwConnection();
  14    con->setInnerConnection(NULL);
  15    SqlNwConnection *conn = (SqlNwConnection *)con;
  16    conn->setHost("localhost", 5678);
  17    rv = con->connect("root","manager");
  18    if(rv !=OK)return 1;
  19    printf("Connection opened\n");
  20
  21    AbsSqlStatement *stmt = new SqlNwStatement();
  22    stmt->setInnerStatement(NULL);
  23    stmt->setConnection(con);
  24    char statement[200];
  25    strcpy(statement,"CREATE TABLE T1(F1 INT,F2 INT);");
  26
  27    int rows = 0;
  28    rv = stmt->prepare(statement);
  29    if(rv!=OK) { delete stmt; delete con; return 2; }
  30
  31    rv = stmt->execute(rows);
  32    if(rv!=OK) { delete stmt; delete con; return 3; }
  33    printf("Table T1 CREATED\n");
  34
  35    // insert into statement
  36    strcpy(statement,"INSERT INTO T1 VALUES(1,1);");
  37    rv = stmt->prepare(statement);
  38    if(rv!=OK) { delete stmt; delete con; return 4; }
  39
  40    rv = con->beginTrans();
  41    if(rv!=OK) { delete stmt; delete con; return 5; }
  42
  43    rv = stmt->execute(rows); if(rv!=OK) return 6;
  44    rv = con->commit();
  45    if(rv!=OK) return 7;
  46    printf("One record inserted\n");
  47
  48    strcpy(statement,"SELECT F2 FROM T1 ;");
  49    rv = stmt->prepare(statement);
  50    if(rv!=OK) { delete stmt; delete con; return 10; }
  51
  52     int id=10;
  53     stmt->bindField(1,&id);
  54     rv = con->beginTrans();
  55     if(rv!=OK)return 11;
  56     stmt->execute(rows);
  57     int count=0;
  58     stmt->close();
  59     stmt->free();
  60     rv = con->disconnect(); //close the connection
  61
  62     void *rettype;
  63     if(rv!=OK)return 8;
  64     rettype = (char*)stmt->fetch(rv);
  65     if(rettype==NULL && rv == ErrNoConnection) {
  66         con->connect("root", "manager");
  67         stmt->setConnection(con);
  68         strcpy(statement,"DROP TABLE T1;");
  69         rv = stmt->prepare(statement);
  70         if (rv != OK) { return 9; }
  71         rv = stmt->execute(rows);
  72         if(rv==OK){printf("Table Dropped successfully\n");}
  73                 printf("Test script passed\n");
  74         delete stmt;
  75         delete con;
  76         return 0;
  77     }
  78     strcpy(statement,"DROP TABLE T1;");
  79     rv = stmt->prepare(statement);
  80     rv = stmt->execute(rows);
  81     if(rv==OK){printf("Table Dropped successfully\n");}
  82     printf("Test script Failed\n");
  83     delete stmt;
  84     delete con;
  85     return 7;
  86 }