Modified: incubator/derby/code/trunk/java/client/org/apache/derby/client/net/NetStatement.java URL: http://svn.apache.org/viewcvs/incubator/derby/code/trunk/java/client/org/apache/derby/client/net/NetStatement.java?rev=165585&r1=165584&r2=165585&view=diff ============================================================================== --- incubator/derby/code/trunk/java/client/org/apache/derby/client/net/NetStatement.java (original) +++ incubator/derby/code/trunk/java/client/org/apache/derby/client/net/NetStatement.java Sun May 1 23:25:59 2005 @@ -20,166 +20,168 @@ package org.apache.derby.client.net; -import org.apache.derby.client.am.Section; import org.apache.derby.client.am.ColumnMetaData; -import org.apache.derby.client.am.Statement; +import org.apache.derby.client.am.Section; import org.apache.derby.client.am.SqlException; +import org.apache.derby.client.am.Statement; + +public class NetStatement implements org.apache.derby.client.am.MaterialStatement { -public class NetStatement implements org.apache.derby.client.am.MaterialStatement -{ + Statement statement_; - Statement statement_; + // Alias for (NetConnection) statement_.connection + NetConnection netConnection_; - // Alias for (NetConnection) statement_.connection - NetConnection netConnection_; + // Alias for (NetAgent) statement_.agent + NetAgent netAgent_; + + + // If qryrowset is sent on opnqry then it also needs to be sent on every subsequent cntqry. + public boolean qryrowsetSentOnOpnqry_ = false; + + //---------------------constructors/finalizer--------------------------------- + + private NetStatement() { + initNetStatement(); + } + + private void resetNetStatement() { + initNetStatement(); + } + + private void initNetStatement() { + qryrowsetSentOnOpnqry_ = false; + } + + // Relay constructor for NetPreparedStatement. + NetStatement(org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) { + this(); + initNetStatement(statement, netAgent, netConnection); + } + + void resetNetStatement(org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) { + resetNetStatement(); + initNetStatement(statement, netAgent, netConnection); + } + + private void initNetStatement(org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) { + netAgent_ = netAgent; + netConnection_ = netConnection; + statement_ = statement; + statement_.materialStatement_ = this; + } + + // Called by abstract Connection.createStatement().newStatement() for jdbc 1 statements + NetStatement(NetAgent netAgent, NetConnection netConnection) throws SqlException { + this(new Statement(netAgent, netConnection), + netAgent, + netConnection); + } + + void netReset(NetAgent netAgent, NetConnection netConnection) throws SqlException { + statement_.resetStatement(netAgent, netConnection); + resetNetStatement(statement_, netAgent, netConnection); + } + + public void reset_() { + qryrowsetSentOnOpnqry_ = false; + } + + // Called by abstract Connection.createStatement().newStatement() for jdbc 2 statements with scroll attributes + NetStatement(NetAgent netAgent, NetConnection netConnection, int type, int concurrency, int holdability) throws SqlException { + this(new Statement(netAgent, netConnection, type, concurrency, holdability, java.sql.Statement.NO_GENERATED_KEYS, null), + netAgent, + netConnection); + } + + void resetNetStatement(NetAgent netAgent, NetConnection netConnection, int type, int concurrency, int holdability) throws SqlException { + statement_.resetStatement(netAgent, netConnection, type, concurrency, holdability, java.sql.Statement.NO_GENERATED_KEYS, null); + resetNetStatement(statement_, netAgent, netConnection); + } + + protected void finalize() throws java.lang.Throwable { + super.finalize(); + } + + // ------------------------abstract box car methods----------------------------------------------- + + public void writeSetSpecialRegister_(java.util.ArrayList sqlsttList) throws SqlException { + netAgent_.statementRequest_.writeSetSpecialRegister(sqlsttList); + } + + public void readSetSpecialRegister_() throws SqlException { + netAgent_.statementReply_.readSetSpecialRegister(statement_); + } + + public void writeExecuteImmediate_(String sql, + Section section) throws SqlException { + netAgent_.statementRequest_.writeExecuteImmediate(this, sql, section); + } + + public void readExecuteImmediate_() throws SqlException { + netAgent_.statementReply_.readExecuteImmediate(statement_); + } + + // NOTE: NET processing does not require parameters supplied on the "read-side" so parameter sql is ignored. + public void readExecuteImmediateForBatch_(String sql) throws SqlException { + readExecuteImmediate_(); + } + + public void writePrepareDescribeOutput_(String sql, + Section section) throws SqlException { + netAgent_.statementRequest_.writePrepareDescribeOutput(this, sql, section); + } + + public void readPrepareDescribeOutput_() throws SqlException { + netAgent_.statementReply_.readPrepareDescribeOutput(statement_); + } - // Alias for (NetAgent) statement_.agent - NetAgent netAgent_; - - - // If qryrowset is sent on opnqry then it also needs to be sent on every subsequent cntqry. - public boolean qryrowsetSentOnOpnqry_ = false; - - //---------------------constructors/finalizer--------------------------------- - - private NetStatement() - { - initNetStatement(); - } - - private void resetNetStatement() - { - initNetStatement(); - } - - private void initNetStatement() - { - qryrowsetSentOnOpnqry_ = false; - } - - // Relay constructor for NetPreparedStatement. - NetStatement (org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) - { - this(); - initNetStatement (statement, netAgent, netConnection); - } - - void resetNetStatement (org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) - { - resetNetStatement(); - initNetStatement (statement, netAgent, netConnection); - } - - private void initNetStatement (org.apache.derby.client.am.Statement statement, NetAgent netAgent, NetConnection netConnection) - { - netAgent_ = netAgent; - netConnection_ = netConnection; - statement_ = statement; - statement_.materialStatement_ = this; - } - - // Called by abstract Connection.createStatement().newStatement() for jdbc 1 statements - NetStatement (NetAgent netAgent, NetConnection netConnection) throws SqlException - { - this (new Statement (netAgent, netConnection), - netAgent, - netConnection); - } - - void netReset (NetAgent netAgent, NetConnection netConnection) throws SqlException - { - statement_.resetStatement(netAgent, netConnection); - resetNetStatement (statement_, netAgent, netConnection); - } - - public void reset_ () - { - qryrowsetSentOnOpnqry_ = false; - } - - // Called by abstract Connection.createStatement().newStatement() for jdbc 2 statements with scroll attributes - NetStatement (NetAgent netAgent, NetConnection netConnection, int type, int concurrency, int holdability) throws SqlException - { - this (new Statement (netAgent, netConnection, type, concurrency, holdability, java.sql.Statement.NO_GENERATED_KEYS, null), - netAgent, - netConnection); - } - - void resetNetStatement (NetAgent netAgent, NetConnection netConnection, int type, int concurrency, int holdability) throws SqlException - { - statement_.resetStatement(netAgent, netConnection, type, concurrency, holdability, java.sql.Statement.NO_GENERATED_KEYS,null); - resetNetStatement (statement_, netAgent, netConnection); - } - - protected void finalize () throws java.lang.Throwable - { - super.finalize(); - } - - // ------------------------abstract box car methods----------------------------------------------- - - public void writeSetSpecialRegister_ (java.util.ArrayList sqlsttList) throws SqlException - { netAgent_.statementRequest_.writeSetSpecialRegister (sqlsttList); } - public void readSetSpecialRegister_ () throws SqlException - { netAgent_.statementReply_.readSetSpecialRegister (statement_); } - public void writeExecuteImmediate_ (String sql, - Section section) throws SqlException - { netAgent_.statementRequest_.writeExecuteImmediate (this, sql, section); } - public void readExecuteImmediate_ () throws SqlException - { netAgent_.statementReply_.readExecuteImmediate (statement_); } - - // NOTE: NET processing does not require parameters supplied on the "read-side" so parameter sql is ignored. - public void readExecuteImmediateForBatch_ (String sql) throws SqlException - { readExecuteImmediate_(); } - - public void writePrepareDescribeOutput_ (String sql, - Section section) throws SqlException - { netAgent_.statementRequest_.writePrepareDescribeOutput (this, sql, section); } - public void readPrepareDescribeOutput_ () throws SqlException - { netAgent_.statementReply_.readPrepareDescribeOutput (statement_); } - - public void writeOpenQuery_ (Section section, - int fetchSize, - int resultSetType) - throws SqlException - { - netAgent_.statementRequest_.writeOpenQuery ( - this, - section, - fetchSize, - resultSetType); - } - public void readOpenQuery_ () throws SqlException - { netAgent_.statementReply_.readOpenQuery (statement_); } - - public void writeExecuteCall_ (boolean outputExpected, - String procedureName, - Section section, + public void writeOpenQuery_(Section section, int fetchSize, - boolean suppressResultSets, - int resultSetType, - ColumnMetaData parameterMetaData, - Object[] inputs) throws SqlException - { - netAgent_.statementRequest_.writeExecuteCall ( - this, - outputExpected, - procedureName, - section, - fetchSize, - suppressResultSets, - resultSetType, - parameterMetaData, - inputs); - } - public void readExecuteCall_ () throws SqlException - { netAgent_.statementReply_.readExecuteCall (statement_); } - - public void writePrepare_ (String sql, Section section) throws SqlException - { netAgent_.statementRequest_.writePrepare (this, sql, section); } - public void readPrepare_ () throws SqlException - { netAgent_.statementReply_.readPrepare (statement_); } + int resultSetType) + throws SqlException { + netAgent_.statementRequest_.writeOpenQuery(this, + section, + fetchSize, + resultSetType); + } + + public void readOpenQuery_() throws SqlException { + netAgent_.statementReply_.readOpenQuery(statement_); + } + + public void writeExecuteCall_(boolean outputExpected, + String procedureName, + Section section, + int fetchSize, + boolean suppressResultSets, + int resultSetType, + ColumnMetaData parameterMetaData, + Object[] inputs) throws SqlException { + netAgent_.statementRequest_.writeExecuteCall(this, + outputExpected, + procedureName, + section, + fetchSize, + suppressResultSets, + resultSetType, + parameterMetaData, + inputs); + } + + public void readExecuteCall_() throws SqlException { + netAgent_.statementReply_.readExecuteCall(statement_); + } + + public void writePrepare_(String sql, Section section) throws SqlException { + netAgent_.statementRequest_.writePrepare(this, sql, section); + } + + public void readPrepare_() throws SqlException { + netAgent_.statementReply_.readPrepare(statement_); + } - public void markClosedOnServer_ () {} + public void markClosedOnServer_() { + } }
