demo/gateway/odbc/GwStmt.c

   1 //  INSERT SOME TUPLES IN IT. AND FETCH ALL THE TUPLES.
   2
   3
   4 #include<stdio.h>
   5 #include<stdlib.h>
   6 #include<sql.h>
   7 #include<sqlext.h>
   8 #include<string.h>
   9
  10
  11
  12 //*************************************************************************
  13 // ERROR CHECK FUNCTION
  14 inline void checkrc(int rc,int line)
  15 {
  16    if(rc)
  17    {
  18        printf("ERROR %d at line %d\n",rc,line);
  19        exit(1);
  20    }
  21 }
  22
  23 //*************************************************************************
  24 // FUNCTION FOR INSERTING ROWS IN IT.
  25 int  InsertTest(SQLHANDLE env,SQLHANDLE dbc,SQLHANDLE stmt)
  26 {
  27
  28       int ret;
  29       int f1=50; // f1 field
  30       char f2[50]= "Praba";
  31       SQLINTEGER slen = SQL_NTS;
  32       ret = SQLPrepare(stmt,(unsigned char*)"INSERT INTO t1 VALUES(?,?)",SQL_NTS);
  33       checkrc(ret,__LINE__);
  34
  35       // BIND PARAMETER FOR ALL THE FIELD
  36
  37       ret = SQLBindParameter(stmt,1,SQL_PARAM_INPUT,SQL_C_SLONG,SQL_INTEGER,0,0,&f1,0,NULL);
  38       checkrc(ret,__LINE__);
  39
  40       ret = SQLBindParameter(stmt,2,SQL_PARAM_INPUT,SQL_C_CHAR,SQL_CHAR,196,0,(void*)f2,0,&slen);
  41       checkrc(ret,__LINE__);
  42
  43       int i,count=0;
  44       // EXECUTE THE STATEMENT
  45       for(i=0;i<10;i++)
  46       {
  47          f1++;
  48          ret = SQLExecute(stmt);
  49          checkrc(ret,__LINE__);
  50          ret = SQLTransact(env,dbc,SQL_COMMIT);
  51          checkrc(ret,__LINE__);
  52          count++;
  53       }
  54       printf("Total row inserted=%d\n",count);
  55   }
  56 //***********************************************************************
  57 // FETCH ROWS FROM THE TABLE "t1"......select * from T1;
  58 int FetchTest(SQLHANDLE env, SQLHANDLE dbc, SQLHANDLE stmt)
  59 {
  60
  61       int ret;
  62       int f1=10; // f1 field
  63       char f2[50]= "jitendra";
  64
  65      ret = SQLPrepare(stmt,(unsigned char*)"SELECT * FROM t1",SQL_NTS);
  66      checkrc(ret,__LINE__);
  67
  68     ret = SQLBindCol(stmt,1,SQL_C_SLONG,&f1,0,NULL);
  69     checkrc(ret,__LINE__);
  70
  71
  72     ret = SQLBindCol(stmt,2,SQL_C_CHAR,f2,sizeof(f2),NULL);
  73     checkrc(ret,__LINE__);
  74
  75     int j, count=0;
  76     ret = SQLExecute(stmt);
  77     checkrc(ret,__LINE__);
  78     printf("Fetching starts on table  t1 :\n");
  79
  80     while(SQL_SUCCEEDED(ret = SQLFetch(stmt)))
  81     {
  82         printf("F1=%d\tF2=%s\n ",f1,f2);
  83         count++;
  84     }
  85
  86     ret = SQLCloseCursor(stmt);
  87     checkrc(ret,__LINE__);
  88
  89     ret = SQLTransact(env,dbc,SQL_COMMIT);
  90     checkrc(ret,__LINE__);
  91     printf("Total row fetched=%d\n",count);
  92 }
  93
  94
  95 int main()
  96 {
  97   SQLHENV env;
  98   SQLHDBC dbc;
  99   SQLHSTMT stmt;
 100   SQLRETURN ret;
 101   SQLCHAR outstr[1024];
 102   SQLSMALLINT outstrlen;
 103
 104   // Aloocate an environment handle
 105   ret=SQLAllocHandle(SQL_HANDLE_ENV,SQL_NULL_HANDLE,&env);
 106   checkrc(ret,__LINE__);
 107
 108    //we need odbc3 support
 109   ret =  SQLSetEnvAttr(env,SQL_ATTR_ODBC_VERSION,(void*)SQL_OV_ODBC3,0);
 110   checkrc(ret,__LINE__);
 111   //ALLOCATE A Connection handle
 112   ret = SQLAllocHandle(SQL_HANDLE_DBC,env,&dbc);
 113   checkrc(ret,__LINE__);
 114
 115    ret = SQLConnect (dbc,
 116                    (SQLCHAR *) "DSN=test;MODE=Gateway;SERVER=localhost;PORT=5678;", (SQLSMALLINT) strlen ("test"),
 117                    (SQLCHAR *) "root",
 118                    (SQLSMALLINT) strlen ("root"),
 119                    (SQLCHAR *) "manager",
 120                    (SQLSMALLINT) strlen (""));
 121
 122   if(SQL_SUCCEEDED(ret))
 123   {
 124      printf("\nConnected to the Data Source SUCCESSFULLY..\n");
 125
 126
 127   }
 128    else
 129    {
 130         printf("error in connection\n");
 131         return 1;
 132
 133         ret = SQLFreeHandle(SQL_HANDLE_DBC,dbc);
 134         checkrc(ret,__LINE__);
 135
 136         ret = SQLFreeHandle(SQL_HANDLE_ENV,env);
 137         checkrc(ret,__LINE__);
 138         return 1;
 139
 140   }
 141
 142
 143    ret = SQLAllocHandle(SQL_HANDLE_STMT,dbc,&stmt);
 144    checkrc(ret,__LINE__);
 145    //****************************************************************
 146    InsertTest(env,dbc,stmt);
 147    FetchTest(env,dbc,stmt);
 148
 149    //****************************************************************
 150     ret = SQLFreeHandle(SQL_HANDLE_STMT,stmt);
 151     checkrc(ret,__LINE__);
 152
 153    ret = SQLDisconnect(dbc);
 154    checkrc(ret,__LINE__);
 155
 156    ret = SQLFreeHandle(SQL_HANDLE_DBC,dbc);
 157    checkrc(ret,__LINE__);
 158
 159    ret = SQLFreeHandle(SQL_HANDLE_ENV,env);
 160    checkrc(ret,__LINE__);
 161    return 0;
 162 }