/*
    * Replica is published under the terms
    * of the Apache Software License.
    */
   package replica.server.commands;
   
   import java.sql.SQLException;
   
   import org.springframework.jdbc.datasource.DriverManagerDataSource;
  
  import replica.core.ApplicationMessage;
  import junit.framework.TestCase;
  
  /***
   * 
   * @author Pedro Costa
   * @author Helder Silva
   * @since 31/Jan/2004
   */
  public class StartupDatabaseCommandTest extends TestCase {
  	
  	StartupDatabaseCommand stdbc;
  	DriverManagerDataSource dataSource;
  	ShutdownDatabaseCommand sddbc;
  
  	/***
  	 * Constructor for StartupDatabaseCommandTest.
  	 * @param name
  	 */
  	public StartupDatabaseCommandTest(String name) {
  		super(name);
  	}
  
  	public void testInternalExecute() {
  		
  		ApplicationMessage msg = new ApplicationMessage();
  		
  		msg.setBody("startup database on port 9011;");
  		
  		stdbc.internalExecute(msg);
  		
  		assertEquals("org.hsqldb.jdbcDriver", dataSource.getDriverClassName());
  		assertEquals("jdbc:hsqldb:hsql://localhost:9011/replicatest", dataSource.getUrl());
  		
  		assertNotNull(sddbc.server);
  		
  		try{Thread.sleep(500);}catch(InterruptedException e){}
  		
  		try{
  			dataSource.getConnection("sa","");
  		}
  		catch(SQLException e){
  			e.printStackTrace();
  			fail();
  		}
  	}
  
  	/* (non-Javadoc)
  	 * @see junit.framework.TestCase#setUp()
  	 */
  	protected void setUp() throws Exception {
  		super.setUp();
  		
  		stdbc = new StartupDatabaseCommand();
  		
  		stdbc.setName("replicatest");
  		
  		dataSource = new DriverManagerDataSource();
  		
  		stdbc.setDataSource(dataSource);
  		
  		sddbc = new ShutdownDatabaseCommand();
  		
  		stdbc.setShutdownDatabaseCommand(sddbc);
  	}
  
  	/* (non-Javadoc)
  	 * @see junit.framework.TestCase#tearDown()
  	 */
  	protected void tearDown() throws Exception {
  		super.tearDown();
  		
  		sddbc.server.stop();
  		while( sddbc.server.getState() != 16 /*ServerConstants.SERVER_STATE_SHUTDOWN*/ ){
  			try{ Thread.sleep(200); }catch(InterruptedException e){}
  		}
  	}
  
  }