package dk.daoas.daoadresseservice;

import java.sql.SQLException;

import javax.servlet.ServletContext;

import dk.daoas.daoadresseservice.admin.ServiceConfig;

public class DataLoader {
	
	boolean isRunning = false;
	
	ServiceConfig config; 
	
	ServletContext ctxt;
	public DataLoader(ServletContext ctxt) {
		this.ctxt = ctxt;
		
		config = (ServiceConfig) ctxt.getAttribute("config");
	}
	
	public void doLoad() {
		synchronized(this) {
			if (isRunning == false) {
				isRunning = true;
				
				Thread t = new Thread( new DataLoadWorker(this), "SearchDataLoader");
				t.start();
			}
		}
	}
	
	public boolean isRunning() {
		synchronized(this) {
			return isRunning;	
		}		
	}
	
	protected void  setRunningFalse() {
		synchronized(this) {
			isRunning = false;
		}
	}

	
	
	
	public static class DataLoadWorker implements Runnable {
		DataLoader loader;
		public DataLoadWorker(DataLoader ld) {
			this.loader = ld;
		}
		

		@Override
		public void run() {
    	
	    	
	    	try {
	    		AdressSearch search = new AdressSearch(loader.config);
	    		search.buildSearchStructures();
	    		
	    		AdressSearch oldSearch = (AdressSearch) loader.ctxt.getAttribute("search");
	    		loader.ctxt.setAttribute("search", search);
	    		
	    		if (oldSearch != null) {
	    			oldSearch.clear();
	    		}
	    			    		
	    	} catch (SQLException e) {
	    		System.out.println("Error loading data: " + e.getMessage());
	    	} finally {
	    		loader.setRunningFalse();
	    	}
	    	
		}
		

	}

}