daoas/daoadresseservice/DataLoader.java

package dk.daoas.daoadresseservice;

import java.sql.SQLException;

import javax.servlet.ServletContext;

import dk.daoas.daoadresseservice.admin.ServiceConfig;
import dk.daoas.daoadresseservice.db.DatabaseLayerImplementation;

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