| gvSIG desktop 1

package com.hardcode.gdbms.engine;

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

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

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

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

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

/**

 * Clase que representa el producto cartesiano de dos o m?s tablas. El

 * almacenamiento de dicha tabla se realiza en las propias tablas sobre las

 * que se opera, haciendo los c?lculos en cada acceso para saber en qu? tabla

 * y en qu? posici?n de la tabla se encuentra el dato buscado

 *

 * @author Fernando Gonz?lez Cort?s

 */

public class PDataSource implements DataSource {

    private DataSource[] tables;

    private long tablesArity;

    private FieldNameAccessSupport fnaSupport = new FieldNameAccessSupport(this);

    /**

     * Creates a new PDataSource object.

     *

     * @param tables Array de tablas que forman el producto

     */

    public PDataSource(DataSource[] tables) {

        this.tables = tables;

    }

    /**

     * Dado un ?ndice de campo en la tabla producto, devuelve el ?ndice en la

     * tabla operando a la cual pertenence el campo

     *

     * @param fieldId ?ndice en la tabla producto

     *

     * @return ?ndice en la tabla operando

     *

     * @throws DriverException Si se prouce alg?n error accediendo a la tabla

     *         operando

     */

    private int getFieldIndex(int fieldId) throws DriverException {

        int table = 0;

        while (fieldId >= tables[table].getFieldCount()) {

            fieldId -= tables[table].getFieldCount();

            table++;

        }

        return fieldId;

    }

    /**

     * Dado un ?ndice de campo en la tabla producto, devuelve el ?ndice en el

     * array de tablas de la tabla operando que contiene dicho campo

     *

     * @param fieldId ?ndice del campo en la tabla producto

     *

     * @return ?ndice de la tabla en el array de tablas

     *

     * @throws DriverException Si se prouce alg?n error accediendo a la tabla

     *         operando

     */

    private int getTableIndexByFieldId(int fieldId) throws DriverException {

        int table = 0;

        while (fieldId >= tables[table].getFieldCount()) {

            fieldId -= tables[table].getFieldCount();

            table++;

        }

        return table;

    }

    /**

     * Devuelve la fila de la tabla operando con ?ndice tableIndex que contiene

     * la informaci?n de la fila rowIndex en la tabla producto

     *

     * @param rowIndex fila en la tabla producto a la que se quiere acceder

     * @param tableIndex ?ndice de la tabla

     *

     * @return fila en la tabla operando de ?ndice tableIndex que se quiere

     *         acceder

     *

     * @throws DriverException Si se prouce alg?n error accediendo a la tabla

     *         operando

     * @throws ArrayIndexOutOfBoundsException Si la fila que se pide (rowIndex)

     *         supera el n?mero de filas de la tabla producto

     */

    private long getTableRowIndexByTablePosition(long rowIndex, int tableIndex)

        throws DriverException {

        if (rowIndex >= tablesArity) {

            throw new ArrayIndexOutOfBoundsException();

        }

        int arity = 1;

        for (int i = tableIndex + 1; i < tables.length; i++) {

            arity *= tables[i].getRowCount();

        }

        long selfArity = tables[tableIndex].getRowCount();

        return (rowIndex / arity) % selfArity;

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#getFieldName(int)

     */

    public String getFieldName(int fieldId) throws DriverException {

        return tables[getTableIndexByFieldId(fieldId)].getFieldName(getFieldIndex(

                fieldId));

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#getIntFieldValue(int, int)

     */

    public Value getFieldValue(long rowIndex, int fieldId)

        throws DriverException {

        int tableIndex = getTableIndexByFieldId(fieldId);

        return tables[tableIndex].getFieldValue(getTableRowIndexByTablePosition(

                rowIndex, tableIndex), getFieldIndex(fieldId));

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#getFieldCount()

     */

    public int getFieldCount() throws DriverException {

        int ret = 0;

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

            ret += tables[i].getFieldCount();

        }

        return ret;

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#getRowCount()

     */

    public long getRowCount() {

        return tablesArity;

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#open(java.io.File)

     */

    public void start() throws DriverException {

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

            try {

                tables[i].start();

            } catch (DriverException e) {

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

                    tables[i].stop();

                }

                throw e;

            }

        }

        tablesArity = 1;

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

            tablesArity *= tables[i].getRowCount();

        }

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#close()

     */

    public void stop() throws DriverException {

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

            tables[i].stop();

        }

    }

    /**

     * @see com.hardcode.gdbms.data.DataSource#getFieldIndexByName(String)

     */

    public int getFieldIndexByName(String fieldName) throws DriverException {

        return fnaSupport.getFieldIndexByName(fieldName);

    }

    /**

     * @see com.hardcode.gdbms.engine.data.DataSource#getName()

     */

    public String getName() {

        return "";

    }

        /**

         * @see com.hardcode.gdbms.engine.data.DataSource#getDBMS()

         */

        public String getDBMS() {

                return null;

        }

        /**

         * @see com.hardcode.gdbms.engine.data.DataSource#getDriver()

         */

        public ReadDriver getDriver() {

                return null;

        }

}