| gvSIG desktop 1

#Build Number for ANT. Do not edit!

#Tue Nov 28 10:22:44 CET 2006

build.number=73

<?xml version="1.0" encoding="UTF-8"?>

<project default="javadoc">

    <target name="javadoc">

        <javadoc destdir="doc" access="private" source="1.4" use="true" notree="false" nonavbar="false" noindex="false" splitindex="true" author="true" version="true" nodeprecatedlist="false" nodeprecated="false" packagenames="es.prodevelop.cit.gvsig.arcims.fmap.datasource,es.prodevelop.cit.gvsig.arcims.gui.toc,es.prodevelop.cit.gvsig.arcims.gui.panels,es.prodevelop.cit.gvsig.arcims.gui.panels.utils,es.prodevelop.cit.gvsig.arcims.gui.dialogs,es.prodevelop.cit.gvsig.arcims.gui.wizards,es.prodevelop.cit.gvsig.arcims.extension,es.prodevelop.cit.gvsig.arcims.fmap.drivers,es.prodevelop.cit.gvsig.arcims.fmap.layers" sourcepath="src" classpath="../libFMap/lib/jmrsid-0.0.2.jar;../libFMap/lib/mysql-connector-java-3.1.7-bin.jar;../libFMap/lib/geojava.jar;../appgvSIG/lib/batik-xml.jar;../libFMap/lib/gt2-legacy.jar;../libFMap/lib/gt2-postgis.jar;../libFMap/lib/tar.jar;../extWMS/lib/remote-clients.jar;../libFMap/lib/driver-manager-1.0.jar;../fwAndami/lib/javaws.jar;../libFMap/lib/tempFileManager.jar;../appgvSIG/lib/batik-css.jar;../appgvSIG/lib/batik-util.jar;../libFMap/lib/jts-1.6.jar;../libFMap/lib/jmgeoraster.jar;../appgvSIG/lib/JimiProClasses.zip;../libFMap/lib/hsqldb.jar;../libRemoteServices/lib/kxml2.jar;../fwAndami/lib/iver-utiles.jar;../libFMap/lib/postgresql-74.213.jar;../fwAndami/lib/castor-0.9.5.3-xml.jar;../libFMap/lib/jogr.jar;../appgvSIG/lib/batik-bridge.jar;../appgvSIG/lib/batik-script.jar;../libFMap/lib/geoapi-2.0.jar;../libFMap/lib/units-0.01.jar;../appgvSIG/lib/itext-1.3.jar;../appgvSIG/lib/batik-svg-dom.jar;../appgvSIG/lib/batik-ext.jar;../libRemoteServices/bin;../fwAndami/lib/log4j-1.2.8.jar;../fwAndami/lib/xerces_2_5_0.jar;../appgvSIG/lib/batik-parser.jar;../appgvSIG/lib/batik-gvt.jar;../fwAndami/lib/xml-apis.jar;../appgvSIG/lib/batik-svggen.jar;../libFMap/lib/jgdal-0.1.0.jar;../libFMap/lib/gt2-main.jar;../fwAndami/bin;../libFMap/lib/batik-awt-util.jar;../appgvSIG/bin;../libFMap/lib/gdbms-0.8-SNAPSHOT.jar;../libFMap/bin;../appgvSIG/lib/pdf-transcoder.jar;../libFMap/lib/geotiff-jai.jar;../libFMap/lib/cms.jar;../libFMap/lib/jecwcompress-0.0.0.jar;../fwAndami/lib/crimson.jar;../appgvSIG/lib/jep-2.24.jar;../appgvSIG/lib/batik-awt-util.jar;../appgvSIG/lib/js.jar;../appgvSIG/lib/batik-swing.jar;../libFMap/lib/wkb4j-1.0-RC1.jar;../libArcIMS/bin;../appgvSIG/lib/batik-transcoder.jar;../fwAndami/lib/JUF-1.0.jar;../appgvSIG/lib/batik-gui-util.jar;../appgvSIG/lib/batik-dom.jar;../libFMap/lib/jecw-0.0.1.jar;../libFMap/lib/vecmath-1.3.jar;../libFMap/lib/postgis-jdbc-driver.jar;../appgvSIG/lib/batik-extension.jar;../fwAndami/lib/tempFileManager.jar"/>

    </target>

</project>

package es.prodevelop.cit.gvsig.arcims.extension;

import java.io.File;

import java.net.MalformedURLException;

import java.net.URL;

import com.iver.andami.PluginServices;

import com.iver.andami.plugins.Extension;

import com.iver.cit.gvsig.About;

import com.iver.cit.gvsig.AddLayer;

import com.iver.cit.gvsig.project.documents.view.toc.gui.FPopupMenu;

import com.iver.utiles.extensionPoints.ExtensionPoints;

import com.iver.utiles.extensionPoints.ExtensionPointsSingleton;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FFeatureLyrArcIMS;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FFeatureLyrArcIMSCollection;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FRasterLyrArcIMS;

import es.prodevelop.cit.gvsig.arcims.gui.toc.ArcImsLayerScaleTocMenuEntry;

import es.prodevelop.cit.gvsig.arcims.gui.toc.ArcImsPropsTocMenuEntry;

import es.prodevelop.cit.gvsig.arcims.gui.toc.ArcImsRasterPropsTocMenuEntry;

import es.prodevelop.cit.gvsig.arcims.gui.wizards.ArcImsWizard;

/**

 * This class implements the extension to access ArcIMS servers.

 * 

 * @author jldominguez

 *

 */

public class ArcimsClientModule extends Extension {

	/**

     * This method initializes the extension. Adds the ArcIMS wizard

     * and the right-click popup menus to the gvSIG resources.

     */

    public void initialize() {

    	// must add menus and a new tab to the wizard

    	// to create an arcims layer

    	FPopupMenu.addEntry(new ArcImsPropsTocMenuEntry());

    	FPopupMenu.addEntry(new ArcImsRasterPropsTocMenuEntry());

    	FPopupMenu.addEntry(new ArcImsLayerScaleTocMenuEntry());

    	AddLayer.addWizard(ArcImsWizard.class);

    	// about

        java.net.URL newurl = createResourceUrl("about/extarcims-about.html");

    	About claseAbout = (About) PluginServices.getExtension(com.iver.cit.gvsig.About.class);

        claseAbout.getAboutPanel().addAboutUrl("ArcIMS", newurl);

        // catalog

    	ExtensionPoints extensionPoints = ExtensionPointsSingleton.getInstance();

    	extensionPoints.add("CatalogLayers", "arcims_raster", FRasterLyrArcIMS.class);

    	extensionPoints.add("CatalogLayers", "arcims_vectorial", FFeatureLyrArcIMSCollection.class);

    }

    /**

     * This method is called when the extension's controls are used.

     * So far, the ArcIMS plugin does <i>not</i> add any controls.

     * 

     * @param actionCommand the control's string action commmad.

     * 

     */

    public void execute(String actionCommand) {

    }

    /**

     * This method is called to find out if the plugin's controls are

     * enabled or not. So far, the ArcIMS plugin does <i>not</i>

     * add any controls.

     *

     * @return <b>true</b> if controls must be enabled, <b>false</b> if not.

     */

    public boolean isEnabled() {

    	return false;

    }

    /**

     * This method is called to find out if the plugin's controls are

     * visible or not. So far, the ArcIMS plugin does <i>not</i>

     * add any controls.

     *

     * @return <b>true</b> if controls must be visible, <b>false</b> if not.

     */

    public boolean isVisible() {

    	return false;

    }

    private java.net.URL createResourceUrl(String path) {

		return getClass().getClassLoader().getResource(path);

	}

}

package es.prodevelop.cit.gvsig.arcims.fmap.listeners;

public interface FRasterLyrArcIMSListener {

	public void thingsHaveChanged(String query, String name);

}

package es.prodevelop.cit.gvsig.arcims.fmap.datasource;

import java.awt.geom.Rectangle2D;

import java.net.URL;

import java.util.TreeMap;

import java.util.Vector;

import com.iver.cit.gvsig.fmap.DriverException;

import com.iver.cit.gvsig.fmap.MapControl;

import com.iver.cit.gvsig.fmap.edition.VectorialEditableAdapter;

import com.iver.cit.gvsig.fmap.layers.FLayer;

import com.iver.utiles.swing.threads.DefaultCancellableMonitorable;

import es.prodevelop.cit.gvsig.arcims.fmap.drivers.ArcImsDriver;

import es.prodevelop.cit.gvsig.arcims.fmap.drivers.ArcImsVectorialAdapter;

import es.prodevelop.cit.gvsig.arcims.fmap.drivers.FMapRasterArcImsDriver;

import es.prodevelop.cit.gvsig.arcims.fmap.drivers.FMapFeatureArcImsDriver;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FFeatureLyrArcIMS;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FFeatureLyrArcIMSCollection;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.FRasterLyrArcIMS;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.LayerScaleData;

import org.gvsig.remoteClient.arcims.*;

import org.gvsig.remoteClient.arcims.utils.MyCancellable;

import org.gvsig.remoteClient.arcims.utils.ServiceInfoTags;

import org.gvsig.remoteClient.arcims.utils.ServiceInformation;

import org.gvsig.remoteClient.arcims.utils.ServiceInformationLayerFeatures;

import org.apache.log4j.Logger;

import org.cresques.cts.IProjection;

/**

 * This class implements a data source object, owned by the ArcImsWizard

 * object. It will create the ArcIMS layer and load some basic data.

 * 

 * @author jldominguez

 * 

 */

public class ArcImsWizardData {

	private static Logger logger = Logger.getLogger(ArcImsWizardData.class.getName());

	/**

	* The graphic context in which a request is performed

	* (ccord. system, view's dimension etc.)

	*/

	private ArcImsStatus status;

	private String testInfo;

	private String serviceType;

	private FMapRasterArcImsDriver arcImsImageDriver = null;

	private FMapFeatureArcImsDriver arcImsFeatureDriver = null;

	private boolean missingSrs = false;

	private MapControl mapControl;

	private MyCancellable myCanc;

	public ArcImsWizardData() {

		myCanc = new MyCancellable(new DefaultCancellableMonitorable());

	}

	public void setHostService(URL host, String service, String svcType) throws DriverException {

		serviceType = svcType;

		boolean nogood = true;

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vIMAGESERVICE) == 0) {

			nogood = false;

			arcImsImageDriver = new FMapRasterArcImsDriver(host.toString(), service, svcType);

			// Send a getCapabilities request;

			if (! arcImsImageDriver.connect(myCanc)) {

				DriverException de = new DriverException("cant_connect");

				logger.error("While trying to connect ", de);

				throw de;

			}

			testInfo = "Connected successfully.";

		}

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vFEATURESERVICE) == 0) {

			nogood = false;

			arcImsFeatureDriver = new FMapFeatureArcImsDriver(host.toString(), service, svcType);

			// Send a getCapabilities request;

			if (! arcImsFeatureDriver.connect(myCanc)) {

				DriverException de = new DriverException("cant_connect");

				logger.error("While trying to connect ", de);

				throw de;

			}

			testInfo = "Connected successfully.";

		}

		if (nogood) {

			logger.error("Nothing done. Unable to find out serviceType ");

		}

	}

	public void setHostService(URL host, String service, String svcType, FLayer lyr) throws DriverException {

		serviceType = svcType;

		boolean nogood = true;

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vIMAGESERVICE) == 0) {

			nogood = false;

			arcImsImageDriver =

				(FMapRasterArcImsDriver) ((FRasterLyrArcIMS) lyr).getDriver();

			// arcImsImageDriver = new FMapRasterArcImsDriver(host.toString(), service, svcType);

			// Send a getCapabilities request;

			if (! arcImsImageDriver.connect(myCanc)) {

				DriverException de = new DriverException("cant_connect");

				logger.error("While trying to connect ", de);

				throw de;

			}

			testInfo = "Connected successfully.";

		}

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vFEATURESERVICE) == 0) {

			nogood = false;

			// arcImsFeatureDriver = new FMapFeatureArcImsDriver(host.toString(), service, svcType);

			arcImsFeatureDriver =

				(FMapFeatureArcImsDriver) ((FFeatureLyrArcIMS) lyr).getSource().getDriver();

			// Send a getCapabilities request;

			if (! arcImsFeatureDriver.connect(myCanc)) {

				DriverException de = new DriverException("cant_connect");

				logger.error("While trying to connect ", de);

				throw de;

			}

			testInfo = "Connected successfully.";

		}

		if (nogood) {

			logger.error("Nothing done. Unable to find out serviceType ");

		}

	}

	public String getServiceType() { return serviceType; }

	public void setServiceType(String t) { serviceType = t; }

	public ArcImsDriver getDriver() {

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vFEATURESERVICE) == 0) {

			return arcImsFeatureDriver;

		}

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vIMAGESERVICE) == 0) {

			return arcImsImageDriver;

		}

		logger.error("Null value returned. Unable to find out serviceType ");

		return null;

	}

	public void setDriver(ArcImsDriver d) {

		boolean nogood = true;

		if (d instanceof FMapRasterArcImsDriver) {

			arcImsImageDriver = (FMapRasterArcImsDriver) d;

			nogood = false;

		}

		if (d instanceof FMapFeatureArcImsDriver) {

			arcImsFeatureDriver = (FMapFeatureArcImsDriver) d;

			nogood = false;

		}

		if (nogood) {

			logger.error("Nothing done. Unable to find out serviceType ");

		}

	}

	public ArcImsStatus getStatus() { return status; }

	public void setStatus (ArcImsStatus s) { status = s; }

	/**

     * Gets available layers from the current server and service

     * 

     * @return a TreeMap with available layers

	 */

	public TreeMap getLayers() {

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vFEATURESERVICE) == 0) {

			return arcImsFeatureDriver.getLayers();

		}

		if (serviceType.compareToIgnoreCase(ServiceInfoTags.vIMAGESERVICE) == 0) {

			return arcImsImageDriver.getLayers();

		}

		logger.error("Null value returned. Unable to find out serviceType in method " +

				"TreeMap getLayers()" + ", class: "+ this.getClass().toString());

		return null;

		}

	/**

	 * This method is invoqued by the wizard's <tt>getLayer()</tt> method

	 * to create an ArcIMS raster layer.

	 * 

	 * @param host server's URL

	 * @param service service name

	 * @param sLayer comma-separated list of selected layers

	 * @param name new gvSIG layer's name

	 * @param srs project's coordinate system

	 * @return the new layer (of class FRasterLyrArcIMS, which is a

	 * subclass of _FLyrArcIMS which is a subclass of FLayer)

	 */

	public FRasterLyrArcIMS createArcImsRasterLayer(String host, String service, String sLayer,

			String name, IProjection srs, String imgFormat)

	throws  Exception {

		FMapRasterArcImsDriver drv = new FMapRasterArcImsDriver(host, service, this.serviceType);

		if (!drv.connect(myCanc))

			throw new Exception();

		FRasterLyrArcIMS flyr = new FRasterLyrArcIMS();

		flyr.setDriver(drv);

		flyr.setHost(new URL(host));

		flyr.setService(service);

		flyr.setServiceType(this.serviceType);

		flyr.setServiceInformationInStatus(drv.getClient().getServiceInformation());

		ServiceInformation si = flyr.getArcimsStatus().getServiceInfo();

		if ((si.getFeaturecoordsys() == null) || (si.getFeaturecoordsys().equals(""))) {

			missingSrs = true;

			si.setFeaturecoordsys(srs.getAbrev().substring(ServiceInfoTags.vINI_SRS.length()).trim());

			logger.warn("Server provides no SRS. ");

		} else {

			missingSrs = false;

		}

		flyr.setFullExtent(((ArcImsProtImageHandler) drv.getClient().getHandler()).getServiceExtent(srs, flyr.getArcimsStatus()));

		// we *dont* use PNG always

		// flyr.setFormat("image/png");

		flyr.setFormat(imgFormat);

		flyr.setTransparency(0);

		flyr.setLayerQuery(sLayer);

		flyr.setProjection(srs);

		flyr.setName(name);

		// ----------- service info ---------------

		// flyr.getSource().getDriver();

		// ----------------- 1.0

		return flyr;

	}

	public String getTestInfo() {

		return testInfo;

	}

	/**

	 * This method is invoqued by the wizard's <tt>getLayer()</tt> method

	 * to create an ArcIMS feature layer.

	 * 

	 * @param host server's URL

	 * @param service service name

	 * @param sLayer comma-separated list of selected layers

	 * @param name new gvSIG layer's name

	 * @param srs project's coordinate system

	 * @param sep whether it'a grouped set of layers (false) or not (true)

	 * @return the new layer (of class FRasterLyrArcIMS, which is a

	 * subclass of FRasterLyrArcIMS, which is a subclass of FLayer)

	 */

	public FFeatureLyrArcIMSCollection createArcImsFeatureLayer(String host, String service, String sLayer, String name, IProjection srs, boolean sep)

	throws Exception {

		String[] selectedLayerIds = sLayer.split(",");

		int count = selectedLayerIds.length;

		FFeatureLyrArcIMS[] individualLayers = new FFeatureLyrArcIMS[count];

		String item;

		for (int i=0; i<count; i++) {

			item = selectedLayerIds[i];

			FMapFeatureArcImsDriver drv = new FMapFeatureArcImsDriver(host, service, item);

			if (!(drv.connect(myCanc))) throw new Exception();

			ArcImsVectorialAdapter oldadapter = new ArcImsVectorialAdapter(drv);

			VectorialEditableAdapter adapter = new VectorialEditableAdapter();

			/* 1 */ individualLayers[i] = new FFeatureLyrArcIMS(adapter);

			/* 2 */ drv.setLayer(individualLayers[i]);

			ServiceInformation si = drv.getClient().getServiceInformation();

			ServiceInformationLayerFeatures silf = (ServiceInformationLayerFeatures) si.getLayerById(item);

			String lyrname = silf.getName(); 

			individualLayers[i].setProjectionInStatus(srs.getAbrev());

			individualLayers[i].setHostInStatus(new URL(host));

			individualLayers[i].setServiceInStatus(service);

			String units = si.getMapunits();

			int theDpi = si.getScreen_dpi();

			long scale;

			if (silf.getMaxscale()!=-1){

				scale = LayerScaleData.getTrueScaleFromRelativeScaleAndMapUnits(silf.getMaxscale(), units, theDpi);

				individualLayers[i].setMaxScale((double) scale);

			}

			if (silf.getMinscale()!=-1){

				scale = LayerScaleData.getTrueScaleFromRelativeScaleAndMapUnits(silf.getMinscale(), units, theDpi);

				individualLayers[i].setMinScale((double) scale);			

			}

			individualLayers[i].setServiceInformationInStatus(si);

			Vector ids = new Vector(); ids.add(item);

			individualLayers[i].setLayerIdsInStatus((Vector) ids.clone());

			individualLayers[i].setSubfieldsInStatus();

			/* 3 */ 

			// individualLayers[i].setLegend(new VectorialUniqueValueLegend());

			individualLayers[i].setHost(new URL(host));

			individualLayers[i].setService(service);

			individualLayers[i].setServiceType(ServiceInfoTags.vFEATURESERVICE);

			individualLayers[i].setTransparency(0);

			individualLayers[i].setLayerQuery(item);

			individualLayers[i].setProjection(srs);

			individualLayers[i].setName(lyrname);

			Rectangle2D fext = ((ArcImsFeatureClient) drv.getClient()).getLayerExtent(individualLayers[i].getArcimsStatus());

			drv.setFullExtent(fext);

			// individualLayers[i].setF. setFullExtent(((ArcImsProtImageHandler) drv.getClient().getHandler()).getServiceExtent(srs, individualLayers[i].getArcimsStatus()));

			// ------ -------------

			drv.setAdapter(adapter);

			// adapter.setRecordSet(drv.getRecordSet());

			adapter.setOriginalDataSource(drv.getRecordSet());

			adapter.setOriginalVectorialAdapter(oldadapter);

			drv.declareTable();

			individualLayers[i].setInitialLegend();

			individualLayers[i].setShapeType(adapter.getShapeType());

			individualLayers[i].setRecordset(drv.getRecordSet());

			// ------ -------------

			if ((si.getFeaturecoordsys() == null) || (si.getFeaturecoordsys().equals(""))) {

				missingSrs = true;

				si.setFeaturecoordsys(srs.getAbrev().substring(ServiceInfoTags.vINI_SRS.length()).trim());

				logger.warn("Server provides no SRS. ");

			} else {

				missingSrs = false;

			}

		}

		FFeatureLyrArcIMSCollection collection = new FFeatureLyrArcIMSCollection(mapControl.getMapContext(), null, sep);

		collection.setName(name);

		collection.setProjection(srs);

		for (int i=0; i<count; i++) {

			collection.addLayer(individualLayers[i]);

		}

		return collection;

	}	

	/**

	 * Tells whether the SRS was missing on the server.

	 * 

	 * @return <tt>true</tt> if and only if the Srs was not provided by the server.

	 */

	public boolean isMissingSrs() {

		return missingSrs;

	}

	public void setMissingSrs(boolean missingSrs) {

		this.missingSrs = missingSrs;

	}

	public void setMapControl(MapControl mapControl) {

		this.mapControl = mapControl;

	}

}

package es.prodevelop.cit.gvsig.arcims.fmap.drivers;

import java.awt.Dimension;

import java.io.IOException;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Types;

import java.util.ArrayList;

import java.util.HashMap;

import org.apache.log4j.Logger;

import org.gvsig.remoteClient.arcims.utils.FieldInformation;

import com.hardcode.driverManager.DriverLoadException;

import com.hardcode.gdbms.engine.data.DataSource;

import com.hardcode.gdbms.engine.data.DataSourceFactory;

import com.hardcode.gdbms.engine.data.driver.DriverException;

import com.hardcode.gdbms.engine.data.driver.ObjectDriver;

import com.hardcode.gdbms.engine.instruction.EvaluationException;

import com.hardcode.gdbms.engine.instruction.SemanticException;

import com.hardcode.gdbms.engine.values.*;

import com.hardcode.gdbms.parser.ParseException;

import com.iver.cit.gvsig.fmap.layers.FBitSet;

public class ArcImsInMemoryAttsTableDriver {

	private String tableName = "";

	// private String dataBName = "";

	private String idOriginalFieldName = "";

	private String idSqlFieldName = "";

	// private String rowIndexFieldName = "INMEMORYROWNUMBER";

	private int idFieldInd = -1;

	private FBitSet requested;

	private ArrayList sqlColumnNames = new ArrayList();

	private ArrayList originalColumnNames = new ArrayList();

	// private ArrayList originalColumnNames = new ArrayList();

	private ArrayList columnTypes = new ArrayList();

	// private int theRowCount = 0;

	private int theFieldCount = 0;

	private HashMap idToIndex;

	private static Logger logger = Logger.getLogger(FMapFeatureArcImsDriver.class.getName());

	private Dimension lastRequest = new Dimension(-1, -1);

	// ------------------------------------------------

	private ArrayList data = new ArrayList();

	private ArrayList id = new ArrayList();

	// ------------------------------------------------

	// private ArcImsAttributesTableCachee attsCache;

	// private static Logger logger = Logger.getLogger(FMapFeatureArcImsDriver.class.getName());

	public ArcImsInMemoryAttsTableDriver(String tb_name, ArrayList colnames, ArrayList coltypes) {

		// super();

		tableName = tb_name;

		// dataBName = dbName;

		idFieldInd = getIdColumnInd(coltypes);

		idOriginalFieldName = (String) colnames.get(idFieldInd);

		idSqlFieldName = replaceUnwantedCharacters((String) colnames.get(idFieldInd));

		requested = new FBitSet();

		for (int i=0; i<colnames.size(); i++) {

			sqlColumnNames.add(replaceUnwantedCharacters((String) colnames.get(i) ));

			originalColumnNames.add(colnames.get(i));

			columnTypes.add(coltypes.get(i));

			theFieldCount++;

		}

		idToIndex = new HashMap();

	}

    /**

     * user = "as", password = "", dbName = ?

     * 

     * @see com.hardcode.gdbms.engine.data.driver.DBDriver#getConnection(java.lang.String,

     *      int, java.lang.String, java.lang.String, java.lang.String)

     */

//    public Connection getConnection(String host, int port, String _dbName,

//            String _user, String _password) throws SQLException {

//        	

////            if (driverException != null) {

////                throw new RuntimeException(driverException);

////            }

//            String connectionString = "jdbc:hsqldb:mem:" + dataBName;

//            Connection c = DriverManager.getConnection(connectionString, "sa", "");

//            return c;

//        }

//    public Connection getConnection() throws SQLException {

//    	return getConnection("", 0, "", "", "");

//        }

    /**

     * @see com.hardcode.driverManager.Driver#getName()

     */

    public String getName() {

        return "ArcIMS in-memory attributes data driver";

    }

    public void open(String sql) throws SQLException {

//    	open(getConnection(), sql);

    }

    public void execute(String sql) throws SQLException {

//    	execute(getConnection(), sql);

    }

	public String getDbName() {

		return "No database";

	}

	public int getIdFieldInd() {

		return idFieldInd;

	}

	public String getIdFieldName() {

		return idSqlFieldName;

	}

	// public void addRow(DataSourceFactory dsf, Value[] values) throws DriverException {

	public void addRow(Value[] values, boolean filled) throws DriverException {

		if (values.length < theFieldCount) {

			logger.error("Cannot add row with length < field count. ");

			return;

		}

		if (values[idFieldInd].toString().compareTo("") != 0) {

			// not null value

			int theid = ((IntValue) values[idFieldInd]).intValue();

			idToIndex.put(new Integer(theid), new Integer(data.size()));

		}

		requested.set(data.size(), filled);

		data.add(values);

//		String fieldNames = "";

//		for (int i=0; i < (values.length + 1); i++) {

//			fieldNames = fieldNames + ((String) columnNames.get(i)) + ", "; 

//		}

//		fieldNames = fieldNames.substring(0, fieldNames.length() - 2);

//		// + ArcImsSqlUtils.rowIndexFieldName;

//		

//		String fieldValues = "";

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

//			fieldValues = fieldValues + getValueInSqlFormat(values[i]) + ", "; 

//		}

//		fieldValues = fieldValues + getRowCount();

//		

//		String sqlStr = "insert into " + tableName + " (";

//		sqlStr = sqlStr + fieldNames + ") values (";

//		sqlStr = sqlStr + fieldValues + ")";

//		/*

//		* INSERT INTO Table1 (Column1, Column2, Column3?)

//		* VALUES (Value1, Value2, Value3?)

//		*/

//		try {

//			// dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//			execute(sqlStr);

//			theRowCount++;

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

	}

	// public void deleteRow(DataSourceFactory dsf, int i) throws DriverException {

	public void deleteRow(int i) throws DriverException {

		/*

		 DELETE FROM Table1 WHERE Some_Column = Some_Value

		 */

		logger.warn("deleteRow was invoqued, i = " + i);

		int theid = getRowId(i);

		idToIndex.remove(new Integer(theid));

		requested.set(i, false);

		data.set(i, null);

//		String sqlStr = "delete from " + tableName + " where ";

//		sqlStr = sqlStr + rowIndexFieldName + " = ";

//		sqlStr = sqlStr + i;

//		/*

//		* INSERT INTO Table1 (Column1, Column2, Column3?)

//		* VALUES (Value1, Value2, Value3?)

//		*/

//		try {

//			// dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//			execute(sqlStr);

//			theRowCount--;

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

	}

//	private String getValueInSqlFormat(Value v) {

//		String tmp = v.getStringValue(internalValueWriter);

////		if (v instanceof StringValue) {

////			tmp = "'" + tmp + "'";

////		}

//		return tmp;

//	}

	private boolean isEmptyRow(int n) {

		return (data.get(n) == null);

	}

	public int getRowId(int row) throws DriverException {

		Integer rowid = (Integer) id.get(row);

		return rowid.intValue();

//		Value[] therow = (Value []) data.get(row);

//		return ((IntValue) therow[idFieldInd]).intValue();

		// return ((Integer) indexToId.get(new Integer(row))).intValue();

	}

	public int getRowIndex(int id) throws DriverException {

		// logger.debug("Searching for id: " + id);

		return ((Integer) idToIndex.get(new Integer(id))).intValue();

	}

//	public int getRowId(DataSourceFactory dsf, int row) throws DriverException {

//		/*

//		 SELECT * FROM Customers WHERE LastName = 'Smith'

//		 */

//		String sqlStr = "select " + idFieldName + " from " + tableName + " where ";

//		sqlStr = sqlStr + rowIndexFieldName + " = ";

//		sqlStr = sqlStr + row + ";";

//		/*

//		* INSERT INTO Table1 (Column1, Column2, Column3?)

//		* VALUES (Value1, Value2, Value3?)

//		*/

//		DataSource ds = null;

//		try {

//			

//			ds = dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//			// int respind = ds.getFieldIndexByName(idFieldName);

//			IntValue resp = (IntValue) ds.getFieldValue(0, 0);

//			return resp.intValue();

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

//	}

//	

//	public int getRowIndex(DataSourceFactory dsf, int id) throws DriverException {

//		String sqlStr = "select " + rowIndexFieldName + " from " + tableName + " where ";

//		sqlStr = sqlStr + idFieldName + " = ";

//		sqlStr = sqlStr + id + ";";

//		/*

//		* INSERT INTO Table1 (Column1, Column2, Column3?)

//		* VALUES (Value1, Value2, Value3?)

//		*/

//		DataSource ds = null;

//		try {

//			ds = dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//

//			System.err.println("getRowIndex of id = " + id);

//			System.err.println(ds.getAsString());

//			System.err.println("------------------------------");

//			// int respind = ds.getFieldIndexByName(idFieldName);

//			IntValue resp = (IntValue) ds.getFieldValue(0, 0);

//			return resp.intValue();

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

//	}

	public boolean isNonRequestedRow(int rowind) {

		// TODO Auto-generated method stub

		return (! requested.get(rowind));

	}

	// public void updateRow(DataSourceFactory dsf, Value[] new_row, String[] fld_q) throws DriverException {

	// TODO so far, this method is called with

	// a full field query (except rowindex)

	public void updateRow(Value[] upd_row, String[] fld_q, int rowind) throws DriverException {

		if (! isEmptyRow(rowind)) {

			int newid = 0;

			int oldid = getRowId(rowind);

			boolean done = false;

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

				if (fld_q[i].compareTo(idSqlFieldName) == 0) {

					newid = ((IntValue) upd_row[i]).intValue();

					done = true;

				}

			}

			if (done) {

				idToIndex.remove(new Integer(oldid));

				idToIndex.put(new Integer(newid), new Integer(rowind));

			}

		}

		Value[] newrow = new Value[theFieldCount];

		if (data.get(rowind) == null) {

			data.set(rowind, newrow);

		} else {

			newrow = (Value []) data.get(rowind);

		}

		if (fld_q[0].compareTo("#ALL#") == 0) {

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

				newrow[i] = upd_row[i];

			}

		} else {

			int fldind = 0;

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

				String sqlname = replaceUnwantedCharacters(fld_q[i]);

				fldind = getFieldIndexByName(sqlname);

				newrow[fldind] = upd_row[i];

			}

		}

//		data.set()

//		String[] fld_query = null;

//		if (fld_q[0].compareTo("#ALL#") == 0) {

//			

//			int count = getFieldCount() - 1;

//			fld_query = new String[count];

//			for (int i=0; i<count; i++) {

//				fld_query[i] = getFieldName(i);

//			}

//			

//			

//		} else {

//			fld_query = new String[fld_q.length];

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

//				fld_query[i] = ArcImsSqlUtils.getSqlCompliantFieldName(fld_q[i]);

//			}

//		}

//		

//		IntValue id = null;

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

//			if (fld_query[i].compareTo(idFieldName) == 0) {

//				id = (IntValue) new_row[i];

//			}

//		}

//		if (id == null) {

//			DriverException de = new DriverException("id_not_found");

//			throw de;

//		}

//		int intid = id.intValue();

//		

//		String sqlStr = "update " + tableName + " set ";

//		String nthFieldName, nthFieldValue;

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

//			nthFieldName = fld_query[i];

//			nthFieldValue = this.getValueInSqlFormat(new_row[i]);

//			sqlStr = sqlStr + nthFieldName + " = ";

//			sqlStr = sqlStr + nthFieldValue + ", ";

//		}

//		sqlStr = sqlStr.substring(0, sqlStr.length() - 2);

//		sqlStr = sqlStr + " where " + idFieldName + " = " + intid + ";";

//		try {

//			// dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//			execute(sqlStr);

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

	}

	public int getFieldIndexByName(String arg0) throws DriverException {

//		String arg00 = ArcImsSqlUtils.getSqlCompliantFieldName(arg0);

		if (arg0 == null) {

			logger.error("Somebody asked for the index of a null field ");

			return -1;

		}

		for (int i=0; i<sqlColumnNames.size(); i++) {

			if (((String) sqlColumnNames.get(i)).compareTo(arg0) == 0) {

				return i;

			}

		}

		logger.error("Field not found ");

		return -1;

	}

	public Value[] getRow(DataSourceFactory dsf, int n) throws DriverException {

		return (Value []) data.get(n);

//		String sqlStr = "select * from " + tableName + " where ";

//		sqlStr = sqlStr + rowIndexFieldName + " = " + n + ";";

//

//		try {

//			DataSource ds =

//				dsf.executeSQL(sqlStr, DataSourceFactory.AUTOMATIC_OPENING);

//			// int respind = ds.getFieldIndexByName(idFieldName);

//			int count = ds.getFieldCount();

//			Value[] resp = new Value[count];

//			for (int i=0; i<count; i++) {

//				resp[i] = ds.getFieldValue(0, i);

//			}

//			return resp;

//		} catch (Exception e) {

//			DriverException de = new DriverException(e.getMessage());

//			throw de;

//		}

	}

//	public String getRowIndexFieldName() {

//		return rowIndexFieldName;

//	}

	public void setRequested(int n, boolean req) {

		requested.set(n, req);

	}

	public void addTheseAsRequested(FBitSet fbs) {

		requested.or(fbs);

	}

	public long getRowCount() {

		return (long) data.size();

	}

	public int getFieldCount() {

		return theFieldCount;

	}

	public String getFieldName(int i) {

		return (String) sqlColumnNames.get(i);

	}

	public int getFieldType(int i) {

		return ((Integer) columnTypes.get(i)).intValue();

	}

//	public void addInIndexToIdHashMap(int rwcount, int i) {

//		indexToId.put(new Integer(rwcount), new Integer (i));

//	}

	public void addInIdToIndexHashMap(int i, int rwcount) {

		idToIndex.put(new Integer (i), new Integer(rwcount));

	}

//	public String getColumnName(int i) {

//		return (String) columnNames.get(i);

//	}

//	public void increaseRowCount(boolean req) {

//		requested.set(data.size(), req);

//		theRowCount++;

//	}

	public void addAsRequested(FBitSet fbs) {

		requested.or(fbs);

	}

	public FBitSet getThisAndNonRequestedUpTo(int _thisone, int total) {

		int thisone = _thisone;

		int rowcount = (int) getRowCount();

		if (_thisone >= rowcount) {

			thisone = _thisone % rowcount;

		}

		FBitSet fbs = new FBitSet();

		fbs.set(thisone);

		if (total < 2) return fbs;

		int othersMustBeSet = total - 1;

		int checkind;

		for (int j=1; j<rowcount; j++) {

			// checkind = (i + j) % noOfRows;

			checkind = (thisone + j) % rowcount;

			if (isNonRequestedRow(checkind)) {

				fbs.set(checkind);

				othersMustBeSet--;

			}

			if (othersMustBeSet == 0) break;

		}

		return fbs;

	}

	public void addEmptyRowWithId(Value idval, String idcolname) {

		data.add(null);

		id.add(new Integer( ((IntValue) idval).intValue() ));

	}

	public Value getFieldValue(long row, int colind) {

		// printLastAndUpdate(row, colind);

		if (row >= getRowCount() || (row < 0)) {

			logger.error("Row index out of limits ");

			return null;

		}

		Value[] therow = (Value []) data.get((int) row);

		if (therow == null) {

			logger.error("Tried to get non available value (?) ");

			return null;

		}

		if ((colind >= therow.length) || (colind < 0)) {

			logger.error("Field index out of limits ");

			return null;

		}

		if (therow[colind] == null) {

			logger.warn("In order to avoid returning element [ " + row +  ", " + colind + " ] (which is null), returned ValueFactory.createNullValue()");

			return ValueFactory.createNullValue();

		} else {

			return therow[colind];

		}

	}

	private void printLastAndUpdate(long row, int colind) {

		logger.debug("Last request: [ " + lastRequest.height + " , " + lastRequest.width + " ]");

		lastRequest.height = (int) row;

		lastRequest.width = colind;

		logger.debug("Current request: [ " + lastRequest.height + " , " + lastRequest.width + " ]");

	}

	//	public Value getCachedValue(int row, int attind) {

//		return attsCache.getAttribute(row, attind);

//	}

//	

//	public void setCachedValue(int row, int attind, Value v) {

//		attsCache.addToCache(row, attind, v);

//	}

	public int getIdColumnInd(ArrayList col_Types) {

		int coltype, idindex = -1;

		for (int i=0; i<col_Types.size(); i++) {

			coltype = ((Integer) col_Types.get(i)).intValue();

			if (coltype == FieldInformation.ID) {

				idindex = i;

				break;

			}

		}

		if (idindex == -1) {

			logger.error("ID not found ");

		}

		return idindex;

	}

	public String getTableName() {

		return tableName;

	}

	public static String replaceUnwantedCharacters(String str) {

		String resp = str;

		resp = resp.replace('.', '_');

		resp = resp.replace('#', 'z');

		return resp;

	}

	public String getOriginalFieldName(int idcolindex) {

		return (String) originalColumnNames.get(idcolindex);

	}

	public String getSqlFieldName(int idcolindex) {

		return (String) sqlColumnNames.get(idcolindex);

	}

}

package es.prodevelop.cit.gvsig.arcims.fmap.drivers;

import java.io.File;

import java.net.URL;

import java.util.TreeMap;

import org.apache.log4j.Logger;

import org.gvsig.remoteClient.arcims.*;

import org.gvsig.remoteClient.arcims.exceptions.ArcImsException;

import org.gvsig.remoteClient.exceptions.ServerErrorException;

import org.gvsig.remoteClient.wms.ICancellable;

import es.prodevelop.cit.gvsig.arcims.fmap.layers.ArcImsLayerNode;

/**

* ArcIMS driver implementation. Requests are passed to the <tt>ArcImsClientP</tt> object.

* 

* @see org.gvsig.remoteClient.arcims.ArcImsImageClient ArcImsImageClient

* @author jldominguez

*/

public class FMapRasterArcImsDriver implements ArcImsDriver {

	private static Logger logger = Logger.getLogger(FMapRasterArcImsDriver.class.getName());

	private ArcImsImageClient client;

	private String server; 

	private String service;

	private String serviceType;

	private boolean connectionDone = false;

	public FMapRasterArcImsDriver() {

	}

	/**

	* The constructor needs the server's URL and the name of the service to be used.

	* 

	* @param host server's URL

	* @param service name of the service, chosen among the ones retrieved after a

	* request with the parameter <tt>ServiceName=Catalog</tt>

	*/

	public FMapRasterArcImsDriver(String host, String service, String svcType) {

		serviceType = svcType;

		init(host, service);

	}

	/**

	 * This method is called by the constructor and creates the

	 * <tt>client</tt> oject.

	 * @param host

	 * @param service

	 */

	public void init(String host, String service) {

		server = host;

		this.service = service;

		client = new ArcImsImageClient(host, service, this.serviceType);

	}

	/**

     * Gets available layers from the current server and service

     * 

     * @return a TreeMap with available layers

	 */

	public TreeMap getLayers() {

		return client.getLayers();

	}

	/**

	* Gets the layers available on the server (the class that implements

	* this interface will get the service name from the user)

	* 

	* @param server ArcIMS server's URL

	*/

	public void getCapabilities(URL server, ICancellable cancel) throws ArcImsException {

		if (connectionDone) {

			return;

		} else {

			connectionDone = getClient().connect(server, cancel); 

		}

		if (! connectionDone) {

			throw new ArcImsException("connect_error");

		}

	}

	/**

	* Gets the visual information from the layers of 

	* the required service (that is, the map itself) depending

	* on the graphic context (coord. system, view's size, etc)

	* 

	* @param status the graphic context in which the request is performed

	* @return the graphic data to be viewed, that is, the map. For the imageservice,

	* it will be a <tt>File</tt> object.

	*/

	public Object getMap(ArcImsStatus status) throws ArcImsException {

		try {

			return client.getMap(status);

		} catch (ServerErrorException e) {

			logger.error("While getting map ", e);

			throw new ArcImsException("ArcIMS Unexpected server error."

					+ e.getMessage());

		}

	}

	/**

	* Gets the layer's available information on a particular xy coordinates

	* (usually derived from a mouse click). If it's a raster layer,

	* a request will be sent to the server asking for the data associated

	* to the elements (polygon, line or point) which cover the clicked

	* pixel.

	* 

	* @param status the graphic context in which the request is performed

	* (ccord. system, view's dimension etc.)

	* @param i x coordinate of the queried pixel 

	* @param j y coordinate of the queried pixel

	* @param  max_value maximun number of vector elements whose information

	* will be retrieved.

	* @return the available information at the given coordinates

	*/

	public String getFeatureInfo(ArcImsStatus status, int i, int j, int max_value) throws ArcImsException { 

		String r = "No info available.";

			try {

				r = client.getFeatureInfo(status, i, j, max_value);

			} catch (ArcImsException e) {

				logger.error("ArcImsException. ", e);

				throw e;

			}

			return r;

	}

	/**

	* Given a layer name, gets a node that contains relevant information

	* about the layer. 

	* 

	* @param layerName the name of the layer

	* @return a node with layer's information

	*/

	public ArcImsLayerNode getLayer(String layerName) {

		ArcImsLayerNode node = new ArcImsLayerNode();

		node.setName(layerName);

		return node;

	}

	/**

	 * This method starts a connection with the server and sends

	 * a <tt>getCapabilities</tt> request.

	 * @return <b>true</b> if the connection was successful, <b>false</b>

	 * otherwise (bad or no server URL, for example)

	 */

	public boolean connect(ICancellable cancel) {

		if (connectionDone) {

			return true;

		} else {

			connectionDone = client.connect(cancel);; 

		 	return connectionDone;

		}

	}

	/**

	 * Gets the <tt>ArcImsClientP</tt> object, onto which requests

	 * are passed.

	 * 

	 * @return the object that actually performs requests.

	 */

	public ArcImsClientP getClient() {

		if (client == null) {

			init(server, service);

		}

		return client;

	}

	/**

	 * This method tells whether this layer is queriable with a call to

	 * <tt>getFeatureInfo(...)</tt>

	 * 

	 * @return <b>true</b> if method <tt>getFeatureInfo(...)</tt> can be invoqued,

	 * <b>false</b> otherwise

	 */

	public boolean isQueryable() {

		return client.isQueryable();

	}

	public boolean testFormat(ArcImsStatus status, String imgFormat) {

		try {

			return client.testFromat(status, imgFormat);

		} catch (ArcImsException e) {

			logger.error("While testing omage format ", e);

		}

		return false;

	}

}

package es.prodevelop.cit.gvsig.arcims.fmap.drivers;

import com.iver.cit.gvsig.fmap.layers.RasterAdapter;

public class ArcImsRasterAdapter extends RasterAdapter {

	public ArcImsRasterAdapter(ArcImsRasterDriver drv) {

		setDriver(drv);

	}

}

package es.prodevelop.cit.gvsig.arcims.fmap.drivers;

import java.io.File;

import java.io.IOException;

import java.sql.SQLException;

import java.sql.Types;

import java.util.ArrayList;

import java.util.BitSet;

import java.util.HashMap;

import org.apache.log4j.Logger;

import org.gvsig.remoteClient.arcims.exceptions.ArcImsException;

import org.gvsig.remoteClient.arcims.utils.FieldInformation;

import org.gvsig.remoteClient.arcims.utils.GetFeaturesTags;

import com.hardcode.driverManager.Driver;

import com.hardcode.driverManager.DriverLoadException;

import com.hardcode.gdbms.engine.data.DataSource;

import com.hardcode.gdbms.engine.data.DataSourceFactory;

import com.hardcode.gdbms.engine.data.IDataSourceListener;

import com.hardcode.gdbms.engine.data.SourceInfo;

import com.hardcode.gdbms.engine.data.driver.DriverException;

import com.hardcode.gdbms.engine.data.driver.ObjectDriver;

import com.hardcode.gdbms.engine.data.edition.DataWare;

import com.hardcode.gdbms.engine.data.object.ObjectSourceInfo;

import com.hardcode.gdbms.engine.data.persistence.DataSourceLayerMemento;

import com.hardcode.gdbms.engine.data.persistence.Memento;

import com.hardcode.gdbms.engine.data.persistence.MementoException;

import com.hardcode.gdbms.engine.instruction.EvaluationException;

import com.hardcode.gdbms.engine.instruction.SemanticException;

import com.hardcode.gdbms.engine.values.IntValue;

import com.hardcode.gdbms.engine.values.Value;

import com.hardcode.gdbms.engine.values.ValueCollection;

import com.hardcode.gdbms.engine.values.ValueFactory;

import com.hardcode.gdbms.parser.ParseException;

import com.iver.cit.gvsig.fmap.layers.FBitSet;

import es.prodevelop.cit.gvsig.arcims.gui.wizards.ArcImsWizard;

public class ArcImsAttributesDataSourceAdapter implements ArcImsAlphanumericDataSource, ObjectDriver {

	private static Logger logger = Logger.getLogger(ArcImsAttributesDataSourceAdapter.class.getName());

	private ArcImsInMemoryAttsTableDriver dataDriver;

	// private File csvFile;

	private String tableName;

	private DataSourceFactory dsFactory = null;

	private ObjectSourceInfo sourceInfo;

	private FMapFeatureArcImsDriver parentDriver;

	private int rowsPerRequest = 10;

	// private int privateKeyIndex = 0;

	// array of Value[]

	// private AttributesDataa attsData; 

	public ArcImsAttributesDataSourceAdapter(ArrayList col_Names, ArrayList col_Types,

			Value[] ids, DataSourceFactory dsf, FMapFeatureArcImsDriver drv, String forcedName) {

		// attsData = new AttributesDataa(col_Names, col_Types, ids, drv);

		parentDriver = drv;

		dsFactory = dsf;

		if (forcedName == null) {

			long timeid = System.currentTimeMillis();

			tableName = "table_" + timeid;

		} else {

			tableName = forcedName;

		}

		dataDriver = new ArcImsInMemoryAttsTableDriver(tableName, col_Names, col_Types);

		sourceInfo = new ObjectSourceInfo();

		sourceInfo.driver = this;

		sourceInfo.name = tableName;

		sourceInfo.driverName = dataDriver.getName();

//		dsFactory = new DataSourceFactory();

//		dsFactory.initialize();

//		dsFactory.addDataSource(this, tableName);

		// dsFactory.crea

		try {

			// dataDriver.open(dataDriver.getConnection(), tableName);

//			String sqlStr = ArcImsSqlUtils.getSqlSentenceCreateTableWithFieldsAndTypes(tableName, col_Names, col_Types, dataDriver.getRowIndexFieldName());

//			dataDriver.open(sqlStr);

			// sqlStr = ArcImsSqlUtils.getSqlSentenceCreateIndex(tableName);

			// dataDriver.execute(sqlStr);

			// dsFactory.executeSQL(sqlStr, DataSourceFactory.DATA_WARE_COHERENT_ROW_ORDER);

			String idcolname = getIdColumnName(col_Names, col_Types);

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

				Value id = ids[i];

				int rwcount = (int) dataDriver.getRowCount(); 

//				sqlStr = ArcImsSqlUtils.getSqlSentenceSetEmptyRowWithId(

//						tableName, id, idcolname,

//						rwcount,

//						dataDriver.getRowIndexFieldName());

				dataDriver.addEmptyRowWithId(id, idcolname);

				// dataDriver.addInIndexToIdHashMap(rwcount, ((IntValue) id).intValue());

				// logger.debug("Adding id = " + ((IntValue) id).intValue() + " in row = " + rwcount);

				dataDriver.addInIdToIndexHashMap(((IntValue) id).intValue(), rwcount);

				// dsFactory.executeSQL(sqlStr, DataSourceFactory.DATA_WARE_DIRECT_MODE);

//				dataDriver.execute(sqlStr);

//				dataDriver.increaseRowCount(false);

			}

			logger.info("Stored " + ids.length + " IDs");

			setRowsPerRequest();

			// String idcolname = dataDriver.executeCreateTableWithFieldsAndTypes(tableName, col_Names, col_Types);

			// dataDriver.executeSetEmptyRowsWithIds(tableName, ids, idcolname);

			// System.err.println("dataDriver.getFieldValue(0, 0) = " + dataDriver.getFieldValue(0, 0).getStringValue(dataDriver.internalValueWriter));

			// getRowId(5);

			// stop();

			// logger.debug("Done: dataDriver.close();");

		} catch (Exception e) {

			logger.error("While creating in-memory database ", e);

		}

	}

	public void deleteRow(long rowInd) throws DriverException {

		// DriverException de = new DriverException("cannot_delete");

		logger.warn("So far, you cannot delete ");

		// throw de;

//		// dataDriver.setRequested((int) rowInd, false);

//		start();

//		dataDriver.deleteRow(dsFactory, (int) rowInd);

//		stop();

//		// dataDriver.deleteRow(dsFactory, (int) rowInd);

	}

	public void insertFilledRowAt(long index, Value[] values) throws DriverException {

		insertFilledRowAt(index, values, true);

	}

	public void insertFilledRowAt(long index, Value[] values, boolean req) throws DriverException {

		// dataDriver.setRequested((int) dataDriver.getRowCount(), req);

		// start();

		dataDriver.addRow(values, req);

		// stop();

		logger.warn("Row was added at the end (not inserted at position " + index + ")");

		// this.

		// dataDriver.addRow(dsFactory, values);