appl/data/SerializedDataLoader.java

package appl.data;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;

import de.appl.data.LoadingException;

/**
 * @author Dominik Appl
 */
public class SerializedDataLoader implements DataLoader {

        protected File loadFile;

        private boolean del_after_loading;

        private SerializedDataLoader() {
        }

        public SerializedDataLoader(File loadFile,
                        boolean DELETE_SOURCE_AFTER_LOADING) {
                this.loadFile = loadFile;
                del_after_loading = DELETE_SOURCE_AFTER_LOADING;
        }

        public SerializedDataLoader(File loadFile) {
                this(loadFile, false);
        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.data.DataLoader#load()
         */
        public Object load() throws LoadingException {
                Object loadedObject = null;
                try {
                        BufferedInputStream fis = new BufferedInputStream(
                                        new FileInputStream(loadFile));
                        ObjectInputStream ois = new ObjectInputStream(fis);
                        loadedObject = ois.readObject();
                        ois.close();
                        fis.close();
                        // remove File from Filesystem
                        if (del_after_loading)
                                loadFile.delete();

                } catch (FileNotFoundException e) {
                        throw new LoadingException("Could not find temporary unload-file:"
                                        + loadFile, loadFile);

                } catch (Exception e) {
                        e.printStackTrace();
                        throw new LoadingException("Could not load from temporary file "
                                        + loadFile, loadFile);

                }
                return loadedObject;

        }

        public static void SerializeToFile(Object o, File destFile)
                        throws LoadingException {
                try {
                        destFile.createNewFile();
                        BufferedOutputStream fos = new BufferedOutputStream(
                                        new FileOutputStream(destFile));
                        ObjectOutputStream oos = new ObjectOutputStream(fos);
                        oos.writeObject(o);
                        oos.close();
                        fos.close();
                } catch (Exception e) {
                        e.printStackTrace();
                }

        }

        /*
         * (non-Javadoc)
         * 
         * @see appl.data.DataLoader#getLoadInfo()
         */
        public String getLoadInfo() {
                return "SerializedDataLoader|" + loadFile.getPath();
        }

}
1	package appl.data;
2
3	import java.io.BufferedInputStream;
4	import java.io.BufferedOutputStream;
5	import java.io.File;
6	import java.io.FileInputStream;
7	import java.io.FileNotFoundException;
8	import java.io.FileOutputStream;
9	import java.io.ObjectInputStream;
10	import java.io.ObjectOutputStream;
11
12	import de.appl.data.LoadingException;
13
14	/**
15	* @author Dominik Appl
16	*/
17	public class SerializedDataLoader implements DataLoader {
18
19	protected File loadFile;
20
21	private boolean del_after_loading;
22
23	private SerializedDataLoader() {
24	}
25
26	public SerializedDataLoader(File loadFile,
27	boolean DELETE_SOURCE_AFTER_LOADING) {
28	this.loadFile = loadFile;
29	del_after_loading = DELETE_SOURCE_AFTER_LOADING;
30	}
31
32	public SerializedDataLoader(File loadFile) {
33	this(loadFile, false);
34	}
35
36	/*
37	* (non-Javadoc)
38	*
39	* @see appl.data.DataLoader#load()
40	*/
41	public Object load() throws LoadingException {
42	Object loadedObject = null;
43	try {
44	BufferedInputStream fis = new BufferedInputStream(
45	new FileInputStream(loadFile));
46	ObjectInputStream ois = new ObjectInputStream(fis);
47	loadedObject = ois.readObject();
48	ois.close();
49	fis.close();
50	// remove File from Filesystem
51	if (del_after_loading)
52	loadFile.delete();
53
54	} catch (FileNotFoundException e) {
55	throw new LoadingException("Could not find temporary unload-file:"
56	+ loadFile, loadFile);
57
58	} catch (Exception e) {
59	e.printStackTrace();
60	throw new LoadingException("Could not load from temporary file "
61	+ loadFile, loadFile);
62
63	}
64	return loadedObject;
65
66	}
67
68	public static void SerializeToFile(Object o, File destFile)
69	throws LoadingException {
70	try {
71	destFile.createNewFile();
72	BufferedOutputStream fos = new BufferedOutputStream(
73	new FileOutputStream(destFile));
74	ObjectOutputStream oos = new ObjectOutputStream(fos);
75	oos.writeObject(o);
76	oos.close();
77	fos.close();
78	} catch (Exception e) {
79	e.printStackTrace();
80	}
81
82	}
83
84	/*
85	* (non-Javadoc)
86	*
87	* @see appl.data.DataLoader#getLoadInfo()
88	*/
89	public String getLoadInfo() {
90	return "SerializedDataLoader\|" + loadFile.getPath();
91	}
92
93	}