[Batchserver-cvs] batchserver/test/org/jmonks/batchserver/framework/repository/jdbc MySQLJdbcRepositoryTest.java, NONE, 1.1 JdbcRepositoryTest.java, 1.2, NONE MySQLJdbcRepository.java, 1.1, NONE

[Suresh <sur...@us...>]

Update of /cvsroot/batchserver/batchserver/test/org/jmonks/batchserver/framework/repository/jdbc
In directory sc8-pr-cvs3.sourceforge.net:/tmp/cvs-serv7920

Added Files:
	MySQLJdbcRepositoryTest.java 
Removed Files:
	JdbcRepositoryTest.java MySQLJdbcRepository.java 
Log Message:
no message

--- JdbcRepositoryTest.java DELETED ---

--- NEW FILE: MySQLJdbcRepositoryTest.java ---
/*
 * MySQLJdbcRepositoryTest.java
 * JUnit based test
 *
 * Created on September 10, 2006, 12:53 PM
 */

package org.jmonks.batchserver.framework.repository.jdbc;

import java.util.HashMap;
import java.util.Map;
import junit.framework.*;
import org.jmonks.batchserver.framework.util.JdbcConnectionHelper;



/**
 *
 * @author Suresh Pragada
 */
public class MySQLJdbcRepositoryTest extends TestCase
{
    
    public MySQLJdbcRepositoryTest(String testName)
    {
        super(testName);
    }

    protected void setUp() throws Exception
    {
    }

    protected void tearDown() throws Exception
    {
    }

    public static Test suite()
    {
        TestSuite suite = new TestSuite();
        suite.addTest(new MySQLJdbcRepositoryTest("testInit"));
        suite.addTest(new MySQLJdbcRepositoryTest("testSendDataToNextJob"));
        return suite;
    }

    /**
     * Test of init method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testInit()
    {
        try
        {
            MySQLJdbcRepository repository=new MySQLJdbcRepository();
            repository.init(getMySQLConfigMap());
        }
        catch(Exception exception)
        {
            fail("MySQL Jdbc Repository testInit was failed.");
        }
    }

    /**
     * Test of clearDataTransferredFromThisJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testClearDataTransferredFromThisJob()
    {
    }

    /**
     * Test of sendDataToNextJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testSendDataToNextJob()
    {
        try
        {
            MySQLJdbcRepository repository=new MySQLJdbcRepository();
            repository.init(getMySQLConfigMap());
            Map dataGoingToBeSend=new HashMap();
            dataGoingToBeSend.put("author","suresh");
            boolean sendStatus=repository.sendDataToNextJob("ID1", "process_file_abc", "process_file_xyz", dataGoingToBeSend);
            assertEquals(true, sendStatus);
            Object dataSent=repository.getDataFromPreviousJob("ID1", "process_file_abc", "process_file_xyz");
            assertNotNull(dataSent);
            Map dataSentMap=(Map)dataSent;
            String author=(String)dataSentMap.get("author");
            assertEquals("suresh",author);
        }
        catch(Exception exception)
        {
            fail("MySQL Jdbc Repository testSendDataToNextJob was failed.");
        }        
    }

    /**
     * Test of getDataFromPreviousJob method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testGetDataFromPreviousJob()
    {
    }

    /**
     * Test of logStatistics method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testLogStatistics()
    {
        
    }

    /**
     * Test of getStatistics method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testGetStatistics()
    {
    }

    /**
     * Test of lookupJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testLookupJobMgmtMntrInfo()
    {
    }

    /**
     * Test of unregisterJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testUnregisterJobMgmtMntrInfo()
    {
    }

    /**
     * Test of registerJobMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testRegisterJobMgmtMntrInfo()
    {
    }

    /**
     * Test of getAllRegisteredMgmtMntrInfo method, of class org.jmonks.batchserver.framework.repository.jdbc.JdbcRepository.
     */
    public void testGetAllRegisteredMgmtMntrInfo()
    {
    }

    private Map getMySQLConfigMap()
    {
        Map configMap=new HashMap();
        configMap.put(JdbcConnectionHelper.PROPERTY_JDBC_DRIVER_CLASS_NAME, "com.mysql.jdbc.Driver");
        configMap.put(JdbcConnectionHelper.PROPERTY_JDBC_URL, "jdbc:mysql://localhost:3306/batchserver");
        configMap.put(JdbcConnectionHelper.PROPERTY_DATABASE_USER_NAME, "root");
        configMap.put(JdbcConnectionHelper.PROPERTY_DATABASE_PASSWORD, "ramesh");
        return configMap;
    }
    
    
    class MySQLJdbcRepository extends JdbcRepository
    {

        /**
         * Creates a new instance of MySQLJdbcRepository
         */
        public MySQLJdbcRepository()
        {
        }

        public void init(Map configMap)
        {
            super.init(configMap);
        }
    }    
}

--- MySQLJdbcRepository.java DELETED ---