cvs commit: jakarta-avalon-cornerstone/apps/db/src/java/org/apache/avalon/db/server AbstractDatabaseManager.java

[froehlich]

froehlich    01/11/08 16:26:59

  Modified:    apps/db/src/java/org/apache/avalon/db/server
                        AbstractDatabaseManager.java
  Log:
  prepared statement extension
  
  Revision  Changes    Path
  1.13      +12 -5     
jakarta-avalon-cornerstone/apps/db/src/java/org/apache/avalon/db/server/AbstractDatabaseManager.java
  
  Index: AbstractDatabaseManager.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-avalon-cornerstone/apps/db/src/java/org/apache/avalon/db/server/AbstractDatabaseManager.java,v
  retrieving revision 1.12
  retrieving revision 1.13
  diff -u -r1.12 -r1.13
  --- AbstractDatabaseManager.java      2001/11/06 00:32:34     1.12
  +++ AbstractDatabaseManager.java      2001/11/09 00:26:59     1.13
  @@ -21,6 +21,7 @@
   import org.apache.avalon.db.actions.Insert;
   import org.apache.avalon.db.transport.Request;
   import org.apache.avalon.db.transport.Reply;
  +import org.apache.avalon.db.transport.SelectReply;
   import org.apache.avalon.db.transport.SelectRequest;
   import org.apache.avalon.db.transport.CreateTableRequest;
   import org.apache.avalon.db.transport.ExceptionReply;
  @@ -39,7 +40,7 @@
    *
    *
    * @author Paul Hammant <a href="mailto:[EMAIL PROTECTED]">[EMAIL 
PROTECTED]</a>
  - * @version $Revision: 1.12 $
  + * @version $Revision: 1.13 $
    */
   public abstract class AbstractDatabaseManager extends AbstractLoggable 
implements Composable {
   
  @@ -101,11 +102,19 @@
           */
           Select select = mSQLParser.createSelectAction(selectRequest); 
//optimizedSelectRequest);
           if(!select.getWithParams()) {
  -            select.execute();
  +            select.execute(selectRequest.getParams());
           } else {
               select.execute();
  +        }
  +
  +        /** if prepared statement call then return the paramter count */
  +        if(select.getPrepared()) {
  +            SelectReply reply = new SelectReply();
  +            reply.setParameterCount(select.getParamCount());
  +            return reply;
  +        } else {
  +            return new ResultSetReply(select.getRowSet());
           }
  -        return new ResultSetReply(select.getRowSet());
       }
   
       public Reply processCreateTableRequest(CreateTableRequest 
createTableRequest) throws ActionException {
  @@ -119,6 +128,4 @@
           ins.execute();
           return new UpdateReply(ins.getRecordCount());
       }
  -
  -
   }
  
  
  

--
To unsubscribe, e-mail:   <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>