Simpler is better!

<context:property-placeholder location="jdbc.properties" />

<bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
    <property name="driverClassName" value="${ds1.jdbc.driverClassName}" />
    <property name="url" value="${ds1.jdbc.url}" />
    <property name="username" value="${ds1.jdbc.username}" />
    <property name="password" value="${ds1.jdbc.password}" />
</bean>

<bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
    <property name="driverClassName" value="${ds2.jdbc.driverClassName}" />
    <property name="url" value="${ds2.jdbc.url}" />
    <property name="username" value="${ds2.jdbc.username}" />
    <property name="password" value="${ds2.jdbc.password}" />
</bean>

package migration.test;

import java.io.FileOutputStream;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import javax.sql.DataSource;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.dbunit.Assertion;
import org.dbunit.database.DatabaseConfig;
import org.dbunit.database.DatabaseConnection;
import org.dbunit.database.IDatabaseConnection;
import org.dbunit.database.QueryDataSet;
import org.dbunit.dataset.ITable;
import org.dbunit.dataset.xml.FlatXmlDataSet;
import org.dbunit.ext.oracle.Oracle10DataTypeFactory;
import org.junit.After;
import org.junit.AfterClass;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.jdbc.datasource.DataSourceUtils;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

/**
 * DataVerificationTest
 * 
 * @author Sehwan Noh (sehwan at java2go.net)
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:applicationContext-test.xml" })
public class DataVerificationTest {

    private final Log logger = LogFactory.getLog(getClass());

    @Autowired
    @Qualifier("dataSource1")
    private DataSource dataSource1;

    @Autowired
    @Qualifier("dataSource2")
    private DataSource dataSource2;

    private Connection conn1;

    private Connection conn2;

    @BeforeClass
    public static void setUpBeforeClass() throws Exception {
    }

    @AfterClass
    public static void tearDownAfterClass() throws Exception {
    }

    @Before
    public void setUp() throws Exception {
        conn1 = DataSourceUtils.getConnection(dataSource1);
        conn2 = DataSourceUtils.getConnection(dataSource2);
    }

    @After
    public void tearDown() throws Exception {
        DataSourceUtils.releaseConnection(conn1, dataSource1);
        DataSourceUtils.releaseConnection(conn2, dataSource2);
    }

    /**
     * Test to verify TABLE_A
     */
    @Test
    public void testPeDocMain() throws Exception {
        final String tableName = "TABLE_A";
        final String query = "SELECT * FROM " + tableName;
        logger.debug("query=" + query);

        assertTableEquals(conn1, conn2, tableName, query);
    }

    /**
     * Test to verify TABLE_B
     */
    @Test
    public void testPeDocDetail() throws Exception {
        final String columnNames = "COLUMN1, COLUMN2, COLUMN3";
        final String tableName = "TABLE_B";
        final String query = "SELECT " + columnNames + " FROM " + tableName;
        logger.debug("query=" + query);

        assertTableEquals(conn1, conn2, tableName, query);
    }

    private void assertTableEquals(Connection conn1, Connection conn2, 
                String tableName, String query) throws Exception {
        // Table1
        // IDatabaseConnection dbConn1 = new DatabaseConnection(conn1);
        IDatabaseConnection dbConn1 = getConnection(conn1);
        QueryDataSet dataSet1 = new QueryDataSet(dbConn1);
        dataSet1.addTable(tableName, query);
        FlatXmlDataSet.write(dataSet1, new FileOutputStream("./test-output/"
                + tableName + "_1.xml"));
        ITable table1 = dataSet1.getTable(tableName);

        // Table2
        // IDatabaseConnection dbConn2 = new DatabaseConnection(conn2);
        IDatabaseConnection dbConn2 = getConnection(conn2);
        QueryDataSet dataSet2 = new QueryDataSet(dbConn2);
        dataSet2.addTable(tableName, query);
        FlatXmlDataSet.write(dataSet2, new FileOutputStream("./test-output/"
                + tableName + "_2.xml"));
        ITable table2 = dataSet2.getTable(tableName);

        if (logger.isInfoEnabled()) {
            logger.info("==========================================");
            logger.info(tableName);
            logger.info("------------------------------------------");
            logger.info("Table1 Row Count: " + table1.getRowCount());
            logger.info("Table2 Row Count: " + table2.getRowCount());
            logger.info("==========================================");
        }

        // Assertion
        // Assert.assertEquals(table1.getRowCount(), table2.getRowCount());
        Assertion.assertEquals(table1, table2);
    }

    private IDatabaseConnection getConnection(Connection conn) throws Exception {
        // IDatabaseConnection dbConn = new DatabaseConnection(conn);
        DatabaseMetaData databaseMetaData = conn.getMetaData();
        IDatabaseConnection dbConn = new DatabaseConnection(conn, 
                databaseMetaData.getUserName().toUpperCase());
        DatabaseConfig config = dbConn.getConfig(); // Orable 10g
        config.setProperty(DatabaseConfig.PROPERTY_DATATYPE_FACTORY, 
                new Oracle10DataTypeFactory());
        config.setFeature(DatabaseConfig.FEATURE_SKIP_ORACLE_RECYCLEBIN_TABLES,
                Boolean.TRUE);
        return dbConn;
    }
}

<target name="test-verify">
    <mkdir dir="${test.output.dir}" />
    <junit fork="yes" printsummary="yes" haltonfailure="false">
        <classpath refid="classpath" />
        <formatter type="plain" usefile="true" />
        <formatter type="xml" usefile="true" />
        <batchtest fork="yes" todir="${test.output.dir}">
            <fileset dir="${src.dir}">
                <include name="**/test/*Test.java" />
            </fileset>
        </batchtest>
    </junit>
</target>

<target name="test-report">
    <mkdir dir="${test.report.dir}" />
    <junitreport todir="${test.output.dir}">
        <fileset dir="${test.output.dir}">
            <include name="TEST-*.xml" />
        </fileset>
        <report format="frames" todir="${test.report.dir}" />
    </junitreport>
</target>

<data a="1" b="2" c="3"/>

<data b="2" c="3" a="1"/>

<data c="3" a="1" b="2"></data>

<data c="3" a="1"
            b="2"></data>

<data a="1" b="2" c="3"></data>