Application: gvSIG desktop

package com.hardcode.gdbms.engine.data.db;

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

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

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

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

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

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

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

import java.sql.Connection;

import java.sql.SQLException;

/**

 * Adaptador de la interfaz DBDriver a la interfaz DataSource. Adapta las

 * interfaces de los drivers de base de datos a la interfaz DataSource.

 *

 * @author Fernando Gonz?lez Cort?s

 */

public abstract class DBDataSourceAdapter extends AbstractDataSource

    implements DBDataSource {

    /*

     * datos de la conexi?n

     */

    protected String host;

    protected int port;

    protected String dbName;

    protected String user;

    protected String password;

    //driver de base de datos

    protected DBDriver driver;

    //objetos jdbc

    protected Connection con;

    //Instrucci?n sql completa que representa el dataSource

    protected String sql;

    /**

     * @see com.hardcode.gdbms.engine.data.driver.ObjectDriver#getRowCount()

     */

    public long getRowCount() throws DriverException {

        return getDriver().getRowCount();

    }

    /**

     * Establece el driver

     *

     * @param driver The driver to set.

     */

    public void setDriver(DBDriver driver) {

        this.driver = driver;

        if (driver instanceof DriverCommons) {

            if (((DriverCommons) driver).getDriverProperties() != null) {

                sourceProperties.putAll(((DriverCommons) driver).getDriverProperties());

            }

        }

    }

    /**

     * @see com.hardcode.gdbms.engine.data.driver.ObjectDriver#getFieldCount()

     */

    public int getFieldCount() throws DriverException {

        return getDriver().getFieldCount();

    }

    /**

     * @see com.hardcode.gdbms.engine.data.driver.ObjectDriver#getFieldName(int)

     */

    public String getFieldName(int fieldId) throws DriverException {

        return getDriver().getFieldName(fieldId);

    }

    /**

     * @see com.hardcode.gdbms.engine.data.driver.ObjectDriver#getFieldType(int)

     */

    public int getFieldType(int i) throws DriverException {

        return getDriver().getFieldType(i);

    }

    /**

     * @see com.hardcode.gdbms.engine.data.driver.ObjectDriver#getFieldValue(long,

     *      int)

     */

    public Value getFieldValue(long rowIndex, int fieldId)

        throws DriverException {

        return getDriver().getFieldValue(rowIndex, fieldId);

    }

    /**

     * DOCUMENT ME!

     *

     * @return

     */

    protected DBDriver getDriver() {

        return driver;

    }

    /**

     * @see com.hardcode.gdbms.engine.data.DataSource#getProperty(java.lang.String)

     */

    public String getProperty(String propertyName) {

        return (String) sourceProperties.get(propertyName);

    }

    /**

     * DOCUMENT ME!

     *

     * @param sourceInfo

     */

    public void setSourceInfo(DriverInfo sourceInfo) {

        super.setSourceInfo(sourceInfo);

        this.host = ((DBDriverInfo) sourceInfo).host;

        this.port = ((DBDriverInfo) sourceInfo).port;

        this.dbName = ((DBDriverInfo) sourceInfo).dbName;

        this.user = ((DBDriverInfo) sourceInfo).user;

        this.password = ((DBDriverInfo) sourceInfo).password;

    }

    /**

     * @see com.hardcode.gdbms.engine.data.db.DBDataSource#execute(java.lang.String)

     */

    public void execute(String sql) throws DriverException {

        try {

            getDriver().execute(driver.getConnection(host, port, dbName, user, password), sql, (HasProperties) this);

        } catch (SQLException e) {

            throw new DriverException(e);

        }

    }

}