/* ************************************************************************ * * * * Program Name : adlServ.java * * Author : Bing Xue * * Current Ver : Ver 0. Jan. 29 * * Ver 0.1 Feb. 5 * * Ver 0.2 Mar. 27 * * Maintenance Page : adlServ.readme * * * * ************************************************************************ */ import java.io.*; import java.net.*; import javax.servlet.*; import javax.servlet.http.*; import java.sql.*; public class saveAppServ extends GenericServlet { static PrintWriter out = null; // May. 5. static ServerSocket ssock = null; static Socket csock = null; public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException { System.out.println("enter the servlet saveAppServ"); String DrepIP = req.getParameter("DrepIP"); String DrepPort= req.getParameter("DrepPort"); String DrepDBA = req.getParameter("DrepDBA"); res.setContentType("text/html"); out = new PrintWriter(res.getOutputStream()); out.println(" adlServ Servlet Output "); out.println("

adlServlet output

"); out.println("

"); out.flush(); out.close(); try { ssock = new ServerSocket(5678); if (ssock == null ) { ssock = new ServerSocket(5678); } } catch (IOException e) {System.out.println("ERROR: new ServerSocket");} String str1 = ssock.toString(); System.out.println("Server socket is: " + str1); System.out.println(" listening."); try { csock = ssock.accept(); } catch (IOException e) { System.out.println("ERROR: accepting a connection."); } System.out.println(" The client is connected."); String str2 = csock.toString(); System.out.println("Client socket is: " + str2); DataInputStream ins = null; try { ins = new DataInputStream(csock.getInputStream()); } catch (IOException e) { System.out.println(" ERROR: get csocket's input stream"); } String userID, applID, astatement; int rs = 0; boolean succ = false; // connect and write to database VDCE ... try { Class.forName("COM.imaginary.sql.msql.MsqlDriver"); String url = "jdbc:msql://" + DrepIP + ":" + DrepPort + "/VDCE"; Connection con = DriverManager.getConnection(url, DrepDBA, ""); Statement sqlstmt = con.createStatement(); userID = ins.readLine(); for (int i = 0; i < 2; i ++) { astatement = ins.readLine(); System.out.println("S=" + astatement); rs = sqlstmt.executeUpdate(astatement); sqlstmt.close(); } // close database VDCE, con.close(); System.out.println("closed VDCE and be going to open VDCE_TABLES"); url = "jdbc:msql://" + DrepIP + ":" + DrepPort + "/VDCE_TABLES"; con = DriverManager.getConnection(url, DrepDBA, ""); sqlstmt = con.createStatement(); while ((astatement = ins.readLine()) != null) { System.out.println("S=" + astatement); rs = sqlstmt.executeUpdate(astatement); sqlstmt.close(); } con.close(); // close the connection to database VDCE_TABLES System.out.println("Now, the service done, exit"); } catch( Exception e ) { System.out.println(e.getMessage()); e.printStackTrace(); } ins.close(); } public String getServletInfo() { return " servlet for saveAppServ"; } }