Application: gvSIG desktop

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.spi.DataServerExplorerProviderServices;

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

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

    @Override

    public JDBCServerExplorer createServerExplorer(

            JDBCServerExplorerParameters parameters, 

            DataServerExplorerProviderServices providerServices

        ) throws InitializeException {

        JDBCServerExplorer explorer = new JDBCServerExplorerBase(

                parameters, 

                providerServices, 

                this

        );

        this.initialize(explorer, parameters, null);

        return explorer;

    }

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

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.net.URI;

import java.nio.file.FileSystem;

import java.nio.file.FileSystems;

import java.nio.file.Files;

import java.nio.file.Path;

import java.util.HashMap;

import java.util.Map;

import org.apache.commons.io.FilenameUtils;

import org.apache.commons.io.IOUtils;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.exception.InitializeException;

import org.gvsig.fmap.dal.spi.DataServerExplorerProviderServices;

import org.gvsig.fmap.dal.store.jdbc.JDBCServerExplorerParameters;

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

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

/**

 *

 * @author jjdelcerro

 */

@SuppressWarnings("UseSpecificCatch")

public class H2SpatialExplorer extends JDBCServerExplorerBase {

    private class H2Resource implements DataResource {

        private final File zipFile;

        private final String tableName;

        private InputStream in;

        private ByteArrayOutputStream out;

        private FileSystem fs;

        public H2Resource(File zipFile, String tableName) {

            this.zipFile = zipFile;

            this.tableName = tableName;

        }

        @Override

        public boolean exists() {

            if( !this.zipFile.exists() ) {

                return false;

            }

            try {

                Map<String, String> attributes = new HashMap<>();

                attributes.put("create", "false");

                URI zipURI = new URI("jar:"+this.zipFile.toURI().toString());

                this.fs = FileSystems.newFileSystem(zipURI, attributes);

                Path tablePath = fs.getPath(this.tableName);

                if( tablePath==null ) {

                    IOUtils.closeQuietly(fs);

                    this.fs = null;

                    return false;

                }

                return true;

            } catch(Exception ex) {

                IOUtils.closeQuietly(fs);

                this.fs = null;

                return false;

            }

        }

        @Override

        public InputStream asInputStream() throws IOException {

            if( !this.zipFile.exists()) {

                return null;

            }

            if( this.in!=null || this.out!=null ) {

                throw new IllegalStateException("Resource is already open ("+this.zipFile.toString()+"!"+this.tableName+")");

            }

            try {

                Map<String, String> attributes = new HashMap<>();

                attributes.put("create", "false");

                URI zipURI = new URI("jar:"+this.zipFile.toURI().toString());

                this.fs = FileSystems.newFileSystem(zipURI, attributes);

                Path tablePath = fs.getPath(this.tableName);

                if( tablePath==null ) {

                    IOUtils.closeQuietly(fs);

                    this.fs = null;

                    return null;

                }

                this.in = Files.newInputStream(tablePath);

                return this.in;

            } catch(Exception ex) {

                IOUtils.closeQuietly(fs);

                this.fs = null;

                return null;

            }

        }

        @Override

        public OutputStream asOutputStream() throws IOException {

            if( !this.zipFile.exists() ) {

                return null;

            }

            if( this.in!=null || this.out!=null ) {

                throw new IllegalStateException("Resource is already open ("+this.zipFile.toString()+"!"+this.tableName+")");

            }

            this.out = new ByteArrayOutputStream();

            return this.out;

        }

        @Override

        public void close() {

            if( this.in!=null ) {

                IOUtils.closeQuietly(this.in);

                this.in = null;

            }

            if(this.out != null ) {

                try {

                    Map<String, String> attributes = new HashMap<>();

                    attributes.put("create", "true");

                    URI zipURI = new URI("jar:"+this.zipFile.toURI().toString());

                    this.fs = FileSystems.newFileSystem(zipURI, attributes);

                    Path tablePath = fs.getPath(this.tableName);

                    ByteArrayInputStream lin = new ByteArrayInputStream(this.out.toByteArray());

                    Files.copy(lin, tablePath);

                } catch(Exception ex) {

                    IOUtils.closeQuietly(this.out);

                    this.out = null;

                }

            }

            if( this.fs!=null ) {

                IOUtils.closeQuietly(this.fs);

                this.fs = null;

            }

        }

    }

    public H2SpatialExplorer(JDBCServerExplorerParameters parameters, DataServerExplorerProviderServices services, JDBCHelper helper) throws InitializeException {

        super(parameters, services, helper);

    }

    @Override

    public H2SpatialExplorerParameters getParameters() {

        return (H2SpatialExplorerParameters) super.getParameters(); 

    }

    @Override

    public DataResource getResource(DataStore dataStore, String resourceName) throws DataException {

        String zipPath = this.getParameters().getFile().getAbsolutePath();

        zipPath = FilenameUtils.removeExtension(zipPath);

        zipPath = zipPath + "." + resourceName;

        H2Resource resource = new H2Resource(new File(zipPath), dataStore.getName());

        return resource;

    }

}

    @Override

    public String[] getRequiredFieldNames() {

        return null;

    }

    @Override

    public String[] getRequiredFieldNames() {

        return null;

    }

        public String[] getRequiredFieldNames();

import java.io.Closeable;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

    public interface DataResource extends Closeable {

        public boolean exists();

        public InputStream asInputStream() throws IOException;

        public OutputStream asOutputStream() throws IOException;

        public void close();

    }

     * @deprecated use getResource

    /**

     * Return the DataResource associated to this name and store. If the

     * resource not exists or the explorer don't support this opperation return

     * null.

     *

     * @param dataStore

     * @param resourceName

     * @return the DataResource or null

     * @throws DataException

     */

    public DataResource getResource(DataStore dataStore, String resourceName) throws DataException;

    @Deprecated

    @Override

    public DataResource getResource(DataStore dataStore, String resourceName) throws DataException {

        return null;

    }

import java.io.FileInputStream;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import org.apache.commons.io.IOUtils;

@SuppressWarnings("UseSpecificCatch")

    private class FileResource implements DataResource {

        private final File f;

        private FileInputStream in;

        private FileOutputStream out;

        public FileResource(File f) {

            this.f = f;

        }

        public File getFile() {

            return this.f;

        }

        @Override

        public boolean exists() {

            return this.f.exists();

        }

        @Override

        public InputStream asInputStream() throws java.io.FileNotFoundException {

            if( this.out != null || this.in!=null ) {

                throw new IllegalStateException("Input already open");

            }

            this.in = new FileInputStream(this.f);

            return this.in;

        }

        @Override

        public OutputStream asOutputStream() throws java.io.FileNotFoundException {

            if( this.out != null || this.in!=null ) {

                throw new IllegalStateException("Input already open");

            }

            this.out = new FileOutputStream(this.f);

            return this.out;

        }

        @Override

        public void close() {

            IOUtils.closeQuietly(out);

            IOUtils.closeQuietly(in);

            this.in = null;

            this.out = null;

        }

    }

        for (String f : allfiles) {

            File file = new File(this.root, f);

            throw new FileNotFoundException(this.current);

            throw new IllegalArgumentException(this.getProviderName()

        DataStoreParameters dsp;

        } catch (DataException | ValidateDataParametersException e) {

            throw new IllegalArgumentException("not instance of FilesystemStoreParameters");

    @Deprecated

        FileResource resource = (FileResource) this.getResource(dataStore, resourceName);

        if( resource==null ) {

            return null;

        }

        return resource.getFile();

    }

    @Override

    public DataResource getResource(DataStore dataStore, String resourceName) throws DataException {

        FilesystemServerExplorerProvider provider = this.getProvider(dataStore.getProviderName());

            return new FileResource(f);

        return new FileResource(new File(rootPathName + "." + resourceName));

import org.gvsig.fmap.dal.DataServerExplorer.DataResource;

            DataResource resource = explorer.getResource(this, "dal");

            if( resource == null ) {

                dalFile.write(resource);

            DataResource resource = explorer.getResource(this, "dal");

            if( resource == null || !resource.exists() ) {

            DALFile dalFile = DALFile.getDALFile(resource);

import java.io.InputStream;

import java.io.OutputStream;

import org.gvsig.fmap.dal.DataServerExplorer.DataResource;

    public static DALFile getDALFile(DataResource resource) {

        df.read(resource);

    public void write(DataResource resource) {

            OutputStream out = resource.asOutputStream();

            throw new RuntimeException("Can't write DAL resource.",ex);

            IOUtils.closeQuietly(resource);

    public void read(DataResource resource) {

            InputStream in = resource.asInputStream();

            IOUtils.closeQuietly(resource);