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

import java.io.File;

import java.io.IOException;

import java.nio.charset.Charset;

import java.util.AbstractList;

import java.util.List;

import org.apache.commons.io.IOUtils;

import org.gvsig.fmap.dal.store.simplereader.virtualrows.RandomAccessFileIndex;

import org.gvsig.fmap.dal.store.simplereader.virtualrows.RandomAccessFileReader;

/**

 *

 * @author jjdelcerro

 */

public abstract class AbstractCSVList

        extends AbstractList<List<String>>

        implements CSVList {

    protected final RandomAccessFileReader reader;

    protected final RandomAccessFileIndex index;

    protected int skipLines;

    public AbstractCSVList(File text, File index, Charset charset) throws IOException {

        // FIXME: falla con campos multilinea

        // FIXME: falla si hay comentarios en el CSV

        this.reader = new RandomAccessFileReader(text, charset);

        this.index = new RandomAccessFileIndex(index);

        this.skipLines = 0;

    }

    public AbstractCSVList(RandomAccessFileReader reader, RandomAccessFileIndex index) throws IOException {

        this.reader = reader;

        this.index = index;

        this.skipLines = 0;

    }

    @Override

    public void close() {

        IOUtils.closeQuietly(this.reader);

        IOUtils.closeQuietly(this.index);

    }

    @Override

    public List<String> get(int index) {

        try {

            long pos = this.index.get(index+skipLines);

            this.reader.seek(pos);

            return nextRecord();

        } catch (IOException ex) {

            throw new RuntimeException("Can't access to " + index + " element.", ex);

        }

    }

    @Override

    public int size() {

        return this.index.size()-skipLines;

    }

    @Override

    public void clear() {

        throw new UnsupportedOperationException();

    }

    @Override

    public long size64() {

        return this.index.size64()-skipLines;

    }

    @Override

    public List<String> get64(long index) {

        try {

            long pos = this.index.get64(index+skipLines);

            this.reader.seek(pos);

            return nextRecord();

        } catch (IOException ex) {

            throw new RuntimeException("Can't access to " + index + " element.", ex);

        }

    }

    abstract protected List<String> nextRecord() throws IOException;

}