import java.sql.*;
import java.util.ArrayList;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.List;

public class Importacion {
	
	private String JDBC_driver = "com.mysql.jdbc.Driver";
	private String ODBC_driver = "sun.jdbc.odbc.JdbcOdbcDriver";
	private String dsn; 
	private String dbURL; 
	private String Usuario; 
	private String Passwd;
	
	/*
	 *  CONNECT mysql
	 */
	synchronized public Connection ConectaMysql(String User, String Pass, String dsn) throws Exception {
		this.dsn=dsn;
		this.dbURL="jdbc:mysql://localhost:3306/"+this.dsn+"?useServerPrepStmts=true";
		this.Usuario=User;
		this.Passwd=Pass;
		
			Class.forName(JDBC_driver);

			Connection con = DriverManager.getConnection(dbURL,Usuario,Passwd);
			
			return con;
			//System.out.println("Conectamos a la base. id="+this.toString());
			//System.out.println("con="+con.toString());
			//con.setReadOnly(true);
	}
	
	/*
	 * DISCONNECT mysql
	 */
	synchronized public void DesconectarMysql(Connection con)  {
		if (con!=null) {
			try {
				con.close();
				//System.out.println("Desconectamos de la base. id="+this.toString());
				//System.out.println("con="+con.toString());
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				//System.out.println("Error al desconectar id="+this.toString());
				//System.out.println("con="+con.toString());
				e.printStackTrace();
			}
		}
	}
	/*
	 *  CONNECT OTHER DATABASE (NO MYSQL)
	 */
	synchronized public Connection ConectaEloq(String User, String Pass, String dsn) throws Exception {
		this.dsn=dsn;
		this.dbURL="jdbc:odbc:"+this.dsn;
		this.Usuario=User;
		this.Passwd=Pass;
		
		// Carreguem el driver
			Class.forName(ODBC_driver);

		// obtenim la connexio
			Connection con = DriverManager.getConnection(dbURL,Usuario,Passwd);
			
			//System.out.println("Conectamos a la base. id="+this.toString());
			//System.out.println("con="+con.toString());
			con.setReadOnly(true);
			
			return con;
	}
	
	/*
	 * DISCONNECT OTHER DATABASE (NO MYSQL)
	 */
	synchronized public void DesconectarEloq(Connection con)  {
		if (con!=null) {
			try {
				con.close();
				//System.out.println("Desconectamos de la base. id="+this.toString());
				//System.out.println("con="+con.toString());
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				//System.out.println("Error al desconectar id="+this.toString());
				//System.out.println("con="+con.toString());
				e.printStackTrace();
			}
		}
	}

	/*
	 * GET DATA OF OTHER DATABASE (NO MYSQL)
	 */
	@SuppressWarnings("unchecked")
	public ArrayList<Element> getListElementos (Connection con, int reg_inicial, int n_limite) throws Exception {
			
		ArrayList<Element> Listado = new ArrayList<Element>();
		******************GET DATA OTHER DATABASE (NO MYSQL) AND IT SAVES TO Listado************** 
		return Listado;
	}
	

        /*
         * Obitene un arraylist con todos los elementos del eloq
         */
        @SuppressWarnings("unchecked")
        public ArrayList<Element> getListElementos (Connection con) throws Exception {

                ArrayList<Element> Listado = new ArrayList<Element>();
		    ******************GET DATA OTHER DATABASE (NO MYSQL) AND IT SAVES TO Listado**************
                return Listado;
        }


	/*
	 * CHANGE ' by ´ 
	 */
	@SuppressWarnings("unchecked")
	public ArrayList<Element> pasaFiltro(ArrayList<Element> Listado)
	{
		ArrayList<Element> ListadoRes = new ArrayList<Element>();
		int tam = Listado.size();
		for(int i=0;i<tam;i++)
		{
	         Element elem =	(Element)Listado.get(0);
	         Listado.remove(0);
	         elem.setDescripcion((elem.getDescripcion()).replace("'","´"));
	         ListadoRes.add(elem);
		}

		return ListadoRes;

	}
	
	/*
	 * GET NUMBER REGISTERS TO UPDATE (OF OTHER DATABASE)
	 */
	public int getNumElementos(Connection con) throws Exception 
	{
		String Query = "";
		PreparedStatement pstm = null ;
		ResultSet rs;
		Query = "SELECT COUNT(*) AS 'Num' FROM xxxxxxx";
		pstm = con.prepareStatement(Query);
		rs=pstm.executeQuery();
		int n_elementos = 0;
		if(rs.next()) {
			n_elementos = rs.getInt("Num");
		}
		rs.close();
		pstm.close();
		return n_elementos;
	}
	
	/*
	 * UPDATE TO MYSQL
	 */
	public int updateElemento(Connection con, int id, String descripcion) throws Exception 
	{

	Statement st = con.createStatement();
	int rs = 0;
	rs = st.executeUpdate("UPDATE elementos2 SET descripcion_elemento='"+descripcion+"' WHERE id_elemento LIKE "+id+" LIMIT 1");
	st.close();
	return rs;

	}
	
	/*
	 * INSERT TO MYSQL
	 */
	public int insertElemento(Connection con, int id, String descripcion) throws Exception 
	{
		String Query = "";
		PreparedStatement pstm = null ;
		int rs = 0;
		Query = "INSERT INTO elementos2 (id_elemento, descripcion_elemento) values (?,?)";
		pstm = con.prepareStatement(Query);
		pstm.setInt(1,id);
		pstm.setString(2,descripcion);
		rs=pstm.executeUpdate();
		pstm.close();
		return rs;
	}
	
	/*
	 * main: GET DATA FROM OTHER DATABASE AND UPDATE OR INSERT TO MYSQL 
	 */
	public static void main( String args[] )
	{
		Importacion im = new Importacion();
		try {
			Date fecha_inicio = (new GregorianCalendar()).getTime();
			System.out.println(fecha_inicio.toString());

			Connection con  = null; 
                  int n_reg_actualizados = 0;
                  int reg_inicial = 0;
                  int resultadoUpdate = 0;
			int tam = 0;

			//*********GET NUMBER REGISTERS TO OTHER DATABASE
			con=im.ConectaEloq("xxxx","xxxxx","xxxxxx");
			int n_reg_totales=im.getNumElementos(con);
			im.DesconectarEloq(con);
			System.out.println("Num reg = "+n_reg_totales);

			//*********GET DATA FROM OTHER DATABSE
			ArrayList<Element> Listado = new ArrayList<Element>();
                  con = im.ConectaEloq("public","","BAQ901_BS4");
                  Listado = im.getListElementos(con, reg_inicial,n_reg_totales);
 			//Listado = im.getListElementos(con); 
                  im.DesconectarEloq(con);
			Listado = im.pasaFiltro(Listado);
 
			con =im.ConectaMysql("root","mysql","busquedas");
			String Query = "";
                	PreparedStatement pstm = null;
                	int rs = 0;
                	Query = "UPDATE elementos2 SET descripcion_elemento=? WHERE id_elemento LIKE ? LIMIT 1";
                	pstm = con.prepareStatement(Query);

			while (n_reg_actualizados < n_reg_totales)
			{
				if (n_reg_totales - n_reg_actualizados >=1000){
					tam = 1000;
				}else{
					tam = n_reg_totales - n_reg_actualizados;
				}
	
				for( int i=0; i<tam; i++ )
				{
					Element ele = (Element)Listado.get(n_reg_actualizados);
					//Listado.remove(0);
					int clave = ele.getId();
					String valor = ele.getDescripcion();

					//*********UPDATE O INSERT TO MYSQL
					resultadoUpdate = im.updateElemento(con,clave,valor);
                			pstm.setString(1,valor);
					pstm.setInt(2,clave);
                			resultadoUpdate=pstm.executeUpdate();
					
					if(resultadoUpdate == 0)
					{
					im.insertElemento(con,clave,valor);
					}

					n_reg_actualizados++;
				}
				reg_inicial = reg_inicial+1001;
				System.out.println(reg_inicial + "<i-a>" + n_reg_actualizados);
				Date fecha_fin = (new GregorianCalendar()).getTime();
				System.out.println(fecha_fin.toString());
			}
		pstm.close();
		im.DesconectarMysql(con);
			//Date fecha_fin = (new GregorianCalendar()).getTime();
			//System.out.println(fecha_fin.toString());
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			Date fecha_fin = (new GregorianCalendar()).getTime();
			System.out.println(fecha_fin.toString());
		}
	}
	
}