src/jdbc/JdbcSqlStatement.java

   1 package csql.jdbc;
   2 import java.sql.Connection;
   3 import java.sql.Statement;
   4 import java.sql.SQLException;
   5 import java.sql.ResultSet;
   6 import java.sql.SQLWarning;
   7
   8 public class JdbcSqlStatement extends JSqlError implements Statement, JSqlErrorType
   9 {
  10     public boolean closedFlag;
  11     public boolean isPrepared;
  12     public int rowsAffect;
  13     public JSqlStatement jniStmt;
  14     public JdbcSqlConnection conn;
  15     public JdbcSqlResultSet rs;
  16     public boolean isSelect;
  17     public boolean isFirstExecute;
  18     public int rowLimit;
  19     JdbcSqlStatement( Connection con )
  20     {
  21         jniStmt = new JSqlStatement();
  22         isFirstExecute = false;
  23         conn = (JdbcSqlConnection) con;
  24         jniStmt.alloc(conn.mode);
  25         jniStmt.setConnectionPtr( conn.getConnection().getPtr() );
  26         closedFlag = false;
  27         isPrepared = false;
  28         rowsAffect = 0;
  29         isSelect = false;
  30         rs = new JdbcSqlResultSet();
  31     }
  32     protected void finalize ()
  33     {
  34         try
  35         {
  36             if(!closedFlag)
  37                 close();
  38             jniStmt.free();//praba
  39         }
  40         catch(SQLException e)
  41         {
  42             System.out.println(e);
  43         }
  44     }
  45     public void prepareInt(String query) throws SQLException
  46     {
  47         int rv = 0;
  48         if(isPrepared)
  49         {
  50             if(isSelect) rs.close();
  51             jniStmt.freeStmt();
  52             isPrepared = false;
  53             isFirstExecute = false;
  54             isSelect = false;
  55         }
  56         rv = jniStmt.prepare(query);
  57         if( rv != 0 ) // 0 ->OK
  58         {
  59             throw getException(CSQL_PREPARE_ERR);
  60         }
  61         isSelect = jniStmt.isSelect();
  62         isPrepared = true;
  63         isFirstExecute = true;
  64     }
  65     public boolean executeInt() throws SQLException
  66     {
  67         if (!isPrepared) throw getException(CSQL_NOT_PREPARED);
  68         rowsAffect = jniStmt.execute();
  69         if( rowsAffect < 0 )
  70             throw getException(CSQL_EXECUTE_ERR);
  71         if(conn.getAutoCommit())
  72             conn.commit();
  73
  74         return(isSelect);
  75     }
  76
  77     public void close() throws SQLException
  78     {
  79         if(closedFlag) return;
  80         if(isPrepared)
  81         {
  82             if(isSelect) rs.close();
  83             jniStmt.freeStmt();
  84             //jniStmt.free(); Praba. this makes the stmt unusable after close
  85         }
  86         closedFlag = true;
  87         return;
  88     }
  89
  90     public void closeScan() throws SQLException
  91     {
  92         if(isSelect) jniStmt.close();
  93     }
  94
  95     public boolean execute (String query) throws SQLException
  96     {
  97         prepareInt(query);
  98         return(executeInt());
  99     }
 100
 101     public ResultSet executeQuery(String query) throws SQLException
 102     {
 103         prepareInt(query);
 104         if( !isSelect ) {
 105             jniStmt.freeStmt();
 106             isPrepared = false;
 107             isFirstExecute = false;
 108             throw getException(CSQL_NOT_QUERY);
 109         }
 110         boolean hasResult = executeInt();
 111
 112         rs.setStmt( this );
 113         rs.setProjField();
 114         return( rs );
 115     }
 116     public int executeUpdate (String query) throws SQLException
 117     {
 118         if(execute(query))
 119             throw getException(CSQL_NOT_UPDATE);
 120         return(rowsAffect);
 121     }
 122     public Connection getConnection() throws SQLException
 123     {
 124        return(conn);
 125     }
 126     public int getFetchDirection() throws SQLException
 127     {
 128         return(ResultSet.FETCH_FORWARD);
 129     }
 130     public int getFetchSize() throws SQLException
 131     {
 132         return 1;
 133     }
 134     public ResultSet getResultSet() throws SQLException
 135     {
 136         if(!isSelect)
 137             return (null);
 138          if(closedFlag) throw getException( CSQL_INVALID_STATE );
 139          rs.setStmt(this);
 140          return rs;
 141     }
 142     public int getResultSetConcurrency() throws SQLException
 143     {
 144         return(ResultSet.CONCUR_READ_ONLY);
 145     }
 146     public int getResultSetHoldability() throws SQLException
 147     {
 148         return(ResultSet.CLOSE_CURSORS_AT_COMMIT);
 149     }
 150     public int getResultSetType()  throws SQLException
 151     {
 152         return(ResultSet.TYPE_FORWARD_ONLY);
 153     }
 154     public int getUpdateCount() throws SQLException
 155     {
 156        // if(isSelect)
 157             return -1;
 158        // return rowsAffect;
 159     }
 160
 161
 162     //Unsupported APIs
 163     public void addBatch(String sql) throws SQLException
 164     {
 165         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::addBatch called");
 166         throw getException(CSQL_NOT_SUPPORTED);
 167     }
 168     public void cancel() throws SQLException
 169     {
 170         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::cancel called");
 171         throw getException(CSQL_NOT_SUPPORTED);
 172     }
 173     public void clearBatch() throws SQLException
 174     {
 175         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::clearBatch called");
 176         throw getException(CSQL_NOT_SUPPORTED);
 177     }
 178     public void clearWarnings() throws SQLException
 179     {
 180         //TODO
 181         return;
 182     }
 183     public boolean execute(String sql, int autoGeneratedKeys) throws SQLException
 184     {
 185         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::execute called");
 186         throw getException(CSQL_NOT_SUPPORTED);
 187     }
 188     public boolean execute(String sql, int[] columnIndexes) throws SQLException
 189     {
 190         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::execute called");
 191         throw getException(CSQL_NOT_SUPPORTED);
 192     }
 193     public boolean execute(String sql, String[] columnNames) throws SQLException
 194     {
 195         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::execute called");
 196         throw getException(CSQL_NOT_SUPPORTED);
 197     }
 198     public int[] executeBatch() throws SQLException
 199     {
 200         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::executeBatch called");
 201         throw getException(CSQL_NOT_SUPPORTED);
 202     }
 203     public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException
 204     {
 205         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::executeUpdate called");
 206         throw getException(CSQL_NOT_SUPPORTED);
 207     }
 208     public int executeUpdate(String sql, int[] columnIndexes) throws SQLException
 209     {
 210         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::executeUpdate called");
 211         throw getException(CSQL_NOT_SUPPORTED);
 212     }
 213     public int executeUpdate(String sql, String[] columnNames) throws SQLException
 214     {
 215         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::executeUpdate called");
 216         throw getException(CSQL_NOT_SUPPORTED);
 217     }
 218     public ResultSet getGeneratedKeys() throws SQLException
 219     {
 220         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::getGeneratedKeys called");
 221         throw getException(CSQL_NOT_SUPPORTED);
 222     }
 223     public int getMaxFieldSize() throws SQLException
 224     {
 225         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::getMaxFieldSize called");
 226         throw getException(CSQL_NOT_SUPPORTED);
 227     }
 228     public int getMaxRows() throws SQLException
 229     {
 230         //TODO:
 231         return rowLimit;
 232         //if (JSqlError.isDebug) System.out.println("JdbcSqlStatement:;getMaxRows called");
 233         //throw getException(CSQL_NOT_SUPPORTED);
 234     }
 235     public boolean getMoreResults() throws SQLException
 236     {
 237 //        if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::getMoreResults called");
 238         //throw getException(CSQL_NOT_SUPPORTED);
 239         return false;
 240     }
 241     public boolean getMoreResults( int current) throws SQLException
 242     {
 243         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::getMoreResults(int) called");
 244         throw getException(CSQL_NOT_SUPPORTED);
 245     }
 246     public int getQueryTimeout() throws SQLException
 247     {
 248         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::getQueryTimeout called");
 249         throw getException(CSQL_NOT_SUPPORTED);
 250     }
 251     public SQLWarning getWarnings() throws SQLException
 252     {
 253         //TODO information present in Action Item
 254         return null;
 255     }
 256     public void setCursorName(String name) throws SQLException
 257     {
 258         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setCursorName called");
 259         throw getException(CSQL_NOT_SUPPORTED);
 260     }
 261     public void setEscapeProcessing(boolean enable) throws SQLException
 262     {
 263         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setEscapeProcessing called");
 264         throw getException(CSQL_NOT_SUPPORTED);
 265     }
 266     public void setFetchDirection(int direction) throws SQLException
 267     {
 268         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setFetchDirection called");
 269         throw getException(CSQL_NOT_SUPPORTED);
 270     }
 271     public void setFetchSize(int rows) throws SQLException
 272     {
 273         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setFetchSize called");
 274         throw getException(CSQL_NOT_SUPPORTED);
 275     }
 276     public void setMaxFieldSize(int max) throws SQLException
 277     {
 278         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setMaxFieldSize called");
 279         throw getException(CSQL_NOT_SUPPORTED);
 280     }
 281     public void setMaxRows(int maxRows) throws SQLException
 282     {
 283        //TODO:
 284        rowLimit = maxRows;
 285        // if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setMaxRows called");
 286         //throw getException(CSQL_NOT_SUPPORTED);
 287     }
 288     public void setQueryTimeout(int seconds) throws SQLException
 289     {
 290         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::setQueryTimeout called");
 291         throw getException(CSQL_NOT_SUPPORTED);
 292     }
 293     //java 1.6 methods
 294     public boolean isPoolable()
 295     {
 296         return false;
 297     }
 298     public void setPoolable(boolean pool)
 299     {
 300         return;
 301     }
 302     public boolean isWrapperFor(Class ifact) throws SQLException
 303     {
 304         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::isWrapperFor called");
 305         throw getException(CSQL_NOT_SUPPORTED);
 306     }
 307     public Class unwrap(Class iface) throws SQLException
 308     {
 309         if (JSqlError.isDebug) System.out.println("JdbcSqlStatement::unwrap called");
 310         throw getException(CSQL_NOT_SUPPORTED);
 311     }
 312     public boolean isClosed()
 313     {
 314         return closedFlag;
 315     }
 316
 317 }