gvSIG projects pool

package org.gvsig.vcsgis.lib.repository.localdb.tables;

import java.security.MessageDigest;

import javax.json.JsonObject;

import org.apache.commons.codec.binary.Hex;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

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

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

import org.gvsig.fmap.dal.feature.FeatureSet.DisposableFeatureSetIterable;

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

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

import org.gvsig.json.JsonObjectBuilder;

import org.gvsig.tools.dataTypes.DataTypes;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.dynform.spi.DynFormSPIManager;

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

import org.gvsig.vcsgis.lib.VCSGisTopologyPlan;

import org.gvsig.vcsgis.lib.VCSGisTopologyPlanImpl;

import static org.gvsig.vcsgis.lib.VCSGisUtils.updateMessageDigest;

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

/**

 *

 * @author gvSIG Team

 */

@SuppressWarnings("UseSpecificCatch")

public class TopologyplanRepoTable extends AbstractRepoTable {

    public static final String TABLE_NAME = "VCSGISREPO_TOPOLOGYPLANS";

    public static final String COD_TOPOLOGYPLAN = "COD_TOPOLOGYPLAN";

    public static final String TOPPLAN_NAME = "TOPP_NAME";

    private static final String TOPPLAN_DESCRIPTION = "TOPP_DESCRIPTION";

    private static final String TOPPLAN_DATA = "TOPP_DATA";

    public static class TopologyplanRow extends AbstractRow implements VCSGisTopologyPlan {

        public TopologyplanRow(VCSGisRepositoryLocaldb repository) {

            super(repository, TABLE_NAME, COD_TOPOLOGYPLAN, null);

        }

        public TopologyplanRow(VCSGisRepositoryLocaldb repository, Feature feature) {

            super(repository, TABLE_NAME, COD_TOPOLOGYPLAN, feature);

        }

        @Override

        public String getTopologyPlanCode() {

            return this.getString(COD_TOPOLOGYPLAN);

        }

        @Override

        public String getName() {

            return this.getString(TOPPLAN_NAME);

        }

        @Override

        public String getDescription() {

            return this.getString(TOPPLAN_DESCRIPTION);

        }

        @Override

        public String getData() {

            return this.getString(TOPPLAN_DATA);

        }

        @Override

        public String getLabel() {

            return this.getName();

        }

        @Override

        public VCSGisTopologyPlan getValue() {

            return this;

        }

        @Override

        public void copyFrom(VCSGisTopologyPlan other) {

            this.set(COD_TOPOLOGYPLAN,other.getTopologyPlanCode());

            this.set(TOPPLAN_NAME,other.getName());

            this.set(TOPPLAN_DESCRIPTION,other.getDescription());

            this.set(TOPPLAN_DATA,other.getData());

        }

        @Override

        public JsonObject toJson() {

            return this.toJsonBuilder().build();

        }

        @Override

        public JsonObjectBuilder toJsonBuilder() {

            return VCSGisTopologyPlanImpl.toJsonBuilder(this);

        }

        @Override

        public String toString() {

            return VCSGisTopologyPlanImpl.toString(this);

        }

    }

    public static final FeatureType featureType() {

        DataManager dataManager = DALLocator.getDataManager();

        EditableFeatureType ft = dataManager.createFeatureType();

        ft.setLabel("VCSGIS TopologyPlans");

        ft.getTags().set("ID", TABLE_NAME);

        ft.getTags().set(DynFormSPIManager.TAG_DYNFORM_HEIGHT, 300);

        ft.getTags().set(DynFormSPIManager.TAG_DYNFORM_WIDTH, 570);

        ft.getTags().set(DynFormSPIManager.TAG_DYNFORM_LAYOUTMODE, DynFormSPIManager.TAG_DYNFORM_LAYOUTMODE_VALUE_TABS);

        ft.add(COD_TOPOLOGYPLAN, DataTypes.STRING)

                .setSize(VCSGISCODELEN)

                .setIsPrimaryKey(true)

                .setLabel("Code")

                .setReadOnly(false)

                .setDefaultFieldValue("<%=replace(UUID(),'-','')%>");

        ft.add(TOPPLAN_NAME, DataTypes.STRING)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setSize(50)

                .setLabel("Name");

        ft.add(TOPPLAN_DESCRIPTION, DataTypes.STRING)

                .setDataProfileName("Text")

                .setSize(10240)

                .setLabel("Description");

        ft.add(TOPPLAN_DATA, DataTypes.STRING)

                .setDataProfileName("Text")

                .setSize(10240)

                .setLabel("Serialized topology plan in json.")

                .setGroup("Plan");

        return ft.getNotEditableCopy();

    }

    public TopologyplanRepoTable() {

        super(TABLE_NAME, featureType());

    }

    public String getByCode(VCSGisRepositoryLocaldb repository, String topologyPlanCode) {

        FeatureStore store = null;

        try {

            store = repository.getFeatureStore(TABLE_NAME);

            Feature f = store.findFirst("\"" + COD_TOPOLOGYPLAN + "\"='" + topologyPlanCode + "'");

            if (f == null) {

                return null;

            }

            return f.getString(TOPPLAN_DATA);

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve topology plan '" + topologyPlanCode + "'.", ex);

        } finally {

            DisposeUtils.disposeQuietly(store);

        }

    }

    public DisposableFeatureSetIterable getAll(VCSGisRepositoryLocaldb repository) {

        FeatureStore store = null;

        try {

            store = repository.getFeatureStore(TABLE_NAME);

            DisposableFeatureSetIterable changes = store.getFeatureSet().iterable();

            return changes;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve all topology plans.", ex);

        } finally {

            if( store!=null ) {

                DisposeUtils.dispose(store);

            }

        }

    }

    public String getHashCode(VCSGisRepositoryLocaldb repository) {

        FeatureStore store = null;

        DisposableFeatureSetIterable changes = null;

        try {

            MessageDigest md = MessageDigest.getInstance("MD5");

            store = repository.getFeatureStore(TABLE_NAME);

            changes = store.getFeatureSet().iterable();

            for (Feature change : changes) {

                updateMessageDigest(md, change, COD_TOPOLOGYPLAN);

                updateMessageDigest(md, change, TOPPLAN_NAME);

                updateMessageDigest(md, change, TOPPLAN_DESCRIPTION);

                updateMessageDigest(md, change, TOPPLAN_DATA);

            }

            String hash = Hex.encodeHexString(md.digest());

            return hash;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve hash of topology plans.", ex);

        } finally {

            DisposeUtils.dispose(changes);

            DisposeUtils.dispose(store);

        }

    }

}