gvSIG projects pool

package org.gvsig.vcsgis.lib.workspace.tables;

import java.sql.Timestamp;

import javax.json.JsonObject;

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.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.dynobject.DynObjectValueItem;

import org.gvsig.tools.util.GetItemWithSizeAndIterator64;

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

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

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

import org.gvsig.vcsgis.lib.VCSGisRevision;

import org.gvsig.vcsgis.lib.VCSGisRevisionImpl;

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

/**

 *

 * @author gvSIG Team

 */

@SuppressWarnings("UseSpecificCatch")

public class LocalRevisionsTable extends AbstractTable {

    public static final String TABLE_NAME = "VCSGIS_LOCALREVISIONS";

    private static final String COD_REVISION = "COD_REVISION";

    private static final String COD_USER = "COD_USER";

    public static final String COD_ENTITY = "COD_ENTITY";

    private static final String REVISION_NUMBER = "REV_NUMBER";

    private static final String REVISION_COMMENT = "REV_COMMENT";

    private static final String REVISION_EFECTIVEDATE = "REV_EFECTIVEDATE";

    private static final String REVISION_DATE = "REV_OPERATIONDATE";

    private static final String REVISION_TAGS = "REV_TAGS";

    private static final String REVISION_GROUP = "REV_IDENTIFIER";

    private static final String REVISION_TOPOLOGYPLAN = "REV_TOPPLAN";

    public static class LocalRevisionRow extends AbstractRow implements VCSGisRevision {

        public LocalRevisionRow(VCSGisWorkspace workspace) {

            super(workspace, TABLE_NAME, COD_REVISION);

        }

        public LocalRevisionRow(VCSGisWorkspace workspace, Feature feature) {

            super(workspace, TABLE_NAME, COD_REVISION, feature);

        }

        public String getGroup() {

            return this.getString(REVISION_GROUP);

        }

        @Override

        public String getUserCode() {

            return this.getString(COD_USER);

        }

        @Override

        public String getRevisionCode() {

            return this.getCode();

        }

        @Override

        public Timestamp getRevisionDate() {

            return (Timestamp) this.getTimestamp(REVISION_DATE);

        }

        @Override

        public Timestamp getEfectiveDate() {

            return (Timestamp) this.getTimestamp(REVISION_EFECTIVEDATE);

        }

        @Override

        public int getTopologyPlan() {

            return this.getInt(REVISION_TOPOLOGYPLAN);

        }

        @Override

        public String getTags() {

            return this.getString(REVISION_TAGS);

        }

        @Override

        public long getNumber() {

            return this.getLong(REVISION_NUMBER);

        }

        @Override

        public String getComment() {

            return this.getString(REVISION_COMMENT);

        }

        @Override

        public String getEntityCode() {

            return this.getString(COD_ENTITY);

        }

        public void setGroup(String group) {

            this.set(REVISION_GROUP, group);

        }

        public void setUserCode(String code) {

            this.set(COD_USER, code);

        }

        public void setRevisionDate(Timestamp date) {

            this.set(REVISION_DATE, date);

        }

        public void setEfectiveDate(Timestamp date) {

            this.set(REVISION_EFECTIVEDATE, date);

        }

        public void setRevisionDate(java.util.Date date) {

            Timestamp tm = new Timestamp(date.getTime());

            this.set(REVISION_DATE, tm);

        }

        public void setEfectiveDate(java.util.Date date) {

            Timestamp tm = new Timestamp(date.getTime());

            this.set(REVISION_EFECTIVEDATE, tm);

        }

        public void setTopologyPlan(int topologyPlan) {

            this.set(REVISION_TOPOLOGYPLAN,topologyPlan);

        }

        public void setTags(String tags) {

            this.set(REVISION_TAGS,tags);

        }

        public void setComment(String comment) {

            this.set(REVISION_COMMENT, comment);

        }

        public void setEntityCode(String code) {

            this.set(COD_ENTITY, code);

        }

        public void setNumber(long number) {

            this.set(REVISION_NUMBER, number);

        }

        @Override

        public void copyFrom(VCSGisRevision other) {

            this.setCode(other.getRevisionCode());

            this.setComment(other.getComment());

            this.setEfectiveDate(other.getEfectiveDate());

            this.setEntityCode(other.getEntityCode());

            this.setRevisionDate(other.getRevisionDate());

            this.setTags(other.getTags());

            this.setUserCode(other.getUserCode());

            this.setNumber(other.getNumber());

            this.setTopologyPlan(other.getTopologyPlan());

        }

        @Override

        public LocalRevisionRow getValue() {

            return this;

        }

        @Override

        public String getLabel() {

            return VCSGisRevisionImpl.getLabel(this);

        }

        @Override

        public JsonObject toJson() {

            return this.toJsonBuilder().build();

        }

        @Override

        public JsonObjectBuilder toJsonBuilder() {

            return VCSGisRevisionImpl.toJsonBuilder(this);

        }

        @Override

        public String toString() {

            return VCSGisRevisionImpl.toString(this);

        }

        public boolean exists(FeatureStore store) {

            try {

                Feature f = store.findFirst("\""+COD_REVISION+"\" = '"+this.getCode()+"'");

                return f!=null;

            } catch (Exception ex) {

                throw new RuntimeException("Can't check if revision exists.", ex);

            }

        }

    }

    public LocalRevisionsTable() {

        super(TABLE_NAME, featureType());

    }

    public static final FeatureType featureType() {

        DataManager dataManager = DALLocator.getDataManager();

        EditableFeatureType ft = dataManager.createFeatureType();

        ft.setLabel("VCSGIS Revisions");

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

        ft.add(COD_REVISION, DataTypes.STRING)

                .setSize(40)

                .setIsPrimaryKey(true)

                .setLabel("Code");        

        ft.add(COD_USER, DataTypes.STRING)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setSize(40)

                .setLabel("Cod. user");

        ft.add(COD_ENTITY, DataTypes.STRING)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setSize(40)

                .setLabel("Cod. entity");

        ft.add(REVISION_GROUP, DataTypes.STRING)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setSize(40)

                .setLabel("Group");

        ft.add(REVISION_DATE, DataTypes.TIMESTAMP)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setLabel("Revision date");

        ft.add(REVISION_EFECTIVEDATE, DataTypes.TIMESTAMP)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setLabel("Efective date");

        ft.add(REVISION_NUMBER, DataTypes.LONG)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(true)

                .setLabel("Revision number");

        ft.add(REVISION_TOPOLOGYPLAN, DataTypes.INT)

                .setIsIndexed(false)

                .setLabel("Topology plan")

                .setAvailableValues(new DynObjectValueItem[] {

                    new DynObjectValueItem(TOPOLOGYPLAN_UNKNOWN, "Unknown"),

                    new DynObjectValueItem(TOPOLOGYPLAN_PASSED, "Passed"),

                    new DynObjectValueItem(TOPOLOGYPLAN_NOTPASSED, "Not passed"),

                });

        ft.add(REVISION_TAGS, DataTypes.STRING)

                .setSize(200)

                .setLabel("Tags");

        ft.add(REVISION_COMMENT, DataTypes.STRING)

                .setSize(200)

                .setLabel("Comment");

        return ft.getNotEditableCopy();

    }

    public LocalRevisionsTable(String tableName, FeatureType featureType) {

        super(tableName, featureType);

    }

    public void deleteByEntityCodeAndGroup(VCSGisWorkspace workspace, FeatureStore store, String entityCode, String group) {

        store.delete("\""+COD_ENTITY+"\" = '"+entityCode+"' AND \""+REVISION_GROUP+"\" = '"+group+"'");

    }

    public GetItemWithSizeAndIterator64<Feature> getRevisions(VCSGisWorkspace workspace, String entityCode, String group) {

        FeatureStore store = null;

        try {

            store = workspace.getFeatureStore(TABLE_NAME);

            GetItemWithSizeAndIterator64<Feature> revisions = store.getFeatures64(

                    "\""+COD_ENTITY+"\" = '"+entityCode+"' AND \""+REVISION_GROUP+"\" = '"+group+"'",

                    "\""+REVISION_NUMBER+"\"", 

                    true

            );

            return revisions;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve changes by entity.", ex);

        } finally {

            if( store!=null ) {

                DisposeUtils.dispose(store);

            }

        }

    }

}