package org.opensync.importexport;
   
   import java.io.CharArrayWriter;
   import java.io.File;
   import java.io.FileInputStream;
   import java.io.FileNotFoundException;
   import java.io.IOException;
   import java.io.StringReader;
   import java.sql.Connection;
  import java.sql.SQLException;
  import java.sql.SQLWarning;
  import java.sql.Statement;
  import java.util.Hashtable;
  import java.util.Vector;
  
  import org.opensync.tools.ConnectionPool;
  import org.opensync.tools.Element;
  import org.xml.sax.Attributes;
  import org.xml.sax.InputSource;
  import org.xml.sax.SAXException;
  import org.xml.sax.XMLReader;
  import org.xml.sax.helpers.DefaultHandler;
  import org.xml.sax.helpers.XMLReaderFactory;
  
  public class ImportOfView extends DefaultHandler {
  
    private Vector keysUpdate;
    private Hashtable recordValues;
    private View theme;
    private CharArrayWriter contents;
    private ConnectionPool pool;
    private Connection conn;
    private Statement stmt;
    private boolean batchMode = false;
    private StringBuffer exceptionsMsg = new StringBuffer();
  
    private int nbExceptions;
    private Vector exceptions;
  
    private int nbInsert;
    private int nbUpdate;
  
    public String getExceptionMsg() {
      return exceptionsMsg.toString();
    }
  
    public int getNbExceptions() {
      return nbExceptions;
    }
  
    public String getException(int i) {
      if(i < exceptions.size())
        return (String)exceptions.get(i);
      else return null;
    }
    /***
     * Constructor
     */
    public ImportOfView(ConnectionPool _pool, View _view) throws SQLException,SQLWarning {
      pool = _pool;
      conn = null;
      theme = _view;
      // List of columns for Update
      keysUpdate = buildColumnsUpdate();
      // init values
      recordValues = new Hashtable();
      nbInsert = 0;
      nbUpdate = 0;
      nbExceptions = 0;
      exceptions = new Vector();
    }
  
    public ImportOfView(Connection _conn, Statement stmt, boolean batchMde, View _view) throws SQLException,SQLWarning {
      pool = null;
      conn = _conn;
      this.stmt = stmt;
      this.batchMode = batchMode;
      theme = _view;
      // List of columns for Update
      keysUpdate = buildColumnsUpdate();
      // init values
      recordValues = new Hashtable();
      nbInsert = 0;
      nbUpdate = 0;
      nbExceptions = 0;
      exceptions = new Vector();
  
    }
  
    private Vector buildColumnsUpdate () {
      Vector vector;
      Column v[];
      int j,indexP,iMax,jMax,indexPMax;
      boolean found ;
      String keyW,keyWT,s1,visible;
  
      j= 0;
      vector = new Vector();
      // fill into keys vector the field for Visible = "TRUE"
     v = theme.getElements();
     jMax = v.length;
     for (j=0;j<jMax;j++) {
       Column e = v[j];
       keyW = e.getKeyWord();
       if ( theme.getIdParentFile().equals(e.getFile()) && vector.indexOf(keyW) == -1 ) vector.addElement(keyW);
     }
     return vector;
   }
 
   // parser le resultat Xml
   public void processStringXml(File file)
       throws SAXException,FileNotFoundException,IOException{
 
     exceptionsMsg = new StringBuffer();
     contents = new CharArrayWriter();
     XMLReader xr = XMLReaderFactory.createXMLReader("org.apache.xerces.parsers.SAXParser");
     xr.setContentHandler( this );
     xr.parse( new InputSource(new FileInputStream(file)));
   }
 
   // parser le resultat Xml
   public void processStringXml(String xml)
       throws SAXException,FileNotFoundException,IOException{
 
     exceptionsMsg = new StringBuffer();
     contents = new CharArrayWriter();
     XMLReader xr = XMLReaderFactory.createXMLReader("org.apache.xerces.parsers.SAXParser");
     xr.setContentHandler( this );
     xr.parse( new InputSource(new StringReader(xml)));
   }
 
   public void startDocument(String namespaceURI, String localName, String qName, Attributes attr ) throws SAXException {
     this.exceptionsMsg = new StringBuffer();
   }
 
   public void startElement( String namespaceURI, String localName, String qName, Attributes attr ) throws SAXException {
 
     contents.reset();
     Element currentRefColumn;
 
     if (qName.equals("ROW")) {
       if (recordValues!=null && !recordValues.isEmpty()) recordValues.clear();
     }
   }
 
   public void endElement( String namespaceURI, String localName, String qName ) throws SAXException {
     if (qName.equals("ROW")) {
       //System.out.println("Update Start :******************************************************** ");
       Update update = null;
       Insert insert;
       boolean okInsert=true;
       try {
 	if (theme.getMode().equals("both") || theme.getMode().equals("updateonly")) {
 	  if (pool != null) update = new Update(pool,theme,recordValues);
 	  else if (conn != null) update = new Update(conn, stmt, batchMode, theme,recordValues);
       okInsert = update.getInsertOK();
       if(update != null && !okInsert ) nbUpdate ++;
 	}
       }
       catch (SQLWarning wx) {
 	throw new SAXException(wx);
 	//this.exceptionsMsg.append("\n"+wx.getLocalizedMessage()+"\n");
       }
       catch (SQLException ex) {
 	throw new SAXException(ex);
 	//this.exceptionsMsg.append("\n"+ex.getLocalizedMessage()+"\n");
       }
 
       //System.out.println("Update End :******************************************************** ");
       if ( okInsert && ( theme.getMode().equals("both") || theme.getMode().equals("insertonly") ) ) {
 	//System.out.println("Insert Start :******************************************************** ");
 	try {
 	  if (pool != null) {
       insert = new Insert(pool, theme, recordValues);
       nbInsert++;
     }
     else if (conn != null) {
       insert = new Insert(conn,theme,recordValues, batchMode);
       nbInsert++;
     }
 
 
 	}
 	catch (SQLWarning wx) {
 	  //throw new SAXException(wx);
 	  this.exceptionsMsg.append("\n"+wx.getLocalizedMessage()+"\n");
     nbExceptions ++;
     exceptions.add(wx.getLocalizedMessage());
 	}
 	catch (SQLException ex) {
 	  //throw new SAXException(ex);
 	  this.exceptionsMsg.append("\n"+ex.getLocalizedMessage()+"\n");
     nbExceptions ++;
     exceptions.add(ex.getLocalizedMessage());
 	}
 	//System.out.println("Insert End :******************************************************** ");
       }
     }
     // Remplir Hashtable recordValues
     if (!qName.equals("ROW") && !qName.equals("DATA")) {
       recordValues.put(qName,contents.toString());
     }
 
   }
 
   public void characters( char[] ch, int start, int length ) throws SAXException {
     contents.write( ch, start, length );
   }
 
   public int getNbUpdate() {
     return nbUpdate;
   }
   public int getNbInsert() {
     return nbInsert;
   }
 
 }