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 public class JdbcSqlStatement extends JSqlError implements Statement, JSqlErrorType
   8 {
   9     public boolean isClosed;
  10     public boolean isPrepared;
  11     public int rowsAffect;
  12     public JSqlStatement jniStmt;
  13     public JdbcSqlConnection conn;
  14     //public JdbcSqlResultSet rs;
  15
  16     JdbcSqlStatement(Connection con)
  17     {
  18         jniStmt = new JSqlStatement();
  19         jniStmt.alloc();
  20         jniStmt.setConnectionPtr(((JdbcSqlConnection)con).getConnection().getPtr());
  21         conn = (JdbcSqlConnection)con;
  22         isClosed = false;
  23         isPrepared = false;
  24         rowsAffect = 0;
  25     }
  26     protected void finalize ()
  27     {
  28         try
  29         {
  30             if(!isClosed)
  31                 close();
  32         }
  33         catch(SQLException e)
  34         {
  35             System.out.println(e);
  36         }
  37     }
  38     public void prepareInt(String query) throws SQLException
  39     {
  40         int rv = 0;
  41         if(isPrepared)
  42         {
  43             jniStmt.freeStmt();
  44         }
  45         rv = jniStmt.prepare(query);
  46         if( rv != 0 ) // 0 ->OK
  47         {
  48             throw getException(CSQL_PREPARE_ERR);
  49         }
  50         isPrepared = true;
  51     }
  52     public boolean executeInt() throws SQLException
  53     {
  54         if (!isPrepared) throw getException(CSQL_NOT_PREPARED);
  55         boolean isSelect = jniStmt.isSelect();
  56         rowsAffect = jniStmt.execute();
  57         if( rowsAffect < 0 )
  58             throw getException(CSQL_EXECUTE_ERR);
  59         if(conn.getAutoCommit())
  60             conn.commit();
  61
  62         return(isSelect);
  63     }
  64
  65     public void close() throws SQLException
  66     {
  67         if(isClosed) return;
  68         if(isPrepared)
  69         {
  70             //rs.close();
  71             jniStmt.freeStmt();
  72             jniStmt.free();
  73         }
  74         isClosed = true;
  75         return;
  76     }
  77     public boolean execute (String query) throws SQLException
  78     {
  79         prepareInt(query);
  80         return(executeInt());
  81     }
  82
  83     public ResultSet executeQuery(String query) throws SQLException
  84     {
  85         if(!execute(query))
  86             throw getException(CSQL_NOT_QUERY);
  87         return(null);
  88     }
  89     public int executeUpdate (String query) throws SQLException
  90     {
  91         if(execute(query))
  92             throw getException(CSQL_NOT_UPDATE);
  93         return(rowsAffect);
  94     }
  95     public Connection getConnection() throws SQLException
  96     {
  97        return(conn);
  98     }
  99     public int getFetchDirection() throws SQLException
 100     {
 101         return(ResultSet.FETCH_FORWARD);
 102     }
 103     public int getFetchSize() throws SQLException
 104     {
 105         return 1;
 106     }
 107     public ResultSet getResultSet() throws SQLException
 108     {
 109         if(!jniStmt.isSelect())
 110             return (null);
 111
 112         //TODO::Create ResultSet object
 113         return null;
 114     }
 115     public int getResultSetConcurrency() throws SQLException
 116     {
 117         return(ResultSet.CONCUR_READ_ONLY);
 118     }
 119     public int getResultSetHoldability() throws SQLException
 120     {
 121         return(ResultSet.CLOSE_CURSORS_AT_COMMIT);
 122     }
 123     public int getResultSetType()  throws SQLException
 124     {
 125         return(ResultSet.TYPE_FORWARD_ONLY);
 126     }
 127     public int getUpdateCount() throws SQLException
 128     {
 129         if(jniStmt.isSelect())
 130             return -1;
 131         return rowsAffect;
 132     }
 133
 134
 135     //Unsupported APIs
 136     public void addBatch(String sql) throws SQLException
 137     {
 138         throw getException(CSQL_NOT_SUPPORTED);
 139     }
 140     public void cancel() throws SQLException
 141     {
 142         throw getException(CSQL_NOT_SUPPORTED);
 143     }
 144     public void clearBatch() throws SQLException
 145     {
 146         throw getException(CSQL_NOT_SUPPORTED);
 147     }
 148     public void clearWarnings() throws SQLException
 149     {
 150         throw getException(CSQL_NOT_SUPPORTED);
 151     }
 152     public boolean execute(String sql, int autoGeneratedKeys) throws SQLException
 153     {
 154         throw getException(CSQL_NOT_SUPPORTED);
 155     }
 156     public boolean execute(String sql, int[] columnIndexes) throws SQLException
 157     {
 158         throw getException(CSQL_NOT_SUPPORTED);
 159     }
 160     public boolean execute(String sql, String[] columnNames) throws SQLException
 161     {
 162         throw getException(CSQL_NOT_SUPPORTED);
 163     }
 164     public int[] executeBatch() throws SQLException
 165     {
 166         throw getException(CSQL_NOT_SUPPORTED);
 167     }
 168     public int executeUpdate(String sql, int autoGeneratedKeys) throws SQLException
 169     {
 170         throw getException(CSQL_NOT_SUPPORTED);
 171     }
 172     public int executeUpdate(String sql, int[] columnIndexes) throws SQLException
 173     {
 174         throw getException(CSQL_NOT_SUPPORTED);
 175     }
 176     public int executeUpdate(String sql, String[] columnNames) throws SQLException
 177     {
 178         throw getException(CSQL_NOT_SUPPORTED);
 179     }
 180     public ResultSet getGeneratedKeys() throws SQLException
 181     {
 182         throw getException(CSQL_NOT_SUPPORTED);
 183     }
 184     public int getMaxFieldSize() throws SQLException
 185     {
 186         throw getException(CSQL_NOT_SUPPORTED);
 187     }
 188     public int getMaxRows() throws SQLException
 189     {
 190         throw getException(CSQL_NOT_SUPPORTED);
 191     }
 192     public boolean getMoreResults() throws SQLException
 193     {
 194         throw getException(CSQL_NOT_SUPPORTED);
 195     }
 196     public boolean getMoreResults( int current) throws SQLException
 197     {
 198         throw getException(CSQL_NOT_SUPPORTED);
 199     }
 200     public int getQueryTimeout() throws SQLException
 201     {
 202         throw getException(CSQL_NOT_SUPPORTED);
 203     }
 204     public SQLWarning getWarnings() throws SQLException
 205     {
 206         throw getException(CSQL_NOT_SUPPORTED);
 207     }
 208     public void setCursorName(String name) throws SQLException
 209     {
 210         throw getException(CSQL_NOT_SUPPORTED);
 211     }
 212     public void setEscapeProcessing(boolean enable) throws SQLException
 213     {
 214         throw getException(CSQL_NOT_SUPPORTED);
 215     }
 216     public void setFetchDirection(int direction) throws SQLException
 217     {
 218         throw getException(CSQL_NOT_SUPPORTED);
 219     }
 220     public void setFetchSize(int rows) throws SQLException
 221     {
 222         throw getException(CSQL_NOT_SUPPORTED);
 223     }
 224     public void setMaxFieldSize(int max) throws SQLException
 225     {
 226         throw getException(CSQL_NOT_SUPPORTED);
 227     }
 228     public void setMaxRows(int maxRows) throws SQLException
 229     {
 230         throw getException(CSQL_NOT_SUPPORTED);
 231     }
 232     public void setQueryTimeout(int seconds) throws SQLException
 233     {
 234         throw getException(CSQL_NOT_SUPPORTED);
 235     }
 236
 237
 238 }