| gvSIG desktop 1

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

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

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

import com.iver.utiles.NumberUtilities;

	/**

	 * Return the default tabledefinition (only

	 * has field description values).

	 * Each driver that inheret this class must overwrite

	 * this.

	 * 

	 * */

	public ITableDefinition getTableDefinition(){

		TableDefinition tableDef = new TableDefinition();

		try {

			tableDef.setFieldsDesc(getFieldsDescription());

		} catch (DriverException e) {

			throw new RuntimeException(e);//excepcion sin chequear

		}

		return tableDef;

	}

	/*azabala

	TODO Copypasteado de SelectableDataSource.

	?No estar?a mejor aqu?? 

	*

	*/

	private FieldDescription[] getFieldsDescription() throws DriverException

	{

		int numFields = getFieldCount();

		FieldDescription[] fieldsDescrip = new FieldDescription[numFields];

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

			fieldsDescrip[i] = new FieldDescription();

			int type = getFieldType(i);

			fieldsDescrip[i].setFieldType(type);

			fieldsDescrip[i].setFieldName(getFieldName(i));

			fieldsDescrip[i].setFieldLength(getFieldWidth(i));

			if (NumberUtilities.isNumeric(type))

			{

				if (!NumberUtilities.isNumericInteger(type))

					// TODO: If there is a lost in precision, this should be changed.

					fieldsDescrip[i].setFieldDecimalCount(6);

			}

			else

				fieldsDescrip[i].setFieldDecimalCount(0);

			// TODO: ?DEFAULTVALUE?

			// fieldsDescrip[i].setDefaultValue(get)

		}

		return fieldsDescrip;

	}

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

    /**

     * Devuelve el "esquema" del origen de datos subyacente al driver.

     * (azabala).

     * Es necesario porque determinados drivers de escritura 

     * (los de bbdd que no soportan resultsets updatables) necesitan conocer

     * el esquema de la tabla subyacente (nombre, p. ej) para poder construir

     * al vuelo la consulta SQL final. 

     * */

    public ITableDefinition getTableDefinition();

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

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

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

import com.iver.utiles.NumberUtilities;

	public ITableDefinition getTableDefinition() {

		TableDefinition tableDef = new TableDefinition();

		try {

			tableDef.setFieldsDesc(getFieldsDescription());

		} catch (DriverException e) {

			throw new RuntimeException(e);//excepcion sin chequear

		}

		return tableDef;

	}

	/*azabala

	TODO Codigo repetido entre ODBCDriver y AbstractJDBCDriver.

	Igual hay que ponerlo en una clase auxiliar comun

	*

	*/

	private FieldDescription[] getFieldsDescription() throws DriverException

	{

		int numFields = getFieldCount();

		FieldDescription[] fieldsDescrip = new FieldDescription[numFields];

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

			fieldsDescrip[i] = new FieldDescription();

			int type = getFieldType(i);

			fieldsDescrip[i].setFieldType(type);

			fieldsDescrip[i].setFieldName(getFieldName(i));

			fieldsDescrip[i].setFieldLength(getFieldWidth(i));

			if (NumberUtilities.isNumeric(type))

			{

				if (!NumberUtilities.isNumericInteger(type))

					// TODO: If there is a lost in precision, this should be changed.

					fieldsDescrip[i].setFieldDecimalCount(6);

			}

			else

				fieldsDescrip[i].setFieldDecimalCount(0);

			// TODO: ?DEFAULTVALUE?

			// fieldsDescrip[i].setDefaultValue(get)

		}

		return fieldsDescrip;

	}

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

	public ITableDefinition getTableDefinition() {

		return null;

	}

/*

 * Created on 16-ene-2007

 *

 * gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2004 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

/* CVS MESSAGES:

*

* $Id$

* $Log$

* Revision 1.1  2007-01-16 20:06:02  azabala

* changes to allow edition with MySQL drivers

*

*

*/

package com.hardcode.gdbms.driver.mysql;

import java.sql.Types;

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

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

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

import com.iver.cit.gvsig.fmap.core.IRow;

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

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

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

public class MySQL {

	public boolean isNumeric(Value val) {

		switch (val.getSQLType()) {

		case Types.DOUBLE:

		case Types.FLOAT:

		case Types.INTEGER:

		case Types.SMALLINT:

		case Types.BIGINT:

		case Types.NUMERIC:

		case Types.REAL:

		case Types.TINYINT:

			return true;

		}

		return false;

	}

	/**

	 * 

	 * @param dbLayerDef

	 * @param fieldsDescr

	 * @param bCreateGID

	 * @return

	 */

	public String getSqlCreateSpatialTable(DBLayerDefinition dbLayerDef,

										FieldDescription[] fieldsDescr, 

										boolean bCreateGID) {

		String result = "CREATE TABLE " + dbLayerDef.getTableName()

					+ " (gid int(10) unsigned NOT NULL auto_increment,";

		int j=0;

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

			int fieldType = fieldsDescr[i].getFieldType();

			//TODO ver si XTypes me los devuelve con la sintaxis MySQL

			String strType = XTypes.fieldTypeToString(fieldType);

			//We dont allow GID field. It is a reserved field name

			if (fieldsDescr[i].getFieldName().equalsIgnoreCase("gid"))

				continue;

			result +=  ", " + dbLayerDef.getFieldNames()[i] + " "	+ strType;

			j++;

		}

		result = result.substring(0, result.length()-1);

		result += ", PRIMARY KEY(GID))";

		return result;

	}

	protected String format(Object value) {

		String retString = null;

		if (value != null) {

			if (value instanceof NullValue)

				retString = "null";

			else{

			    retString += ("'" + value.toString().trim() + "',");	

			}

		} else {

			retString = "null";

		}

		return retString;

	}

	/**

	 * Based in code from JUMP (VividSolutions) and Geotools Things to be aware:

	 * We always will use Spatial Tables with Unique ID. IFeature has the same

	 * field order than dbLayerDef.getFieldNames()

	 * 

	 * @param dbLayerDef

	 * @param feat

	 * @return

	 */

	public String getSqlInsertFeature(DBLayerDefinition dbLayerDef,

			IRow feat) {

		String sql = "INSERT INTO "+ 

					dbLayerDef.getTableName() + " (";

		int numAlphanumericFields = dbLayerDef.getFieldNames().length;

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

			String name = dbLayerDef.getFieldsDesc()[i].getFieldName();

			if (name.equals(dbLayerDef.getFieldID()))

				continue;

			sql += " " + name + ",";

		}//for

		sql = sql.substring(0, sql.length() -1);

		sql += " ) VALUES (";

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

			String name = dbLayerDef.getFieldsDesc()[j].getFieldName();

			if (name.equals(dbLayerDef.getFieldID()))

				continue;

			if (isNumeric(feat.getAttribute(j)))

				sql += feat.getAttribute(j) + ", ";

			else{

				sql += format(feat.getAttribute(j)) + ", ";

			}

		}//for	

		sql = sql.substring(0, sql.length() -1);	   

		sql += " )";

		return sql;

	}

	public String getSqlModifyFeature(DBLayerDefinition dbLayerDef, IRow feat) {

		String sql = "UPDATE " + dbLayerDef.getTableName() + " SET";

		int numAlphanumericFields = dbLayerDef.getFieldsDesc().length;

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

			FieldDescription fldDesc = dbLayerDef.getFieldsDesc()[i];

			if (fldDesc != null){

				String name = fldDesc.getFieldName();

				if (name.equalsIgnoreCase(dbLayerDef.getFieldID()))

					continue;

				Value val = feat.getAttribute(i);

				if (val != null)

				{

					String strAux = val.getStringValue(ValueWriter.internalValueWriter);

					sql += " " + name + " = " + strAux + " ,";

				}//if

			}//if

		}//for

		sql = sql.substring(0, sql.length() -1);

		sql += " WHERE ";

		//TODO El feature.getID() funciona? (AZO)

		sql += dbLayerDef.getFieldID() + " = " + feat.getID();

		return sql;

	}

	/**

	 * It builds MySQL's delete statement

	 * @param dbLayerDef

	 * @param row

	 * @return

	 */

	public String getSqlDeleteFeature(DBLayerDefinition dbLayerDef, IRow row) {

		String sql = "DELETE FROM "

				+ dbLayerDef.getTableName() + " WHERE ";

		int indexFieldId = dbLayerDef.getIdFieldID();

		sql += dbLayerDef.getFieldID() + " = " + row.getAttribute(indexFieldId);

		return sql;

	}

}

import java.sql.ResultSetMetaData;

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

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

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

 * @author azabala

    /**

     * IWriter implementation for MySQL DB.

     * It does editing operations

     * */

    MySQLWriter writer = new MySQLWriter();

        writer.initialize(con);

	    writer.setWriteAll(false);

    	//commented to avoid problems with automatic datasource

//		jdbcSupport.close();

    /*

     *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;

    }

import java.sql.ResultSetMetaData;

import com.iver.cit.gvsig.fmap.core.IRow;

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

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

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

 * 

 * MySQL alphanumeric writer.

 * It is needed because MySQL JDBC driver doesnt allow updatables recordsets.

	private Connection conn;

	private ResultSetMetaData metaData;

	private MySQL mySql = new MySQL();

	public void initialize(Connection conn){

		this.conn = conn;

	}

	public void initialize(ITableDefinition tableDefinition) throws EditionException {

		super.initialize(tableDefinition);

		try {

			createTableIfNeeded();

		} catch (SQLException e) {

			throw new EditionException(e);

		}

	}

	private void createTableIfNeeded() throws SQLException{

		st = conn.createStatement();

		if (bCreateTable) {

			try {

				st.execute("DROP TABLE " + 

						((DBLayerDefinition)tableDef).getTableName() + ";");

			} catch (SQLException e1) {

				e1.printStackTrace();

			}

			//In MySQL you can add geometry column in CREATE TABLE statement

			String sqlCreate = mySql.getSqlCreateSpatialTable((DBLayerDefinition) tableDef,

											tableDef.getFieldsDesc(), 

											true);

			st.execute(sqlCreate);

			conn.commit();

		}//if

		conn.setAutoCommit(false);

		fieldManager = new JdbcFieldManager(conn, 

				((DBLayerDefinition) tableDef).getTableName());

}

			conn.setAutoCommit(false);

			conn.rollback();			

			throw new EditionException(e);

				IRow record =  row.getLinkedRow();

				sqlInsert = mySql.getSqlInsertFeature((DBLayerDefinition) tableDef, record);

				IRow featM =  row.getLinkedRow();

					sqlInsert = mySql.getSqlInsertFeature((DBLayerDefinition) tableDef, featM);

					String sqlModify = mySql.getSqlModifyFeature((DBLayerDefinition) tableDef, featM);

				IRow featO = row.getLinkedRow();

					sqlInsert = mySql.getSqlInsertFeature((DBLayerDefinition) tableDef, featO);

				String sqlDelete = mySql.getSqlDeleteFeature((DBLayerDefinition) tableDef, row);

		try {

			conn.setAutoCommit(true);

		} catch (SQLException e) {

			e.printStackTrace();

			throw new EditionException(e);

		}

		return true;

		try {

			return !conn.isReadOnly();

		} catch (SQLException e) {

			e.printStackTrace();

			return false;

		}

		return "MySQL Alphanumeric Writer";

	public void setCreateTable(boolean createTable) {

		bCreateTable = createTable;

	}

	public boolean isCreateTable() {

		return bCreateTable;

	}

	public boolean isWriteAll() {

		return bWriteAll;

	}

	public void setWriteAll(boolean writeAll) {

		bWriteAll = writeAll;

	}

/*

 * TODO 

 * Esta parte no se si es necesaria, o si se usa (revisar)

 * 

 * */

	public FieldDescription[] getFields() {

		return fieldManager.getFields();

	}

	public FieldDescription[] getOriginalFields() {

		return tableDef.getFieldsDesc();

	}

	public void addField(FieldDescription fieldDesc) {

		fieldManager.addField(fieldDesc);

	}

	public FieldDescription removeField(String fieldName) {

		return fieldManager.removeField(fieldName);

	}

	public void renameField(String antName, String newName) {

		fieldManager.renameField(antName, newName);	

	}