Application: gvSIG desktop

package org.gvsig.fmap.dal.store.h2.operations.usecases.arena2;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import org.gvsig.fmap.dal.DatabaseWorkspaceManager;

import static org.gvsig.fmap.dal.DatabaseWorkspaceManager.TABLE_REPOSITORY_NAME;

import org.gvsig.fmap.dal.SQLBuilder;

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

import static org.gvsig.fmap.dal.store.h2.operations.usecases.arena2.TestAlternativeResourcesStorage.DBNAME;

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

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

import org.gvsig.fmap.dal.store.jdbc2.spi.JDBCSQLBuilderBase;

/**

 *

 * @author jjdelcerro

 */

public class TestArena2Utils {

    public static DatabaseWorkspaceManager initDatabase(AbstractTestUtils utils, String dbname) throws Exception {

        DatabaseWorkspaceManager workspace = utils.initWorkspace(dbname);

        workspace.createTableRepository(TABLE_REPOSITORY_NAME);

        JDBCServerExplorer dbserver = (JDBCServerExplorer) workspace.getServerExplorer();

        utils.info_jdbc(dbname, dbserver);

        FeatureStore[] csv_arena2_stores = new FeatureStore[] {

            utils.openCSVStore("usecases/arena2/ARENA2_CONDUCTORES.csv"),

            utils.openCSVStore("usecases/arena2/ARENA2_ACCIDENTES.csv"),

            utils.openCSVStore("usecases/arena2/ARENA2_VEHICULOS.csv")

        };

        for (FeatureStore sourceStore : csv_arena2_stores) {

            String tableName = sourceStore.getName();

            utils.drop_tables(dbserver, tableName);

            utils.create_table_from(dbserver, tableName, sourceStore);

            FeatureStore dbstore = (FeatureStore) dbserver.open(tableName);

            sourceStore.copyTo(dbstore);

            workspace.writeStoresRepositoryEntry(tableName, dbstore.getParameters());

        }

        return workspace;

    }

    public static void runSQLToCheckSyntax(AbstractTestUtils utils, String testName, String sql) throws Exception {

        DatabaseWorkspaceManager ws = initDatabase(utils, testName+"-"+utils.hashCode());

        JDBCServerExplorer explorer = (JDBCServerExplorer) ws.getServerExplorer();

        explorer.execute(sql);

    }

    public static void runSQLToCheckSyntax(DatabaseWorkspaceManager ws, String testName, String sql) throws Exception {

        JDBCServerExplorer explorer = (JDBCServerExplorer) ws.getServerExplorer();

        explorer.execute(sql);

    }

    static SQLBuilder createSQLBuilder(DatabaseWorkspaceManager ws) {

        JDBCServerExplorer explorer = (JDBCServerExplorer) ws.getServerExplorer();

        return explorer.createSQLBuilder();

    }

}