Application: gvSIG desktop

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package org.gvsig.fmap.dal.store.csv;

import java.io.File;

import java.io.FileOutputStream;

import java.io.FileWriter;

import java.io.IOException;

import java.io.OutputStreamWriter;

import java.io.Writer;

import org.apache.commons.lang3.ArrayUtils;

import org.gvsig.fmap.dal.DataTypes;

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

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

import org.gvsig.fmap.dal.feature.exception.PerformEditingException;

import org.gvsig.fmap.dal.feature.spi.FeatureProvider;

import org.gvsig.fmap.geom.Geometry;

import org.gvsig.fmap.geom.primitive.Envelope;

import org.gvsig.tools.ToolsLocator;

import org.gvsig.tools.dataTypes.CoercionException;

import org.gvsig.tools.dataTypes.DataTypeUtils;

import org.gvsig.tools.dataTypes.Coercion;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.supercsv.io.CsvListWriter;

import org.supercsv.prefs.CsvPreference;

import org.gvsig.tools.dataTypes.CoercionContext;

/**

 *

 * @author osc

 */

@SuppressWarnings("UseSpecificCatch")

public class CSVFeatureWriter {

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

  private Envelope envelope = null;

  private boolean calculate_envelope = false;

  private CsvListWriter listWriter = null;

  private CsvPreference csvpreferences = null;

  private Writer writer = null;

  private FeatureType ftype;

  private File file;

  private String[] values;

  private FeatureAttributeDescriptor[] descriptors;

  private Coercion convert = null;

//  private CoercionContext converContext = null;

  private int errorcounts = 0;

  private Throwable lasterror = null;

  private CSVStoreParameters storeParameters;

  private String charset = null;

  private boolean includeMetadataInHeader;

  public void initialize(CSVStoreParameters storeParameters, File file, FeatureType ftype, CsvPreference csvpreferences) {

    this.file = file;

    this.ftype = ftype;

    this.storeParameters = storeParameters;

    if (csvpreferences == null) {

      this.csvpreferences = CSVStoreParameters.getPredefinedCSVPreferences(storeParameters);

    } else {

      this.csvpreferences = csvpreferences;

    }

    if (this.ftype != null) {

      this.descriptors = this.ftype.getAttributeDescriptors();

      if (ftype.getDefaultGeometryAttributeName() != null) {

        this.calculate_envelope = true;

      }

    }

    this.convert = ToolsLocator.getDataTypesManager().getCoercion(DataTypes.STRING);

//    this.converContext = DataTypeUtils.coerceContextLocale(CSVStoreParameters.getLocale(this.storeParameters));

    this.errorcounts = 0;

    this.charset = CSVStoreParameters.getCharset(storeParameters);

    this.includeMetadataInHeader = CSVStoreParameters.getIncludeMetadataInHeader(storeParameters);

    }

  public void beginAppend() {

    try {

      FileOutputStream fos = new FileOutputStream(file, true);

      if (this.charset != null) {

        this.writer = new OutputStreamWriter(fos, this.charset);

      } else {

        this.writer = new OutputStreamWriter(fos);

      }

      this.listWriter = new CsvListWriter(this.writer, this.csvpreferences);

      if (ftype != null) {

        this.descriptors = ftype.getAttributeDescriptors();

        int n = 0;

        for (FeatureAttributeDescriptor descriptor : descriptors) {

          if (descriptor.getEvaluator() == null) {

            n++;

          }

        }

        this.values = new String[n];

      }

    } catch (IOException e) {

      LOGGER.warn("Can't open file for write (" + file.getAbsolutePath() + ").", e);

      throw new RuntimeException(e);

    }

  }

  public void begin() {

    try {

      this.writer = new FileWriter(file);

    } catch (IOException e) {

      LOGGER.warn("Can't open file for write (" + file.getAbsolutePath() + ").", e);

      throw new RuntimeException(e);

    }

    this.listWriter = new CsvListWriter(this.writer, this.csvpreferences);

    int n = 0;

    for (FeatureAttributeDescriptor descriptor : descriptors) {

      if (descriptor.getEvaluator() == null) {

        n++;

      }

    }

    String[] header = new String[n];

    this.values = new String[n];

    n = 0;

      for (FeatureAttributeDescriptor descriptor : descriptors) {

          if (!descriptor.isComputed()) {

              if (includeMetadataInHeader) {

                header[n++] = (String) descriptor.get("all");

              } else {

                header[n++] = (String) descriptor.getName();

              }

          }

      }

    try {

      listWriter.writeHeader(header);

    } catch (Exception e) {

      LOGGER.warn("Can't write header '" + ArrayUtils.toString(header) + "' file for write (" + file.getAbsolutePath() + ").", e);

      throw new RuntimeException(e);

    }

  }

  public void add(FeatureProvider feature) {

    if (this.calculate_envelope) {

      Geometry geom = feature.getDefaultGeometry();

      if (geom != null) {

        if (envelope == null) {

          try {

            envelope = (Envelope) geom.getEnvelope().clone();

          } catch (CloneNotSupportedException e) {

            LOGGER.warn("Este error no deberia pasar, siempre se puede hacer un clone de un envelope.", e);

          }

        } else {

          envelope.add(geom.getEnvelope());

        }

      }

    }

    for (int i = 0; i < descriptors.length; i++) {

      FeatureAttributeDescriptor descriptor = descriptors[i];

      if (descriptor.getEvaluator() == null) {

        Object value = feature.get(i);

        try {

          values[i] = (String) this.convert.coerce(value, descriptor.getCoercionContext());

        } catch (CoercionException e) {

          try {

            values[i] = value.toString();

          } catch (Exception ex) {

            values[i] = "";

          }

          if (errorcounts++ <= 10) {

            this.lasterror = e;

            LOGGER.warn("Can't convert value of field " + i + " to string in CVS file '" + this.file.getAbsolutePath() + "'.", e);

            if (errorcounts == 10) {

              LOGGER.warn("Too many error writing CVS file '" + this.file.getAbsolutePath() + "', don't output more.");

            }

          }

        }

        if( values[i]!=null ) {

            values[i] = values[i].replaceAll("\\n","\\\\n");

            values[i] = values[i].replaceAll("\\r","\\\\r");

        }

      }

    }

    try {

      this.listWriter.write(values);

    } catch (IOException e) {

      if (errorcounts++ <= 10) {

        this.lasterror = e;

        LOGGER.warn("Can't write values to CVS file '" + this.file.getAbsolutePath() + "'.", e);

        if (errorcounts == 10) {

          LOGGER.warn("Too many error writing CVS file '" + this.file.getAbsolutePath() + "', don't output more.");

        }

      }

    }

  }

  public void end() throws PerformEditingException {

    if (this.errorcounts > 0) {

      throw new PerformEditingException(this.file.getAbsolutePath(), lasterror);

    }

    if (listWriter != null) {

      try {

        listWriter.close();

      } catch (Exception ex) {

        // Ignore error

      }

      listWriter = null;

    }

    if (writer != null) {

      try {

        writer.close();

      } catch (Exception ex) {

        // Ignore error

      }

      writer = null;

    }

  }

  public Envelope getEnvelope() {

    return this.envelope;

  }

}