package test; import java.io.*; import java.net.*; import java.sql.*; import javax.servlet.*; import javax.servlet.http.*; public class TranServlet extends HttpServlet { private String _error = null; public void doGet( HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException { String url = "jdbc:postgresql:webdb"; String user = "postgres"; String password = "postgres"; Connection con = null; Statement stmt = null; ResultSet rs = null; String sql = null; String cname; String cemail; int slct = 0; String rtn = "../TranServlet.html"; String formFunct = req.getParameter("funct"); try { if(formFunct.equals("add")) slct = 1; if(formFunct.equals("upd")) slct = 2; if(formFunct.equals("del")) slct = 3; if(formFunct.equals("lst")) slct = 4; if(formFunct.equals("fnd")) slct = 5; String formCname = req.getParameter("username"); String formCemail = req.getParameter("formcemail"); Class.forName("postgresql.Driver"); con = DriverManager.getConnection(url, user, password); res.setContentType("text/html; charset=JIS"); PrintWriter out = res.getWriter(); out.println("ｅ−ｍａｉｌマスター保守"); out.println(""); out.println(""); out.println(""); out.println("

e-mail address maintenance


"); con.setAutoCommit(false); stmt = con.createStatement(); switch (slct) { case 5: out.println("

" + formFunct + " 結果

"); out.println("
"); out.println("
名前e-mail address"); rs = stmt.executeQuery( "select * from club_y where c_name = '" + formCname + "'"); while (rs.next()) { cname = rs.getString("c_name"); cemail = rs.getString("c_email"); out.println("
" + cname + "" + cemail);} out.println("


"); out.println("Return"); out.println("

"); rs.close(); stmt.close(); out.flush(); break; case 4: out.println("

" + formFunct + " 結果

"); out.println("
"); out.println("
名前e-mail address"); rs = stmt.executeQuery("select * from club_y"); while (rs.next()) { cname = rs.getString("c_name"); cemail = rs.getString("c_email"); out.println("
" + cname + "" + cemail);} out.println("


"); out.println("Return"); out.println("

"); rs.close(); stmt.close(); con.close(); out.close(); break; case 3: out.println("

" + formFunct + formCname + formCemail +" 結果

"); out.println("
"); out.println("
名前e-mail address"); stmt.executeUpdate( "delete from club_y where c_name = '"+ formCname +"'"); log("delete"); con.commit(); log("commit"); con.setAutoCommit(true); rs = stmt.executeQuery( "select c_name, c_email from club_y"); while (rs.next()) { cname = rs.getString("c_name"); cemail = rs.getString("c_email"); out.println("
" + cname + "" + cemail);} out.println("


"); out.println("Return"); out.println("

"); rs.close(); stmt.close(); con.close(); out.close(); break; case 2: out.println("

" + formFunct + formCname + formCemail +" 結果

"); out.println("
"); out.println("
名前e-mail address"); stmt.executeUpdate( "update club_y set c_email = '"+ formCemail + "' where c_name = '"+ formCname + "'"); log("update"); con.commit(); log("commit"); con.setAutoCommit(true); rs = stmt.executeQuery( "select * from club_y where c_name = '" + formCname + "'"); while (rs.next()) { cname = rs.getString("c_name"); cemail = rs.getString("c_email"); out.println("
" + cname + "" + cemail);} out.println("


"); out.println("Return"); out.println("

"); rs.close(); stmt.close(); con.close(); out.close(); break; case 1: out.println("

" + formFunct + formCname + formCemail +" 結果

"); out.println("
"); out.println("
名前(Be-mail address"); stmt.executeUpdate( "insert into club_y values('" + formCname + "','" + formCemail + "');"); log("insert"); con.commit(); log("commit"); con.setAutoCommit(true); rs = stmt.executeQuery( "select c_name, c_email from club_y"); while (rs.next()) { cname = rs.getString("c_name"); cemail = rs.getString("c_email"); out.println("
" + cname + "" + cemail);} out.println("


"); out.println("Return"); out.println("

"); rs.close(); stmt.close(); con.close(); out.close(); break; default: throw new SQLException("処理選択誤り: " + formFunct);} } catch (Exception e) { log(e.getMessage()); PrintWriter outerr = res.getWriter(); _error = "エラー: " + e; outerr.println(_error); outerr.println("

"); outerr.println("Return"); outerr.println("

"); outerr.close(); try { con.rollback(); log("rollback"); } catch (SQLException e2) { log(e2.getMessage()); } } finally { try { if (stmt != null) stmt.close(); if (rs != null) rs.close(); if (con != null) con.close(); } catch (SQLException e) { log(e.getMessage()); } } } public void doPost( HttpServletRequest req, HttpServletResponse res ) throws ServletException, IOException { doGet(req, res); } }