package dk.daoas.daoadresseservice.db;

import java.sql.SQLException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import dk.daoas.daoadresseservice.beans.SearchResult;

public class LogPersistance  {
	
	ExecutorService threadPool = Executors.newFixedThreadPool(1);
	
	static class LogPersistanceWorker implements Runnable {
		String brugerid;
		String postnr;
		String adresse;
		SearchResult result;
		
		public LogPersistanceWorker(String brugerid, String postnr, String adresse, SearchResult result) {
			this.brugerid = brugerid;
			this.postnr = postnr;
			this.adresse = adresse;
			this.result = result;
		}
		
		@Override 
		public void run() {
			try {
				DatabaseLayer.saveRequestLog(brugerid,postnr,adresse,result);
			} catch (SQLException e) {
				System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
			}
		}		
	}
	
	public void saveRequestLog(String brugerid, String postnr, String adresse, SearchResult result) {
		threadPool.execute( new LogPersistanceWorker(brugerid,postnr,adresse,result) );
	}


	public void shutdown() {
		threadPool.shutdown();		
	}
}