examples/odbc/ODBCman6.c

   1 //  Connect to the Data source
   2 //  delete rows from the table
   3 #include<stdio.h>
   4 #include<stdlib.h>
   5 #include<sql.h>
   6 #include<sqlext.h>
   7 #include<string.h>
   8 inline void checkrc(int rc, int line)
   9 {
  10    if(rc)
  11    {
  12       printf("ERROR %d at line %d\n",rc,line);
  13       exit(1);
  14    }
  15 }
  16
  17
  18 int main()
  19 {
  20    SQLHENV env;
  21    SQLHDBC dbc;
  22    SQLHSTMT stmt;
  23    SQLRETURN ret;
  24    SQLCHAR outstr[1024];
  25    SQLSMALLINT  outstrlen;
  26
  27    ret = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &env);
  28    checkrc(ret,__LINE__);
  29
  30    ret = SQLSetEnvAttr(env,SQL_ATTR_ODBC_VERSION,(void*)SQL_OV_ODBC3,0);
  31    checkrc(ret,__LINE__);
  32
  33    ret = SQLAllocHandle(SQL_HANDLE_DBC,env,&dbc);
  34    checkrc(ret,__LINE__);
  35
  36     ret = SQLConnect (dbc,
  37                    (SQLCHAR *) "test", (SQLSMALLINT) strlen ("test"),
  38                    (SQLCHAR *) "root",
  39                    (SQLSMALLINT) strlen ("root"),
  40                    (SQLCHAR *) "manager",
  41                    (SQLSMALLINT) strlen (""));
  42
  43    if(SQL_SUCCEEDED(ret))
  44    {
  45       printf("\nConnect to the data source successfully\n");
  46    }
  47    else
  48    {
  49      printf("Failed to connect\n");
  50      return 2;
  51    }
  52
  53
  54    ret = SQLAllocHandle(SQL_HANDLE_STMT,dbc,&stmt);
  55    checkrc(ret,__LINE__);
  56
  57    // delete 5 rows from the table with parameter.
  58
  59    int eid1;
  60
  61    ret = SQLPrepare(stmt,(unsigned char*)"delete from emp where eid = ?;",SQL_NTS);
  62    checkrc(ret,__LINE__);
  63
  64    ret = SQLBindParameter(stmt,1,SQL_PARAM_INPUT,SQL_C_SLONG,SQL_INTEGER,0,0,&eid1,0,NULL);
  65    checkrc(ret,__LINE__);
  66
  67    int i,count=0;
  68
  69    eid1=5000;
  70    for(i=0;i<5;i++)
  71    {
  72      eid1++;
  73      ret = SQLExecute(stmt);
  74      checkrc(ret,__LINE__);
  75
  76      ret = SQLTransact(env,dbc,SQL_COMMIT);
  77      checkrc(ret,__LINE__);
  78
  79      ret = SQLTransact(env,dbc,SQL_COMMIT);
  80      count++;
  81    }
  82    printf("Deleted first %d updated rows in 'emp' table\n",count);
  83
  84    // delete all the rows from the table
  85    ret = SQLPrepare(stmt,(unsigned char*)"delete from emp;",SQL_NTS);
  86    checkrc(ret,__LINE__);
  87
  88    ret = SQLExecute(stmt);
  89    checkrc(ret,__LINE__);
  90
  91    ret = SQLTransact(env,dbc,SQL_COMMIT);
  92    checkrc(ret,__LINE__);
  93
  94    printf("All the rows are deleted \n");
  95
  96    // drop the table from the table
  97
  98    SQLCHAR drop[30]="drop table emp;";
  99
 100    ret = SQLExecDirect(stmt,drop,SQL_NTS);
 101    checkrc(ret,__LINE__);
 102
 103
 104    printf("Table 'emp'dropped successfully\n");
 105
 106
 107
 108    ret = SQLFreeHandle(SQL_HANDLE_STMT,stmt);
 109    checkrc(ret,__LINE__);
 110
 111    ret - SQLDisconnect(dbc);
 112    checkrc(ret,__LINE__);
 113
 114    ret = SQLFreeHandle(SQL_HANDLE_DBC,dbc);
 115    checkrc(ret,__LINE__);
 116
 117    ret = SQLFreeHandle(SQL_HANDLE_ENV,env);
 118    checkrc(ret,__LINE__);
 119    return 0;
 120 }
 121