| gvSIG desktop 1

import java.sql.ResultSet;

import java.sql.Statement;

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

import com.iver.cit.gvsig.fmap.drivers.jdbc.mysql.MySQLSpatialWriter;

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

import com.iver.cit.gvsig.fmap.edition.writers.JdbcWriter;

    MySQLSpatialWriter writer = new MySQLSpatialWriter();

    public IWriter getWriter() {

		return writer;

	}

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

		jdbcSupport = JDBCSupport.newJDBCSupport(con, sql);

		writer.setCreateTable(false);

		writer.setWriteAll(false);

//		writer.initialize(con);

	}

    public void close() throws SQLException {

		jdbcSupport.close();

//		writer.close();

	}

/*

 * Created on 16-ene-2007 by azabala

 *

 */

package com.hardcode.gdbms.driver.mysql;

import java.sql.Connection;

import java.sql.SQLException;

import java.sql.Statement;

import java.sql.Types;

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

import com.iver.cit.gvsig.fmap.drivers.jdbc.mysql.MySql;

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

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

import com.iver.cit.gvsig.fmap.edition.fieldmanagers.JdbcFieldManager;

import com.iver.cit.gvsig.fmap.edition.writers.AbstractWriter;

/**

 * @author alzabord

 * 

 * @see MySQLSpatialWriter from extJDBC project

 */

public class MySQLWriter extends AbstractWriter{

	private int numRows;

	private Connection conex;

	private Statement st;

	private boolean bCreateTable;

	private boolean bWriteAll;

	private MySql mySql = new MySql();

	private JdbcFieldManager fieldManager;

	public boolean canWriteAttribute(int sqlType) {

		switch (sqlType) {

		case Types.DOUBLE:

		case Types.FLOAT:

		case Types.INTEGER:

		case Types.BIGINT:

			return true;

		case Types.DATE:

			return true;

		case Types.BIT:

		case Types.BOOLEAN:

			return true;

		case Types.VARCHAR:

		case Types.CHAR:

		case Types.LONGVARCHAR:

			return true; 

		}

		return false;

	}

	public void preProcess() throws EditionException {

		numRows = 0;

		try {

			conex.setAutoCommit(false);

			conex.rollback();			

			alterTable();

		} catch (SQLException e) {

			// TODO Auto-generated catch block

			e.printStackTrace();

		}

	}

	public boolean alterTable() throws EditionException {

		return fieldManager.alterTable();

	}

	public void process(IRowEdited row) throws EditionException {

		String sqlInsert;

		try {

			switch (row.getStatus()) {

			case IRowEdited.STATUS_ADDED:

				IFeature feat = (IFeature) row.getLinkedRow();

				sqlInsert = mySql.getSqlInsertFeature(lyrDef, feat);

				st.execute(sqlInsert);

				break;

			case IRowEdited.STATUS_MODIFIED:

				IFeature featM = (IFeature) row.getLinkedRow();

				if (bWriteAll) {

					sqlInsert = mySql.getSqlInsertFeature(lyrDef, featM);

					System.out.println("sql = " + sqlInsert);

					st.execute(sqlInsert);

				} else {

					String sqlModify = mySql.getSqlModifyFeature(lyrDef, featM);

					st.execute(sqlModify);

				}

				break;

			case IRowEdited.STATUS_ORIGINAL:

				IFeature featO = (IFeature) row.getLinkedRow();

				if (bWriteAll) {

					sqlInsert = mySql.getSqlInsertFeature(lyrDef, featO);

					st.execute(sqlInsert);

				}

				break;

			case IRowEdited.STATUS_DELETED:

				String sqlDelete = mySql.getSqlDeleteFeature(lyrDef, row);

				System.out.println("sql = " + sqlDelete);

				st.execute(sqlDelete);

				break;

			}

			numRows++;

		} catch (SQLException e) {

			e.printStackTrace();

			throw new EditionException(e);

		}

	}

	public void postProcess() throws EditionException {

		// TODO Auto-generated method stub

	}

	public boolean canAlterTable() {

		// TODO Auto-generated method stub

		return false;

	}

	public boolean canSaveEdits() {

		// TODO Auto-generated method stub

		return false;

	}

	public String getName() {

		// TODO Auto-generated method stub

		return null;

	}

}