db-derby-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jboy...@apache.org
Subject svn commit: r165585 [32/42] - in /incubator/derby/code/trunk/java/client/org/apache/derby: client/ client/am/ client/net/ client/resources/ jdbc/
Date Mon, 02 May 2005 06:26:03 GMT
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_() {
+    }
 }



Mime
View raw message