/*
    * Created on 25/Jan/2004
    *
    * To change the template for this generated file go to
    * Window>Preferences>Java>Code Generation>Code and Comments
    */
   package replica.database.commands;
   
   import java.sql.Connection;
  import java.sql.SQLException;
  
  import org.hsqldb.Server;
  import org.springframework.jdbc.datasource.DriverManagerDataSource;
  
  import replica.session.SessionManager;
  import replica.session.support.SimpleSessionManager;
  import junit.framework.TestCase;
  
  /***
   * @author Pedro
   *
   * To change the template for this generated type comment go to
   * Window>Preferences>Java>Code Generation>Code and Comments
   */
  public class DatabaseCommandProcessorTest extends TestCase {
  
  	/***
  	 * Constructor for DatabaseCommandProcessorTest.
  	 * @param arg0
  	 */
  	public DatabaseCommandProcessorTest(String arg0) {
  		super(arg0);
  	}
  
  	public void testGetConnection() {
  		
  		Server server = new Server();
  		server.putPropertiesFromString("database.0=dbcomproctest");
  		server.setPort(9002);
  		server.start();
  		
  		try{ Thread.sleep(500); }catch(InterruptedException e){	}
  		
  		DatabaseCommandProcessor cp = new DatabaseCommandProcessor();
  		
  		SessionManager sm = new SimpleSessionManager();
  		String sid = sm.createSession("sa",null);
  		
  		cp.setSessionManager(sm);
  		
  //		BasicDataSource dataSource = new BasicDataSource();
  		DriverManagerDataSource dataSource = new DriverManagerDataSource();
  		dataSource.setDriverClassName("org.hsqldb.jdbcDriver");
  		dataSource.setUrl("jdbc:hsqldb:hsql://localhost:9002");
  		
  		cp.setDataSource(dataSource);
  		
  		try{
  			Connection c = cp.getConnection(sid);
  			
  			assertNotNull(c);
  		}
  		catch(SQLException e){
  			e.printStackTrace();
  			fail(e.getMessage());
  		}
  		finally{
  			server.stop();
  			while( server.getState() != 16 /*ServerConstants.SERVER_STATE_SHUTDOWN*/ ){
  				try{ Thread.sleep(200); }catch(InterruptedException e){}
  			}
  		}
  	}
  
  }