gmatou/dataupload/DataReceiver.java

package com.grundfos.gmatou.dataupload;

import com.oreilly.servlet.multipart.*;

import java.sql.*;
import java.io.*;
import java.util.*;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

/**
 * Servlet implementation class DataReceiver
 */
public class DataReceiver extends HttpServlet {
        private static final long serialVersionUID = 1L;

        /**
         * @see HttpServlet#HttpServlet()
         */
        public DataReceiver() {
                super();
        }

        private static final int SIZE = 10000000; 

        private Map<String,String> getParts(HttpServletRequest request) throws ServletException {
                Map<String,String> response = new HashMap<String,String>();
                try {
                        MultipartParser parser = new MultipartParser(request, SIZE);

                        Part part = null;
                        while ((part = parser.readNextPart()) != null) {

                                if (part.getName().equals("data")) {
                                        FilePart image = (FilePart) part;

                                        InputStream is = image.getInputStream();

                                        BufferedReader reader = new BufferedReader(
                                                        new InputStreamReader(is));
                                        StringBuilder sb = new StringBuilder();

                                        String line;
                                        while ((line = reader.readLine()) != null) {
                                                sb.append(line + "\n");
                                        }
                                        
                                        reader.close();
                                        is.close();
                                        
                                        response.put("data", sb.toString());
                                } else if (part.getName().equals("device")) {
                                        ParamPart pp = (ParamPart) part;
                                        response.put("device", pp.getStringValue());
                                }
                        }// while
                } catch (Exception e) {
                        throw new ServletException(e);
                }
                return response;
        }

        protected void doPost(HttpServletRequest request,
                        HttpServletResponse response) throws ServletException, IOException {
                Map<String,String> parts = getParts(request);
                
                String device = parts.get("device");
                String data = parts.get("data");
                

                if (device == null || data == null)
                        throw new ServletException("insufficient data");

                try {
                        Connection conn = DBConnection.getDbConnection();
                        PreparedStatement stmt = conn.prepareStatement("INSERT INTO dataentries (date,device,data) VALUES (now(), ?,?)");
                        stmt.setString(1, device);
                        stmt.setString(2, data);
                        stmt.execute();

                        stmt.close();
                        conn.close();

                } catch (Exception e) {
                        throw new ServletException(e);
                }
        }
}
1	package com.grundfos.gmatou.dataupload;
2
3	import com.oreilly.servlet.multipart.*;
4
5	import java.sql.*;
6	import java.io.*;
7	import java.util.*;
8	import javax.servlet.ServletException;
9	import javax.servlet.http.HttpServlet;
10	import javax.servlet.http.HttpServletRequest;
11	import javax.servlet.http.HttpServletResponse;
12
13	/**
14	* Servlet implementation class DataReceiver
15	*/
16	public class DataReceiver extends HttpServlet {
17	private static final long serialVersionUID = 1L;
18
19	/**
20	* @see HttpServlet#HttpServlet()
21	*/
22	public DataReceiver() {
23	super();
24	}
25
26	private static final int SIZE = 10000000;
27
28	private Map<String,String> getParts(HttpServletRequest request) throws ServletException {
29	Map<String,String> response = new HashMap<String,String>();
30	try {
31	MultipartParser parser = new MultipartParser(request, SIZE);
32
33	Part part = null;
34	while ((part = parser.readNextPart()) != null) {
35
36	if (part.getName().equals("data")) {
37	FilePart image = (FilePart) part;
38
39	InputStream is = image.getInputStream();
40
41	BufferedReader reader = new BufferedReader(
42	new InputStreamReader(is));
43	StringBuilder sb = new StringBuilder();
44
45	String line;
46	while ((line = reader.readLine()) != null) {
47	sb.append(line + "\n");
48	}
49
50	reader.close();
51	is.close();
52
53	response.put("data", sb.toString());
54	} else if (part.getName().equals("device")) {
55	ParamPart pp = (ParamPart) part;
56	response.put("device", pp.getStringValue());
57	}
58	}// while
59	} catch (Exception e) {
60	throw new ServletException(e);
61	}
62	return response;
63	}
64
65	protected void doPost(HttpServletRequest request,
66	HttpServletResponse response) throws ServletException, IOException {
67	Map<String,String> parts = getParts(request);
68
69	String device = parts.get("device");
70	String data = parts.get("data");
71
72
73	if (device == null \|\| data == null)
74	throw new ServletException("insufficient data");
75
76	try {
77	Connection conn = DBConnection.getDbConnection();
78	PreparedStatement stmt = conn.prepareStatement("INSERT INTO dataentries (date,device,data) VALUES (now(), ?,?)");
79	stmt.setString(1, device);
80	stmt.setString(2, data);
81	stmt.execute();
82
83	stmt.close();
84	conn.close();
85
86	} catch (Exception e) {
87	throw new ServletException(e);
88	}
89	}
90	}