<%@ page contentType="text/html; charset=gb2312" %>
<html><head> <title>Input a Customer</title></head>
<body>
<% if(request.getAttribute("result")!=null)
out.print(request.getAttribute("result"));
%>
<h4>Please Input a Customer</h4>
<form action = "insertCustomer.do" method = "post">
<table>
<tr><td>瀹㈡埛鍚嶏細</td> <td><input type="text" name="custName" ></td></tr>
<tr><td>Email鍦板潃锛?lt;/td><td><input type="text" name="email"></td></tr>
<tr><td>鐢佃瘽锛?lt;/td><td><input type="text" name="phone" ></td></tr>
<tr><td><input type="submit" value="纭畾" ></td>
<td><input type="reset" value="閲嶇疆" ></td>
</tr>
</table>
</form>
</body></html>
package com.model;
import java.io.Serializable;
public class CustomerBean implements Serializable{
private String custName;
private String email;
private String phone;
public void setCustName(String custName){
this.custName = custName;
}
public void setEmail(String email) {
this.email = email;
}
public void setPhone(String phone) {
this.phone = phone;
}
public String getCustName(){
return this.custName;
}
public String getEmail() {
return this.email;
}
public String getPhone() {
return this.phone;
}
}
package com.model;
import java.sql.*;
import javax.sql.*;
import javax.naming.*;
import java.util.ArrayList;
import com.model.CustomerBean;
public class SampleDAO {
private static InitialContext context = null;
private DataSource dataSource = null;
private static final String SELECT_SQL = "SELECT * FROM customer";
private static final String GET_ONE_SQL = "SELECT custName,email,phone FROM customer WHERE custName=?";
private static final String INSERT_SQL = "INSERT INTO customer VALUES(?,?,?)";
private static final String DELETE_SQL = "DELETE FROM customer WHERE custName = ?";
private static final String UPDATE_SQL = "UPDATE customer SET email=? , phone=? WHERE custName=?";
public SampleDAO() {
try {
if (context == null) {
context = new InitialContext();
}
dataSource = (DataSource) context
.lookup("java:comp/env/jdbc/sampleDS");
} catch (NamingException e2) {
}
}
public Connection getConnection() {
Connection conn = null;
try {
conn = dataSource.getConnection();
} catch (SQLException e) {
}
return conn;
}
// 鏌ヨ鎵€鏈夊鎴蜂俊鎭?
public ArrayList<CustomerBean> selectCustomer() {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rst = null;
CustomerBean customer = new CustomerBean();
ArrayList<CustomerBean> custList = new ArrayList<CustomerBean>();
try {
conn = dataSource.getConnection();
pstmt = conn.prepareStatement(SELECT_SQL);
rst = pstmt.executeQuery();
while (rst.next()) {
customer.setCustName(rst.getString("custName"));
customer.setEmail(rst.getString("email"));
customer.setPhone(rst.getString("phone"));
custList.add(customer);
}
pstmt.close();
return custList;
} catch (SQLException se) {
return null;
} finally {
try {
conn.close();
} catch (SQLException se) {
}
}
}
// 鎻掑叆涓€鏉″鎴疯褰?
public boolean insertCustomer(CustomerBean customer) {
Connection conn = null;
PreparedStatement pstmt = null;
System.out.println("Inner");
try {
conn = dataSource.getConnection();
if (conn == null || dataSource == null)
System.out.println("Hi");
pstmt = conn.prepareStatement(INSERT_SQL);
System.out.println(dataSource);
if (pstmt == null)
System.out.println("Here");
else
System.out.println("pstmt:" + pstmt);
pstmt.setString(1, customer.getCustName());
pstmt.setString(2, customer.getEmail());
pstmt.setString(3, customer.getPhone());
System.out.println("There");
pstmt.executeUpdate();
pstmt.close();
return true;
} catch (SQLException se) {
System.out.println("se" + se);
return false;
} finally {
try {
conn.close();
} catch (SQLException se) {
}
}
}
// 鎸夊鍚嶆绱㈠鎴疯褰?
public CustomerBean searchCustomer(String custName) {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rst = null;
CustomerBean customer = new CustomerBean();
try {
conn = dataSource.getConnection();
pstmt = conn.prepareStatement(GET_ONE_SQL);
pstmt.setString(1, custName);
rst = pstmt.executeQuery();
if (rst.next()) {
customer.setCustName(rst.getString("custName"));
customer.setEmail(rst.getString("email"));
customer.setPhone(rst.getString("phone"));
}
rst.close();
pstmt.close();
} catch (SQLException se) {
return null;
} finally {
try {
conn.close();
} catch (SQLException se) {
}
}
return customer;
}
// 鎸夊鍚嶅垹闄ゅ鎴疯褰?
public boolean deleteCustomer(String custName) {
Connection conn = null;
PreparedStatement pstmt = null;
try {
conn = dataSource.getConnection();
pstmt = conn.prepareStatement(DELETE_SQL);
pstmt.setString(1, custName);
pstmt.executeUpdate();
pstmt.close();
} catch (SQLException se) {
return false;
} finally {
try {
conn.close();
} catch (SQLException se) {
}
}
return true;
}
}
package com.control;
import java.io.*;
import java.sql.*;
import java.util.ArrayList;
import javax.servlet.*;
import javax.servlet.http.*;
import com.model.CustomerBean;
import com.model.SampleDAO;
public class InsertCustomerServlet extends HttpServlet {
public void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html;charset=gb2312");
SampleDAO dao = new SampleDAO();
CustomerBean customer = new CustomerBean();
String message = null;
try {
customer.setCustName(request.getParameter("custName"));
customer.setEmail(request.getParameter("email"));
customer.setPhone(request.getParameter("phone"));
System.out.println("Hello");
boolean success = dao.insertCustomer(customer);
if (success) {
message = "<li>鎴愬姛鎻掑叆涓€鏉¤褰曪紒</li>";
} else {
System.out.println(customer.getCustName());
message = "<li>鎻掑叆璁板綍閿欒锛?lt;/li>";
}
} catch (Exception e) {
message = "<li>鎻掑叆璁板綍閿欒锛?lt;/li>";
}
request.setAttribute("result", message);
RequestDispatcher view = getServletContext().getRequestDispatcher(
"/insertCustomer.jsp");
view.forward(request, response);
}
}
<?xml version="1.0" encoding="utf-8"?>
<Context reloadable = "true">
<Resource
name="jdbc/sampleDS"
type="javax.sql.DataSource"
maxActive="4"
maxIdle="2"
username="customr"
maxWait="5000"
driverClassName="org.postgresql.Driver"
password="customer"
url="jdbc:postgresql://localhost:5432/customer"/>
</Context>
2 涓В鍐虫柟妗?/h2>
#1
浣犺鍢庡搱鍟?
#2
灏辨槸璇达紝涓轰粈涔堜細鍑虹幇se org.postgresql.util.PSQLException:ERROR:relation does not exist杩欐牱鐨勯棶棰樺憖锛?
#1
浣犺鍢庡搱鍟?
#2
灏辨槸璇达紝涓轰粈涔堜細鍑虹幇se org.postgresql.util.PSQLException:ERROR:relation does not exist杩欐牱鐨勯棶棰樺憖锛?
#1
浣犺鍢庡搱鍟?
#2
灏辨槸璇达紝涓轰粈涔堜細鍑虹幇se org.postgresql.util.PSQLException:ERROR:relation does not exist杩欐牱鐨勯棶棰樺憖锛?