| gvSIG desktop 1

/*

 * Created on 16-oct-2004

 */

package com.hardcode.gdbms.driver.mysql;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import com.hardcode.gdbms.engine.data.db.JDBCSupport;

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

import com.iver.cit.gvsig.fmap.drivers.DBLayerDefinition;

import com.iver.cit.gvsig.fmap.drivers.ITableDefinition;

import com.iver.cit.gvsig.fmap.drivers.TableDefinition;

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

/**

 * MySQL driver

 *

 * @author Fernando Gonz?lez Cort?s

 * @author azabala

 */

public class MySQLDriver extends AbstractJDBCDriver {

    private static Exception driverException;

    static {

        try {

            Class.forName("com.mysql.jdbc.Driver").newInstance();

        } catch (Exception ex) {

            driverException = ex;

        }

    }

    /**

     * IWriter implementation for MySQL DB.

     * It does editing operations

     * */

    MySQLWriter writer = new MySQLWriter();

    public IWriter getWriter() {

                return writer;

        }

    public void open(Connection con, String sql) throws SQLException {

                jdbcSupport = JDBCSupport.newJDBCSupport(con, sql);

        writer.initialize(con);

                writer.setCreateTable(false);

            writer.setWriteAll(false);

        }

    public void close() throws SQLException {

            //commented to avoid problems with automatic datasource

//                jdbcSupport.close();

//                writer.close();

        }

    /**

     * DOCUMENT ME!

     *

     * @param host DOCUMENT ME!

     * @param port DOCUMENT ME!

     * @param dbName DOCUMENT ME!

     * @param user DOCUMENT ME!

     * @param password DOCUMENT ME!

     *

     * @return DOCUMENT ME!

     *

     * @throws SQLException

     * @throws RuntimeException DOCUMENT ME!

     *

     * @see com.hardcode.gdbms.engine.data.driver.DBDriver#connect(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:mysql://" + host;

        if (port != -1) {

            connectionString += (":" + port);

        }

        connectionString += ("/" + dbName);

        if (user != null) {

            connectionString += ("?user=" + user + "&password=" + password);

        }

        return DriverManager.getConnection(connectionString);

    }

    /**

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

     */

    public String getName() {

        return "mysql";

    }

    /*

     *Sobreescribo el metodo de AbstractJDBCDriver porque

     *si para la gran mayoria de bbdd no hay que escribir querys

     *(se hace con updatableresultset) para MySQL no funciona esto.

     *Como se necesita construir la query al vuelo, as? se le proporciona

     *al ITableDefinition el nombre de la tabla 

     * */

    public ITableDefinition getTableDefinition(){

            DBLayerDefinition solution = new DBLayerDefinition();

            ITableDefinition schema = super.getTableDefinition();

            solution.setFieldsDesc(schema.getFieldsDesc());

            solution.setName(schema.getName());

            try {

                        ResultSetMetaData metadata = jdbcSupport.getResultSet().

                                                getMetaData();

                        solution.setTableName(metadata.getTableName(1));

                } catch (SQLException e) {

                        throw new RuntimeException(e);

                }

            return solution;

    }

}