You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@avalon.apache.org by fr...@apache.org on 2001/11/09 01:26:59 UTC
cvs commit: jakarta-avalon-cornerstone/apps/db/src/java/org/apache/avalon/db/server AbstractDatabaseManager.java
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:Paul_Hammant@yahoo.com">Paul_Hammant@yahoo.com</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: <ma...@jakarta.apache.org>
For additional commands, e-mail: <ma...@jakarta.apache.org>