gvSIG projects pool

package org.gvsig.vcsgis.lib.impl;

import java.io.File;

import java.util.List;

import junit.framework.TestCase;

import static junit.framework.TestCase.assertEquals;

import org.apache.commons.io.FileUtils;

import org.gvsig.expressionevaluator.Expression;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.feature.EditableFeature;

import org.gvsig.fmap.dal.feature.Feature;

import org.gvsig.fmap.dal.feature.FeatureStore;

import static org.gvsig.fmap.dal.feature.FeatureStore.MODE_PASS_THROUGH;

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

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.library.impl.DefaultLibrariesInitializer;

import org.gvsig.vcsgis.lib.SequentialCodeGenerator;

import org.gvsig.vcsgis.lib.VCSGisLocator;

import org.gvsig.vcsgis.lib.VCSGisManager;

import static org.gvsig.vcsgis.lib.VCSGisManager.ERR_NO_ERROR;

import static org.gvsig.vcsgis.lib.VCSGisManager.ERR_UPDATE_NEED_MERGE;

import static org.gvsig.vcsgis.lib.VCSGisManager.FEATURECODE_FIELD_NAME;

import static org.gvsig.vcsgis.lib.VCSGisManager.OP_DELETE;

import static org.gvsig.vcsgis.lib.VCSGisManager.OP_INSERT;

import static org.gvsig.vcsgis.lib.VCSGisManager.STATE_CONFLICT;

import org.gvsig.vcsgis.lib.repository.VCSGisRepository;

import org.gvsig.vcsgis.lib.workspace.VCSGisWorkspace;

import org.gvsig.vcsgis.lib.workspace.tables.RemoteChangesTable;

import org.gvsig.vcsgis.lib.workspace.tables.WorkspaceChangesTable;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class Test14UpdateWithConflict extends TestCase {

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

    public Test14UpdateWithConflict(String testName) {

        super(testName);

    }

    @Override

    protected void setUp() throws Exception {

        super.setUp();

        new DefaultLibrariesInitializer().fullInitialize();

    }

    @Override

    protected void tearDown() throws Exception {

        super.tearDown();

    }

    private void insert(FeatureStore store, int id, String text) throws DataException{

        EditableFeature ef = store.createNewFeature();

        ef.set("id",id);

        ef.set("text",text);

        store.insert(ef);

    }

    private void update(FeatureStore store, int id, String text) throws DataException{

        Feature f = store.findFirst("id="+id);

        EditableFeature ef = f.getEditable();

        ef.set("text", text);

        store.update(ef);

    }

    private void delete(FeatureStore store, int id, String text) throws DataException{

        Feature f = store.findFirst("id="+id);

        store.delete(f);

    }

    private void check(List<Feature> features, int index, int id, String text){

        assertEquals(id    , features.get(index).getInt("id"));

        assertEquals(text, features.get(index).getString("text"));

    }

    private void check(FeatureStore store2, String relatedFeatureCode, int id, String text) throws Exception {

        Feature f = store2.findFirst("VCSGISCODE = '"+relatedFeatureCode+"'");

        assertEquals(id, f.getInt("id"));

        assertEquals(text, f.getString("text"));

    }

    private void selectRemoteChange(VCSGisWorkspace ws, boolean select, int id, String text, VCSGisWorkspace wsSource) throws Exception {

        Feature fTest;

        FeatureStore testStore = ws.getFeatureStore("test");

        FeatureStore testStoreSource = wsSource.getFeatureStore("test");

        fTest = testStoreSource.findFirst("id = "+id);

        FeatureStore rchangesStore = ws.getFeatureStore(RemoteChangesTable.TABLE_NAME);

        Feature fChanges = rchangesStore.findFirst("RCH_DATACODE = '"+fTest.getString(FEATURECODE_FIELD_NAME)+"'");

        EditableFeature efChanges = fChanges.getEditable();

        rchangesStore.edit(MODE_PASS_THROUGH);

        efChanges.set("RCH_SELECTED",select);

        rchangesStore.update(efChanges);

        rchangesStore.finishEditing();

        DisposeUtils.dispose(testStore);

        DisposeUtils.dispose(testStoreSource);

        DisposeUtils.dispose(rchangesStore);

    }

    private void checkLocalChange(FeatureStore data, FeatureStore changes, String code, int operation, int id, String text, int status) throws DataException{

        Feature change = changes.findFirst("WSCH_FEATURECODE = '"+code+"'");

        assertNotNull("Change code not exists", change);

        assertEquals(operation, change.getInt(WorkspaceChangesTable.OPERATION));

        if(status >=0){

            assertEquals(status, change.getInt(WorkspaceChangesTable.STATUS));

        }

        // Uf, ojo con operation delete, no tiene data. en la primera pasada lo saltaria, y a ver que pasa con

        // los inserts y updates.

//        if(operation != OP_DELETE){

//            Feature f = data.findFirst("VCSGISCODE = '"+code+"'");

//            assertEquals(id  , f.getInt("id"));

//            assertEquals(text, f.getString("text"));

//        }

    }

    private VCSGisWorkspace[] initTest() throws Exception{

        VCSGisManager manager = VCSGisLocator.getVCSGisManager();

        JDBCServerExplorer server = TestUtils.openServerExplorer("srv-update");

        File ws1file = TestUtils.getFile(FileUtils.getFile("test-dbs","ws1-update")); 

        File ws2file = TestUtils.getFile(FileUtils.getFile("test-dbs","ws2-update")); 

        File ws3file = TestUtils.getFile(FileUtils.getFile("test-dbs","ws3-update")); 

        manager.setCodeGenerator(new SequentialCodeGenerator());

        int r;

        List<Feature> features;

        FeatureStore store2;

        FeatureStore store3;

        // ------------------------------------------------------------

        // Inicializamos el repositorio y lo abrimos

        r = manager.initRepository(server.getParameters(), null);

        assertEquals("init_server status", ERR_NO_ERROR, r);

        VCSGisRepository repo = manager.openRepository(server.getParameters());

        TestUtils.h2sql_repository(repo);

        // ------------------------------------------------------------

        // Creamos workspace1 y lo abrimos.

        r = manager.initWorkspace(ws1file, repo, "Test update1",null);

        assertEquals("init_ws1 status", ERR_NO_ERROR, r);

        VCSGisWorkspace ws1 = manager.openWorkspace(ws1file);

        TestUtils.h2sql_workspace(ws1);

        // ------------------------------------------------------------

        // Adicionamos al workspace1 la tabla "test" y la commitamos.

        //REV 0

        FeatureStore sourceTest = TestUtils.openSourceStore2();

        r = ws1.add("test", sourceTest, "text");

        DisposeUtils.disposeQuietly(sourceTest);

        assertEquals("ws1.add status", ERR_NO_ERROR, r);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // ------------------------------------------------------------

        // Inicializamos el workspace2 asociandolo al mismo repositorio que 

        // workspace1 y lo abrimos.

        r = manager.initWorkspace(ws2file, repo, "Test update2",null);

        assertEquals("init_ws2 status", ERR_NO_ERROR, r);

        VCSGisWorkspace ws2 = manager.openWorkspace(ws2file);

        TestUtils.h2sql_workspace(ws2);

        // ------------------------------------------------------------

        // Actualizamos (update) la tabla "test" en el workspace2 

        // y comprobamos que tiene lo que toca.

        r = ws2.checkout("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        store2 = ws2.getFeatureStore("test");

        assertEquals("ws2-upfate sizes", 3, store2.size64());

        features = store2.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CCC");

        DisposeUtils.disposeQuietly(features);

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Inicializamos el workspace3 asociandolo al mismo repositorio que 

        // workspace1 y lo abrimos.

        r = manager.initWorkspace(ws3file, repo, "Test update2",null);

        assertEquals("init_ws2 status", ERR_NO_ERROR, r);

        VCSGisWorkspace ws3 = manager.openWorkspace(ws3file);

        TestUtils.h2sql_workspace(ws3);

        // ------------------------------------------------------------

        // Actualizamos (update) la tabla "test" en el workspace3

        // y comprobamos que tiene lo que toca.

        r = ws3.checkout("test");

        assertEquals("ws3.update-1 status", ERR_NO_ERROR, r);

        store3 = ws3.getFeatureStore("test");

        assertEquals("ws3-upfate sizes", 3, store3.size64());

        features = store3.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CCC");

        DisposeUtils.disposeQuietly(features);

        DisposeUtils.disposeQuietly(store2);

        DisposeUtils.disposeQuietly(store3);

        return new VCSGisWorkspace[] {ws1, ws2, ws3};

    }

    public void testTwoUpdatesAndMerge() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        int r;

        Feature f;

        EditableFeature ef;

        FeatureStore store1;

        FeatureStore store2;

        // Añadimos al workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        update(store1, 3, "CC1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Añadimos al workspace2 una feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        update(store2, 3, "CC2");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

//        assertTrue(false);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        // Actualizamos (merge) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.merge("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        //Comprobar que en la tabla de cambios locales hay 1 elemento

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 1, changes.size64());

    }

    public void testTwoUpdatesMergeAndUpdate() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        VCSGisWorkspace ws3 = wss[2];

        int r;

        Feature f;

        EditableFeature ef;

        FeatureStore store1;

        FeatureStore store2;

        FeatureStore store3;

        // Editamos en el workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        update(store1, 3, "CC1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Editamos en el workspace2 la feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        update(store2, 3, "CC2");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

//        assertTrue(false);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        // Actualizamos (merge) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.merge("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        //Comprobar que en la tabla de cambios locales hay 1 elemento

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 1, changes.size64());

        // Commitamos el workspace2

        r = ws2.commit();

        assertEquals("ws2.commit-1 status", ERR_NO_ERROR, r);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace3

        // comprobamos que funciona y que tiene lo que toca.

        r = ws3.updatePrepare("test");

        assertEquals("ws3.update-1 status", ERR_NO_ERROR, r);

        //Comprobar que en la tabla de cambios remotos hay 1 elemento

        FeatureStore remoteChanges = ws3.getFeatureStore(RemoteChangesTable.TABLE_NAME);

        assertEquals("ws3-remoteChanges size", 1, remoteChanges.size64());

        // Actualizamos (update) la tabla "test" en el workspace3 

        // comprobamos que no falla

        r = ws3.update("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        store3 = ws3.getFeatureStore("test");

        assertEquals("ws3-update sizes", 3, store3.size64());

        List<Feature> features = store3.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CC2");

        DisposeUtils.disposeQuietly(store3);

    }

    public void testTwoUpdatesAndUpdate() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        int r;

        Feature f;

        EditableFeature ef;

        FeatureStore store1;

        FeatureStore store2;

        // Añadimos al workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        update(store1, 3, "CC1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Añadimos al workspace2 una feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        update(store2, 3, "CC2");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

//        assertTrue(false);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        //Seleccionar el cambio conflictivo id=4

        selectRemoteChange(ws2, true, 3, "CC1", ws1);

        // Actualizamos (merge) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        //Comprobar que en la tabla de cambios locales no hay nada

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 0, changes.size64());

    }

    public void testTwoInsertsAndUpdate() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        int r;

        Feature f;

        EditableFeature ef;

        List<Feature> features;

        FeatureStore store1;

        FeatureStore store2;

                // Añadimos al workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        insert(store1, 4, "DD1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Añadimos al workspace2 una feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        insert(store2, 4, "DD2");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        checkLocalChange(store2, changes, "00000000000037abcdef0123456789", OP_INSERT, 4, "DD2", STATE_CONFLICT);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        //Seleccionar el cambio conflictivo id=4

        selectRemoteChange(ws2, true, 4, "DD1", ws1);

        //update y comprobar que funciona y se ha borrado la feature conflictiva nuestra

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        store2 = ws2.getFeatureStore("test");

        assertEquals("ws2-upfate sizes", 4, store2.size64());

        features = store2.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CCC");

        check(features, 3, 4, "DD1");

        //Comprobar que en la tabla de cambios locales no hay nada

        changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 0, changes.size64());

    }

    public void testTwoInsertsAndMerge() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        int r;

        Feature f;

        EditableFeature ef;

        List<Feature> features;

        FeatureStore store1;

        FeatureStore store2;

                //Insertamos dos registros nuevos y repetirlo todo sin seleccionar cambio conflictivo y hacer un merge y que funcione

        // Añadimos al workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        insert(store1, 4, "DD1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Añadimos al workspace2 una feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        insert(store2, 4, "DD2");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        //merge y comprobar que funciona y no se insertado el cambio conflictivo

        r = ws2.merge("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        store2 = ws2.getFeatureStore("test");

        assertEquals("ws2-upfate sizes", 4, store2.size64());

        features = store2.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CCC");

        check(features, 3, 4, "DD2");

        //Comprobamos que se ha añadido a la tabla de cambios local el delete del cambio conflictivo

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 2, changes.size64());

        checkLocalChange(store2, changes, "00000000000029abcdef0123456789", OP_DELETE, 4, "DD1", -1);

        checkLocalChange(store2, changes, "00000000000037abcdef0123456789", OP_INSERT, 4, "DD2", -1);

    }

    public void testOneCommitAndUpdateOverDeleted() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        List<Feature> features;

        int r;

        Feature f;

        EditableFeature ef;

        FeatureStore store1;

        FeatureStore store2;

        // Modificamos en workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        update(store1, 3, "CC1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Borramos en el workspace2 la feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        delete(store2, 3, "CCC");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

//        assertTrue(false);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que falla

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

//        // Actualizamos (merge) la tabla "test" en el workspace2 

//        // comprobamos que no falla

//        r = ws2.merge("test");

//        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        //Seleccionar el cambio conflictivo id=4

        selectRemoteChange(ws2, true, 3, "CC1", ws1);

        //update y comprobar que funciona y no se ha insertado la feature conflictiva

        r = ws2.update("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        store2 = ws2.getFeatureStore("test");

        assertEquals("ws2-update sizes", 3, store2.size64());

        features = store2.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

        check(features, 2, 3, "CC1");

        //Comprobar que en la tabla de cambios locales no hay nada

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 0, changes.size64());

    }

    public void testOneCommitAndMergeOverDeleted() throws Exception {

        VCSGisWorkspace[] wss = initTest();

        VCSGisWorkspace ws1 = wss[0];

        VCSGisWorkspace ws2 = wss[1];

        List<Feature> features;

        int r;

        Feature f;

        EditableFeature ef;

        FeatureStore store1;

        FeatureStore store2;

        // Modificamos en workspace1 una feature con una id concreta y la commitamos

        store1 = ws1.getFeatureStore("test");

        store1.edit();

        update(store1, 3, "CC1");

        store1.finishEditing();

        DisposeUtils.disposeQuietly(store1);

        r = ws1.commit();

        assertEquals("ws1.commit-1 status", ERR_NO_ERROR, r);

        // Borramos en el workspace2 la feature con la misma id

        store2 = ws2.getFeatureStore("test");

        store2.edit();

        delete(store2, 3, "CCC");

        store2.finishEditing();

        DisposeUtils.disposeQuietly(store2);

        // ------------------------------------------------------------

        // Preparamos la actualización de (updatePrepare) la tabla "test" en el workspace2 

        // comprobamos que funciona y que tiene lo que toca.

        r = ws2.updatePrepare("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

//        assertTrue(false);

        // Actualizamos (update) la tabla "test" en el workspace2 

        // comprobamos que falla

//        r = ws2.update("test");

//        assertEquals("ws2.update-1 status", ERR_UPDATE_NEED_MERGE, r);

        // Actualizamos (merge) la tabla "test" en el workspace2 

        // comprobamos que no falla

        r = ws2.merge("test");

        assertEquals("ws2.update-1 status", ERR_NO_ERROR, r);

        //Comprobamos que en workspace2 hay lo que toca

        store2 = ws2.getFeatureStore("test");

        assertEquals("ws2-update sizes", 2, store2.size64());

        features = store2.getFeatures((Expression)null, "id", true);

        check(features, 0, 1, "AAA");

        check(features, 1, 2, "BBB");

//        check(features, 2, 3, "CC1");

        //Comprobar que en la tabla de cambios locales permanece el cambio

        FeatureStore changes = ws2.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("ws2-changes size", 1, changes.size64());

    }

}