1 /* 2 * Replica is published under the terms 3 * of the Apache Software License. 4 */ 5 package replica.database.commands.sql; 6 7 import java.sql.SQLException; 8 import java.sql.Statement; 9 10 import replica.core.ApplicationMessage; 11 import replica.database.commands.StatementDbCommand; 12 import replica.server.commands.PrintCommand; 13 14 /*** 15 * 16 * @author Pedro Costa 17 * @author Helder Silva 18 * @since 20/Jan/2004 19 */ 20 public class CallDbCommand extends StatementDbCommand { 21 22 /*** 23 * 24 */ 25 public CallDbCommand() { 26 super(); 27 } 28 29 /* (non-Javadoc) 30 * @see replica.database.commands.DatabaseCommand#execute(java.sql.Statement, java.lang.String) 31 */ 32 protected Object execute(Statement st, String command) throws SQLException{ 33 boolean hasResult = st.execute( command ); 34 35 if( hasResult ) 36 return st.getResultSet(); 37 38 int updateCount = st.getUpdateCount(); 39 40 ApplicationMessage result = new ApplicationMessage(); 41 result.setOriginator(ApplicationMessage.DATABASE_MODULE); 42 result.setBody( PrintCommand.NAME + " " + updateCount + " rows afected."); 43 44 return result; 45 } 46 47 }

This page was automatically generated by Maven