/**
 * Created by IntelliJ IDEA.
 * User: Gerda
 * Date: 13.08.2007
 * Time: 16:47:14
 * To change this template use File | Settings | File Templates.
 */
 package  com.bcc.vasp.admin;

 import  org.apache.log4j.Logger;

 import  javax.naming.Context;
 import  javax.naming.InitialContext;
 import  javax.naming.NamingException;
 import  javax.sql.DataSource;
 import  java.sql.*;

 public   class  DBAdmin {

    DataSource pool;
     private   static   final  Logger LOG = Logger.getLogger("DBAdmin");
     public  DBAdmin(){

        LOG.debug("DBAdmin start");
        Context env =  null ;
       


         try {

            env = (Context)  new  InitialContext().lookup("java:comp/env");
          
            pool = (DataSource) env.lookup("jdbc/MessageBD");
           
            
             if (pool ==  null ){
                LOG.error("jdbc/MessageBD is an unknown DataSource");
            }

        }  catch  (Exception ne){
            LOG.error("error: ");
            ne.printStackTrace();
        }
    }


    
     public   boolean  setNewUser(String clientId){
        LOG.debug("setNewUser start");
        Connection conn = null ;
        PreparedStatement pstmt =  null ;
        ResultSet rs =  null ;
        ResultSetMetaData rsm =  null ;
         try {
            

            conn = pool.getConnection();
            
            pstmt = conn.prepareStatement("insert into messageRep(clientId,messageType, messageValue,received) value(?,?,NULL,true);");
           
            
            pstmt.setString( 1 ,clientId);
            pstmt.setString( 2 ,"DATA");
            
            pstmt.addBatch();
           
            pstmt.executeUpdate();

            pstmt.setString( 1 ,clientId);
            pstmt.setString( 2 ,"CLIENT");
            pstmt.addBatch();
            

             pstmt.executeUpdate();
             
          
        } catch (Exception ex){
            LOG.error("error");
            ex.printStackTrace();
             try  {
                conn.close();
                 this .finalize();
            }  catch  (Throwable throwable) {
                LOG.error("conn.finalize()");
            }
            LOG.debug("setNewUser fin");
             return  false;

        }
         try  {
            conn.close();
             this .finalize();
        }  catch  (Throwable throwable) {
            LOG.error("conn.finalize()");
        }
        LOG.debug("setNewUser fin");
         return  true;
     }
      public   boolean  clearUser(String clientId){
         Connection conn = null ;
        LOG.debug("clearUser start");
        String sql ="Delete from messageRep where clientId = \""+clientId+"\";";

        Statement stmt =  null ;
        ResultSet rs =  null ;
        ResultSetMetaData rsm =  null ;
         try {
            conn = pool.getConnection();
            stmt = conn.createStatement();
           
            stmt.executeUpdate(sql);
           
        } catch (Exception ex){
            LOG.error("error");
            ex.printStackTrace();
             try  {
                conn.close();
                 this .finalize();
            }  catch  (Throwable throwable) {
                LOG.error("conn.finalize()");
            }
            LOG.debug("clearUser fin");
             return  false;

        }
        
         try  {
                conn.close();
                 this .finalize();
            }  catch  (Throwable throwable) {
                LOG.error("conn.finalize()");
            }
         LOG.debug("clearUser fin");
         return  true;
     }



         protected   void  finalize()  throws  Throwable {
                 super .finalize();

     }

}