Application: gvSIG desktop

import java.util.ArrayList;

import java.util.TreeMap;

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

import com.iver.cit.gvsig.fmap.drivers.jdbc.utils.ConnectionWithParams;

import com.iver.cit.gvsig.fmap.drivers.jdbc.utils.SingleJDBCConnectionManager;

    protected static Hashtable poolPassw = new Hashtable();

    protected DBLayerDefinition lyrDef = null;

    protected Rectangle2D fullExtent = null;

    protected String driverClass;

    protected String userName;

    protected String dbUrl;

    protected String className;

    protected String catalogName;

    protected String tableName;

    protected String[] fields;

    protected String FIDfield;

    protected String geometryField;

    protected String whereClause;

    protected String strSRID;

    protected String host, port, dbName, connName;

	    return Types.OTHER;

        // throw new com.hardcode.gdbms.engine.data.driver.DriverException("Tipo no soportado: " + str);

    public void close() {

        if (xml.contains("host"))

        {

	        host = xml.getStringProperty("host");

	        port = xml.getStringProperty("port");

	        dbName = xml.getStringProperty("dbName");

	        connName = xml.getStringProperty("connName");

        }

        else

        {

        	// Por compatibilidad con versiones anteriores

        	dbUrl = xml.getStringProperty("dbURL");

        	extractParamsFromDbUrl(dbUrl);

        }

    private void extractParamsFromDbUrl(String dbUrl2) {

    	//jdbc:postgres://localhost:5431/latin1

    	int iDbName = dbUrl2.lastIndexOf('/');

		dbName = dbUrl2.substring(iDbName+1);

		int iLast2points = dbUrl2.lastIndexOf(':');

		port = dbUrl2.substring(iLast2points+1, iDbName);

		int iHost = dbUrl2.indexOf("//");

		host = dbUrl2.substring(iHost + 2, iLast2points);

		connName = dbUrl2;

	}

	public void load() throws DriverException {

            String _drvName = getName();

            String keyPool = _drvName.toLowerCase() + "_" + host.toLowerCase()

            + "_" + port + "_" + dbName.toLowerCase()

            + "_" + userName.toLowerCase();

            ConnectionWithParams cwp = null;

            if (poolPassw.containsKey(keyPool)) {

                cwp = SingleJDBCConnectionManager.instance().getConnection(

 					_drvName, userName, clave, connName,

 					host, port, dbName, true);

            } else {

                cwp = SingleJDBCConnectionManager.instance().getConnection(

     					_drvName, userName, null, connName,

     					host, port, dbName, false);

                if (cwp.isConnected()) {

                	poolPassw.put(keyPool, cwp.getPw());

                } else {

                    JPasswordDlg dlg = new JPasswordDlg();

                    String strMessage = Messages.getString("conectar_jdbc");

                    String strPassword = Messages.getString("password");

                    dlg.setMessage(strMessage

                    		+ " ["

                    		+ _drvName + ", "

                    		+ host + ", "

                    		+ port + ", "

                    		+ dbName + ", "

                    		+ userName + "]. "

                    		+ strPassword

                    		+ "?");

                    dlg.show();

                    clave = dlg.getPassword();

                    if (clave == null)

                        return;

                    poolPassw.put(keyPool, clave);

                    cwp.connect(clave);

                }

            newConn = cwp.getConnection();

        	throw new DriverException(e.getMessage());

		}

            ConnectionWithParams cwp =

            	SingleJDBCConnectionManager.instance().findConnection(getConnection());

            xml.putProperty("host", cwp.getHost());

            xml.putProperty("port", cwp.getPort());

            xml.putProperty("dbName", cwp.getDb());

            xml.putProperty("connName", cwp.getName());

     * Gets available table names. Should be overwritten by subclasses if its

     * not compatible or if it can be refined

     * 

     * @param conn connection object

     * @param catalog catalog name

     * @return array of strings with available table names

     * @throws SQLException

     */

    public String[] getTableNames(Connection conn, String catalog) throws SQLException {

    	DatabaseMetaData dbmd = conn.getMetaData();

        String[] types = {"TABLE", "VIEW"};

		ResultSet rs = dbmd.getTables(catalog, null, null, types);

		TreeMap ret = new TreeMap();

		while (rs.next()){

			ret.put(rs.getString("TABLE_NAME"), rs.getString("TABLE_NAME"));

		}

		rs.close();

		return (String[]) ret.keySet().toArray(new String[0]);

    }

    /**

     *       Gets all field names of a given table

     * @param conn connection object

     * @param table_name table name

     * @return all field names of the given table

     * @throws SQLException

     */

    public String[] getAllFields(Connection conn, String table_name) throws SQLException {

		Statement st = conn.createStatement();

		ResultSet rs = st.executeQuery("select * from " + table_name + " LIMIT 1");

		ResultSetMetaData rsmd = rs.getMetaData();

		String[] ret = new String[rsmd.getColumnCount()];

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

			ret[i] = rsmd.getColumnName(i+1);

		}

		rs.close(); st.close();

		return ret;

    }

    /**

     *       Gets all field type names of a given table

     * @param conn connection object

     * @param table_name table name

     * @return all field type names of the given table

     * @throws SQLException

     */

    public String[] getAllFieldTypeNames(Connection conn, String table_name) throws SQLException {

		Statement st = conn.createStatement();

		ResultSet rs = st.executeQuery("select * from " + table_name + " LIMIT 1");

		ResultSetMetaData rsmd = rs.getMetaData();

		String[] ret = new String[rsmd.getColumnCount()];

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

			ret[i] = rsmd.getColumnTypeName(i+1);

		}

		rs.close(); st.close();

		return ret;

    }

    /**

     * Gets the table's possible id fields. By default, all fields can be id. 

     * It should be overwritten by subclasses.

     * 

     * @param conn conenction object

     * @param table_name table name

     * @return the table's possible id fields

     * @throws SQLException

     */

    public String[] getIdFieldsCandidates(Connection conn, String table_name) throws SQLException {

    	return getAllFields(conn, table_name);

    }

    /**

     * Gets the table's possible geometry fields. By default, all fields can be geometry

     * fields. It should be overwritten by subclasses.

     * 

     * @param conn conenction object

     * @param table_name table name

     * @return the table's possible geometry fields

     * @throws SQLException

     */

    public String[] getGeometryFieldsCandidates(Connection conn, String table_name) throws SQLException {

    	return getAllFields(conn, table_name);

    }

    /**

     * Tells if it's an empty table (with no records)

     * @param conn conenction object

     * @param tableName rtable name

     * @return whether it's an empty table (with no records) or not

     */

	public boolean isEmptyTable(Connection conn, String tableName) {

		boolean res = true;

		try {

			Statement st = conn.createStatement();

			ResultSet rs = null;

			rs = st.executeQuery("select * from " + tableName + " LIMIT 1");

			res = !rs.next();

			rs.close(); st.close();

		} catch (Exception ex) {

			res = true;

		}

		return res;

	}

	/**

	 * Utility method to allow the driver to do something with the geometry field.

	 * By default does nothing.

	 * 

	 * @param flds user-selected fields

	 * @param geomField geometry field

	 * @return new user-selected fields

	 */

	public String[] manageGeometryField(String[] flds, String geomField) {

		return flds;

	}

	/**