Application: gvSIG desktop

import org.apache.commons.lang.StringUtils;

import org.gvsig.fmap.dal.store.jdbc2.AbstractTestUtils;

import org.gvsig.sqlite.dal.TestUtilsSQLite;

    private static final Logger LOGGER = LoggerFactory.getLogger(TestPerformChanges.class);

    public TestPerformChanges(String testName) {

        super(testName);

    }

    @Override

    protected void setUp() throws Exception {

        super.setUp();

        new DefaultLibrariesInitializer().fullInitialize();

    }

    @Override

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    // TODO add test methods here. The name must begin with 'test'. For example:

    // public void testHello() {}

    public void testPerformChanges() throws Exception {

        try {

            JDBCHelper helper = TestUtils.createJDBCHelper();

            JDBCSQLBuilderBase sqlbuilder = helper.createSQLBuilder();

            OperationsFactory operations = helper.getOperations();

            TestUtilsSQLite utils = new TestUtilsSQLite();

            AbstractTestUtils.Expecteds expected = utils.getExpecteds("performChanges.sql");

            List<String> expectedSQLs = expected.getAll("performChanges");

//            List<String> expectedSQLs = TestUtils.getSQLs("performChanges.sql");

            FeatureStore sourceStore = TestUtils.openSourceStore1();

            TableReference table = operations.createTableReference(

                    "dbtest",

                    sqlbuilder.default_schema(),

                    "test",

                    null

            );

            FeatureType featureType = sourceStore.getDefaultFeatureType();

            FeatureTypeChanged featureTypeChanged = new FeatureTypeChanged() {

                @Override

                public FeatureType getSource() {

                    EditableFeatureType ft = DALLocator.getDataManager().createFeatureType();

                    EditableFeatureAttributeDescriptor id = ft.add("ID", DataTypes.INT);

                    id.copyFrom(featureType.getAttributeDescriptor("ID"));

                    return ft;

                }

                @Override

                public FeatureType getTarget() {

                    return featureType;

                }

            };

            List<FeatureTypeChanged> featureTypesChangeds = Collections.singletonList(featureTypeChanged);

            PerformChangesOperation performChanges = operations.createPerformChanges(

                    table,

                    sourceStore.getDefaultFeatureType(),

                    null,

                    null,

                    null,

                    featureTypesChangeds.iterator()

            );

            String insertSQL = performChanges.getInsertSQL();

            String deleteSQL = performChanges.getDeleteSQL();

            String updateSQL = performChanges.getUpdateSQL();

            List<String> updateTableSQLs = performChanges.getUpdateTableSQLs();

            System.out.println("###### EXP[insert]:" + expectedSQLs.get(0) + "###");

            System.out.println("###### SQL[insert]:" + insertSQL);// + "###");

            System.out.println("###### EXP[delete]:" + expectedSQLs.get(1) + "###");

            System.out.println("###### SQL[delete]:" + deleteSQL);// + "###");    

            System.out.println("###### EXP[update]:" + expectedSQLs.get(2) + "###");

            System.out.println("###### SQL[update]:" + updateSQL);// + "###");    

            for (int i = 0; i < updateTableSQLs.size(); i++) {

                System.out.println("###### EXP[updatetable " + i + "]:" + StringUtils.replace(expectedSQLs.get(i + 3)," ","?") + "###");

                System.out.println("###### SQL[updatetable " + i + "]:" + StringUtils.replace(updateTableSQLs.get(i)," ","?"));// + "###");    

            }

            assertEquals("Insert SQL", expectedSQLs.get(0), insertSQL);

            assertEquals("Delete SQL", expectedSQLs.get(1), deleteSQL);

            assertEquals("Update SQL", expectedSQLs.get(2), updateSQL);

            assertEquals("UpdateTable num. SQLs", expectedSQLs.size() - 3, updateTableSQLs.size());

            for (int i = 0; i < updateTableSQLs.size(); i++) {

                assertEquals("UpdateTable SQL " + i, expectedSQLs.get(i + 3), updateTableSQLs.get(i));

//                assertTrue(expected.match("performChanges", i+3, updateTableSQLs.get(i)));

            }

        } catch (Throwable th) {

            LOGGER.warn("TestPerformChanges: ", th);

            throw th;

        }