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 {
                        AddressSearch search = new AddressSearch(loader.config);
                        search.buildSearchStructures();
                        
                        AddressSearch oldSearch = (AddressSearch) 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	torben	2337	package dk.daoas.daoadresseservice;
2
3			import java.sql.SQLException;
4
5			import javax.servlet.ServletContext;
6
7	torben	2350	import dk.daoas.daoadresseservice.admin.ServiceConfig;
8
9	torben	2337	public class DataLoader {
10
11			boolean isRunning = false;
12
13	torben	2350	ServiceConfig config;
14
15	torben	2337	ServletContext ctxt;
16	torben	2351	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
17	torben	2337	this.ctxt = ctxt;
18	torben	2350
19	torben	2351	config = conf;
20	torben	2337	}
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	torben	2410	AddressSearch search = new AddressSearch(loader.config);
61	torben	2337	search.buildSearchStructures();
62
63	torben	2410	AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search");
64	torben	2337	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			}