daoas/daoadresseservice/DataLoader.java

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,ServiceConfig conf) {
                this.ctxt = ctxt;
                
                config = conf;
        }
        
        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();
                }
                
                }
                

        }

}
1	package dk.daoas.daoadresseservice;
2
3	import java.sql.SQLException;
4
5	import javax.servlet.ServletContext;
6
7	import dk.daoas.daoadresseservice.admin.ServiceConfig;
8
9	public class DataLoader {
10
11	boolean isRunning = false;
12
13	ServiceConfig config;
14
15	ServletContext ctxt;
16	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
17	this.ctxt = ctxt;
18
19	config = conf;
20	}
21
22	public void doLoad() {
23	synchronized(this) {
24	if (isRunning == false) {
25	isRunning = true;
26
27	Thread t = new Thread( new DataLoadWorker(this), "SearchDataLoader");
28	t.start();
29	}
30	}
31	}
32
33	public boolean isRunning() {
34	synchronized(this) {
35	return isRunning;
36	}
37	}
38
39	protected void setRunningFalse() {
40	synchronized(this) {
41	isRunning = false;
42	}
43	}
44
45
46
47
48	public static class DataLoadWorker implements Runnable {
49	DataLoader loader;
50	public DataLoadWorker(DataLoader ld) {
51	this.loader = ld;
52	}
53
54
55	@Override
56	public void run() {
57
58
59	try {
60	AdressSearch search = new AdressSearch(loader.config);
61	search.buildSearchStructures();
62
63	AdressSearch oldSearch = (AdressSearch) loader.ctxt.getAttribute("search");
64	loader.ctxt.setAttribute("search", search);
65
66	if (oldSearch != null) {
67	oldSearch.clear();
68	}
69
70	} catch (SQLException e) {
71	System.out.println("Error loading data: " + e.getMessage());
72	} finally {
73	loader.setRunningFalse();
74	}
75
76	}
77
78
79	}
80
81	}