gvSIG projects pool

package org.gvsig.vcsgis.lib.impl;

import java.io.File;

import junit.framework.TestCase;

import static junit.framework.TestCase.assertEquals;

import org.apache.commons.io.FileUtils;

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

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.VCSGisLocator;

import org.gvsig.vcsgis.lib.VCSGisManager;

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

import org.gvsig.vcsgis.lib.repository.localdb.VCSGisRepositoryLocaldb;

import org.gvsig.vcsgis.lib.repository.localdb.tables.DataRepoTable;

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

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

public class Test06AddCommit extends TestCase {

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

    public Test06AddCommit(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 testAddCommit() throws Exception {

        final String testid = "LocaldbAddCommit";

        VCSGisManager manager = VCSGisLocator.getVCSGisManager();

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

        File wsfile = TestUtils.getFile(FileUtils.getFile("test-dbs","ws-"+testid));

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

        // Creamos el respositorio y lo abrimos.

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

        assertEquals("srv-init status", 0, r);

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

        TestUtils.h2sql_repository(repo);

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

        // Creamos un workspace y lo abrimos.

        r = manager.initWorkspace(wsfile, repo, "Test add and commit",null);

        assertEquals("ws-init status", 0, r);

        VCSGisWorkspace ws = manager.openWorkspace(wsfile);

        TestUtils.h2sql_workspace(ws);

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

        // Adicionamos al workspace la tabla de pruebas y lo commitamos

        FeatureStore sourceStore = TestUtils.openSourceStore1();

        r = ws.add("sourceStore1", sourceStore, "ID");

        assertEquals("ws-add status", 0, r);

        r = ws.commit();

        assertEquals("ws-commit status", 0, r);

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

        // Comprobamos que tras el commit la tabla de cambios esta vacia.

        FeatureStore changesStore = ws.getFeatureStore(WorkspaceChangesTable.TABLE_NAME);

        assertEquals("Changes", 0, changesStore.size64());

        DisposeUtils.disposeQuietly(changesStore);

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

        // Comprobamos que la tabla adicionada al espacio ed trabajo contiene

        // los mismos registros que la original.

        FeatureStore dataStore = ((VCSGisRepositoryLocaldb)repo).getFeatureStore(DataRepoTable.TABLE_NAME);

        assertEquals("DataStore", sourceStore.size64(), dataStore.size64());

        sourceStore.dispose();

        DisposeUtils.disposeQuietly(dataStore);

    }

}