daoadresseservice/db/LogPersistance.java

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);
        
        private static class LogPersistanceWorker implements Runnable {
                
                DatabaseLayer db;
                String brugerid;
                String postnr;
                String adresse;
                SearchResult result;
                
                public LogPersistanceWorker(DatabaseLayer db, String brugerid, String postnr, String adresse, SearchResult result) {
                        this.db = db;
                        this.brugerid = brugerid;
                        this.postnr = postnr;
                        this.adresse = adresse;
                        this.result = result;
                }
                
                @Override 
                public void run() {
                        try {
                                db.saveRequestLog(brugerid,postnr,adresse,result);
                        } catch (SQLException e) {
                                System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
                        }
                }               
        }
        
        public void saveRequestLog(DatabaseLayer db, String brugerid, String postnr, String adresse, SearchResult result) {
                threadPool.execute( new LogPersistanceWorker(db, brugerid, postnr, adresse, result) );
        }


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

1	torben	2371	package dk.daoas.daoadresseservice.db;
2
3			import java.sql.SQLException;
4	torben	2375	import java.util.concurrent.ExecutorService;
5	torben	2371	import java.util.concurrent.Executors;
6
7			import dk.daoas.daoadresseservice.beans.SearchResult;
8
9	torben	2375	public class LogPersistance {
10	torben	2371
11	torben	2375	ExecutorService threadPool = Executors.newFixedThreadPool(1);
12	torben	2371
13	torben	2542	private static class LogPersistanceWorker implements Runnable {
14	torben	2608
15			DatabaseLayer db;
16	torben	2371	String brugerid;
17			String postnr;
18			String adresse;
19			SearchResult result;
20
21	torben	2608	public LogPersistanceWorker(DatabaseLayer db, String brugerid, String postnr, String adresse, SearchResult result) {
22			this.db = db;
23	torben	2371	this.brugerid = brugerid;
24			this.postnr = postnr;
25			this.adresse = adresse;
26			this.result = result;
27			}
28
29			@Override
30			public void run() {
31			try {
32	torben	2608	db.saveRequestLog(brugerid,postnr,adresse,result);
33	torben	2371	} catch (SQLException e) {
34	torben	2541	System.out.println("Error saving log entry " + e.getMessage() + ". Postnr=" + postnr + ". Adresse=" + adresse);
35	torben	2371	}
36			}
37			}
38
39	torben	2608	public void saveRequestLog(DatabaseLayer db, String brugerid, String postnr, String adresse, SearchResult result) {
40			threadPool.execute( new LogPersistanceWorker(db, brugerid, postnr, adresse, result) );
41	torben	2371	}
42	torben	2375
43
44			public void shutdown() {
45			threadPool.shutdown();
46			}
47	torben	2371	}
48	torben	2608