package cz.frantovo.abcDrupal;

 import java.sql.Connection;

 import java.sql.DriverManager;

 import java.sql.PreparedStatement;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.sql.Statement;

 import java.util.Date;

 import java.util.logging.Level;

 import java.util.logging.Logger;

 /**

  * Řídící třída, stará se o konverzi z databáze Drupalu do databáze ABC.

  * @author fiki

  */

 public class Konvertor {

     private static final Logger log = Logger.getLogger(Konvertor.class.getSimpleName());

     private PosluchacLogu posluchacLogu;

     private String jdbcZdroj;

     private String jdbcCil;

     private Connection dbZdroj;

     private Connection dbCil;

     public Konvertor(String jdbcZdroj, String jdbcCil, PosluchacLogu posluchacLogu) {

 	this.jdbcZdroj = jdbcZdroj;

 	this.jdbcCil = jdbcCil;

 	this.posluchacLogu = posluchacLogu;

     }

     public void konvertuj() {

 	vypis("Začíná migrace");

 	try {

 	    nastavDBspojeni();

 	} catch (SQLException e) {

 	    vypis("Chyba při připojování k databázím.");

 	    log.log(Level.SEVERE, "Chyba při připojování k databázím.", e);

 	    vypis("Končím.");

 	    return;

 	}

 	vypis("Migrace dokončena");

     }

     /**

      * Připojí databáze a zkontroluje SQL dotazem, že jsou v pořádku.

      * @throws SQLException

      */

     private void nastavDBspojeni() throws SQLException {

 	dbZdroj = DriverManager.getConnection(jdbcZdroj);

 	dbCil = DriverManager.getConnection(jdbcCil);

 	PreparedStatement sqlZdroj = dbZdroj.prepareStatement("SELECT count(*) FROM node");

 	ResultSet rsZdroj = sqlZdroj.executeQuery();

 	rsZdroj.next();

 	int pocetZdroj = rsZdroj.getInt(1);

 	log.log(Level.INFO, "Počet záznamů v tabulce „node“ ve zdrojové DB: " + pocetZdroj);

 	zavri(null, sqlZdroj, rsZdroj);

 	PreparedStatement sqlCil = dbCil.prepareStatement("SELECT count(*) FROM polozka");

 	ResultSet rsCil = sqlCil.executeQuery();

 	rsCil.next();

 	int pocetCil = rsCil.getInt(1);

 	log.log(Level.INFO, "Počet záznamů v tabulce „polozka“ v cílové DB: " + pocetCil);

 	zavri(null, sqlCil, rsCil);

     }

     private void vypis(String zprava) {

 	if (posluchacLogu != null) {

 	    posluchacLogu.vypis(new Date() + " " + zprava);

 	}

     }

     /**

      * Zavře všechno

      * @param spojeni DB spojení

      * @param prikaz DB dotaz

      * @param vysledek DB výsledek

      */

     protected static void zavri(Connection spojeni, Statement prikaz, ResultSet vysledek) {

         if (vysledek != null) {

             try {

                 vysledek.close();

             } catch (Exception e) {

             }

         }

         if (prikaz != null) {

             try {

                 prikaz.close();

             } catch (Exception e) {

             }

         }

         if (spojeni != null) {

             try {

                 spojeni.close();

             } catch (Exception e) {

             }

         }

     }

 }