java留言管理系统中模糊查询实例分享

1. package cn.mldn.lxh.note.dao.impl ; 
2.   
3. import java.sql.* ; 
4. import java.util.* ; 
5. import cn.mldn.lxh.note.vo.* ; 
6. import cn.mldn.lxh.note.dao.* ; 
7. import cn.mldn.lxh.note.dbc.* ; 
8.   
9. public class NoteDAOImpl implements NoteDAO 
10. { 
11.   // 增加操作 
12.   public void insert(Note note) throws Exception 
13.   { 
14.     String sql = "INSERT INTO note(id,title,author,content) VALUES(note_sequ.nextVal,?,?,?)" ; 
15.     PreparedStatement pstmt = null ; 
16.     DataBaseConnection dbc = null ; 
17.     dbc = new DataBaseConnection() ; 
18.     try 
19.     { 
20.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
21.       pstmt.setString(1,note.getTitle()) ; 
22.       pstmt.setString(2,note.getAuthor()) ; 
23.       pstmt.setString(3,note.getContent()) ; 
24.       pstmt.executeUpdate() ; 
25.       pstmt.close() ; 
26.     } 
27.     catch (Exception e) 
28.     { 
29.       // System.out.println(e) ; 
30.       throw new Exception("操作中出现错误！！！") ; 
31.     } 
32.     finally 
33.     { 
34.       dbc.close() ; 
35.     } 
36.   } 
37.   // 修改操作 
38.   public void update(Note note) throws Exception 
39.   { 
40.     String sql = "UPDATE note SET title=?,author=?,content=? WHERE id=?" ; 
41.     PreparedStatement pstmt = null ; 
42.     DataBaseConnection dbc = null ; 
43.     dbc = new DataBaseConnection() ; 
44.     try 
45.     { 
46.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
47.       pstmt.setString(1,note.getTitle()) ; 
48.       pstmt.setString(2,note.getAuthor()) ; 
49.       pstmt.setString(3,note.getContent()) ; 
50.       pstmt.setInt(4,note.getId()) ; 
51.       pstmt.executeUpdate() ; 
52.       pstmt.close() ; 
53.     } 
54.     catch (Exception e) 
55.     { 
56.       throw new Exception("操作中出现错误！！！") ; 
57.     } 
58.     finally 
59.     { 
60.       dbc.close() ; 
61.     } 
62.   } 
63.   // 删除操作 
64.   public void delete(int id) throws Exception 
65.   { 
66.     String sql = "DELETE FROM note WHERE id=?" ; 
67.     PreparedStatement pstmt = null ; 
68.     DataBaseConnection dbc = null ; 
69.     dbc = new DataBaseConnection() ; 
70.     try 
71.     { 
72.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
73.       pstmt.setInt(1,id) ; 
74.       pstmt.executeUpdate() ; 
75.       pstmt.close() ; 
76.     } 
77.     catch (Exception e) 
78.     { 
79.       throw new Exception("操作中出现错误！！！") ; 
80.     } 
81.     finally 
82.     { 
83.       dbc.close() ; 
84.     } 
85.   } 
86.   // 按ID查询，主要为更新使用 
87.   public Note queryById(int id) throws Exception 
88.   { 
89.     Note note = null ; 
90.     String sql = "SELECT id,title,author,content FROM note WHERE id=?" ; 
91.     PreparedStatement pstmt = null ; 
92.     DataBaseConnection dbc = null ; 
93.     dbc = new DataBaseConnection() ; 
94.     try 
95.     { 
96.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
97.       pstmt.setInt(1,id) ; 
98.       ResultSet rs = pstmt.executeQuery() ; 
99.       if(rs.next()) 
100.       { 
101.         note = new Note() ; 
102.         note.setId(rs.getInt(1)) ; 
103.         note.setTitle(rs.getString(2)) ; 
104.         note.setAuthor(rs.getString(3)) ; 
105.         note.setContent(rs.getString(4)) ; 
106.       } 
107.       rs.close() ; 
108.       pstmt.close() ; 
109.     } 
110.     catch (Exception e) 
111.     { 
112.       throw new Exception("操作中出现错误！！！") ; 
113.     } 
114.     finally 
115.     { 
116.       dbc.close() ; 
117.     } 
118.     return note ; 
119.   } 
120.   // 查询全部 
121.   public List queryAll() throws Exception 
122.   { 
123.     List all = new ArrayList() ; 
124.     String sql = "SELECT id,title,author,content FROM note" ; 
125.     PreparedStatement pstmt = null ; 
126.     DataBaseConnection dbc = null ; 
127.     dbc = new DataBaseConnection() ; 
128.     try 
129.     { 
130.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
131.       ResultSet rs = pstmt.executeQuery() ; 
132.       while(rs.next()) 
133.       { 
134.         Note note = new Note() ; 
135.         note.setId(rs.getInt(1)) ; 
136.         note.setTitle(rs.getString(2)) ; 
137.         note.setAuthor(rs.getString(3)) ; 
138.         note.setContent(rs.getString(4)) ; 
139.         all.add(note) ; 
140.       } 
141.       rs.close() ; 
142.       pstmt.close() ; 
143.     } 
144.     catch (Exception e) 
145.     { 
146.       System.out.println(e) ; 
147.       throw new Exception("操作中出现错误！！！") ; 
148.     } 
149.     finally 
150.     { 
151.       dbc.close() ; 
152.     } 
153.     return all ; 
154.   } 
155.   // 模糊查询 
156.   public List queryByLike(String cond) throws Exception 
157.   { 
158.     List all = new ArrayList() ; 
159.     String sql = "SELECT id,title,author,content FROM note WHERE title LIKE ? or AUTHOR LIKE ? or CONTENT LIKE ?" ;  
160.     PreparedStatement pstmt = null ; 
161.     DataBaseConnection dbc = null ; 
162.     dbc = new DataBaseConnection() ; 
163.     try 
164.     { 
165.       pstmt = dbc.getConnection().prepareStatement(sql) ; 
166.       pstmt.setString(1,"%"+cond+"%") ; 
167.       pstmt.setString(2,"%"+cond+"%") ; 
168.       pstmt.setString(3,"%"+cond+"%") ; 
169.       ResultSet rs = pstmt.executeQuery() ; 
170.       while(rs.next()) 
171.       { 
172.         Note note = new Note() ; 
173.         note.setId(rs.getInt(1)) ; 
174.         note.setTitle(rs.getString(2)) ; 
175.         note.setAuthor(rs.getString(3)) ; 
176.         note.setContent(rs.getString(4)) ; 
177.         all.add(note) ; 
178.       } 
179.       rs.close() ; 
180.       pstmt.close() ; 
181.     } 
182.     catch (Exception e) 
183.     { 
184.       System.out.println(e) ; 
185.       throw new Exception("操作中出现错误！！！") ; 
186.     } 
187.     finally 
188.     { 
189.       dbc.close() ; 
190.     } 
191.     return all ; 
192.   } 
193. }; 

1. package cn.mldn.lxh.note.servlet ; 
2.   
3. import java.io.* ; 
4. import javax.servlet.* ; 
5. import javax.servlet.http.* ; 
6. import cn.mldn.lxh.note.factory.* ; 
7. import cn.mldn.lxh.note.vo.* ; 
8.   
9. public class NoteServlet extends HttpServlet 
10. { 
11.   public void doGet(HttpServletRequest request,HttpServletResponse response) throws IOException,ServletException 
12.   { 
13.     this.doPost(request,response) ; 
14.   } 
15.   public void doPost(HttpServletRequest request,HttpServletResponse response) throws IOException,ServletException  
16.   { 
17.     request.setCharacterEncoding("GB2312") ; 
18.     String path = "errors.jsp" ; 
19.     // 接收要操作的参数值 
20.     String status = request.getParameter("status") ; 
21.     if(status!=null) 
22.     { 
23.       // 参数有内容，之后选择合适的方法 
24.       // 查询全部操作 
25.       if("selectall".equals(status)) 
26.       { 
27.         try 
28.         { 
29.           request.setAttribute("all",DAOFactory.getNoteDAOInstance().queryAll()) ; 
30.         } 
31.         catch (Exception e) 
32.         { 
33.         } 
34.         path = "list_notes.jsp" ; 
35.       } 
36.       // 插入操作 
37.       if("insert".equals(status)) 
38.       { 
39.         // 1、接收插入的信息 
40.         String title = request.getParameter("title") ; 
41.         String author = request.getParameter("author") ; 
42.         String content = request.getParameter("content") ; 
43.         // 2、实例化VO对象 
44.         Note note = new Note() ; 
45.         note.setTitle(title) ; 
46.         note.setAuthor(author) ; 
47.         note.setContent(content) ; 
48.         // 3、调用DAO完成数据库的插入操作 
49.         boolean flag = false ; 
50.         try 
51.         { 
52.           DAOFactory.getNoteDAOInstance().insert(note) ; 
53.           flag = true ; 
54.         } 
55.         catch (Exception e) 
56.         {} 
57.         request.setAttribute("flag",new Boolean(flag)) ; 
58.         path = "insert_do.jsp" ; 
59.       } 
60.       // 按ID查询操作，修改之前需要将数据先查询出来 
61.       if("selectid".equals(status)) 
62.       { 
63.         // 接收参数 
64.         int id = 0 ; 
65.         try 
66.         { 
67.           id = Integer.parseInt(request.getParameter("id")) ; 
68.         } 
69.         catch(Exception e) 
70.         {} 
71.         try 
72.         { 
73.           request.setAttribute("note",DAOFactory.getNoteDAOInstance().queryById(id)) ; 
74.         } 
75.         catch (Exception e) 
76.         { 
77.         }         
78.         path = "update.jsp" ; 
79.       } 
80.       // 更新操作 
81.       if("update".equals(status)) 
82.       { 
83.         int id = 0 ; 
84.         try 
85.         { 
86.           id = Integer.parseInt(request.getParameter("id")) ; 
87.         } 
88.         catch(Exception e) 
89.         {} 
90.         String title = request.getParameter("title") ; 
91.         String author = request.getParameter("author") ; 
92.         String content = request.getParameter("content") ; 
93.         Note note = new Note() ; 
94.         note.setId(id) ; 
95.         note.setTitle(title) ; 
96.         note.setAuthor(author) ; 
97.         note.setContent(content) ; 
98.         boolean flag = false ; 
99.         try 
100.         { 
101.           DAOFactory.getNoteDAOInstance().update(note) ; 
102.           flag = true ; 
103.         } 
104.         catch (Exception e) 
105.         {} 
106.         request.setAttribute("flag",new Boolean(flag)) ; 
107.         path = "update_do.jsp" ; 
108.       } 
109.       // 模糊查询 
110.       if("selectbylike".equals(status)) 
111.       { 
112.         String keyword = request.getParameter("keyword") ; 
113.         try 
114.         { 
115.           request.setAttribute("all",DAOFactory.getNoteDAOInstance().queryByLike(keyword)) ; 
116.         } 
117.         catch (Exception e) 
118.         { 
119.         } 
120.         path = "list_notes.jsp" ; 
121.       } 
122.       // 删除操作 
123.       if("delete".equals(status)) 
124.       { 
125.         // 接收参数 
126.         int id = 0 ; 
127.         try 
128.         { 
129.           id = Integer.parseInt(request.getParameter("id")) ; 
130.         } 
131.         catch(Exception e) 
132.         {} 
133.         boolean flag = false ; 
134.         try 
135.         { 
136.           DAOFactory.getNoteDAOInstance().delete(id) ; 
137.           flag = true ; 
138.         } 
139.         catch (Exception e) 
140.         {} 
141.         request.setAttribute("flag",new Boolean(flag)) ; 
142.         path = "delete_do.jsp" ; 
143.       } 
144.     } 
145.     else 
146.     { 
147.       // 则表示无参数，非法的客户请求 
148.     } 
149.     request.getRequestDispatcher(path).forward(request,response) ; 
150.   } 
151. }; 
152. /* 
153.  <servlet> 
154.   <servlet-name>note</servlet-name> 
155.   <servlet-class>cn.mldn.lxh.note.servlet.NoteServlet</servlet-class> 
156.  </servlet> 
157.  <servlet-mapping> 
158.   <servlet-name>note</servlet-name> 
159.   <url-pattern>/note/note_mvc/Note</url-pattern> 
160.  </servlet-mapping> 
161. */ 

1. <%@ page contentType="text/html;charset=gb2312"%> 
2. <%@ page import="java.util.*"%> 
3. <%@ page import="cn.mldn.lxh.note.vo.*"%> 
4. <html> 
5. <head> 
6.   <title>MVC+DAO 留言管理程序——登陆</title> 
7. </head> 
8. <body> 
9. <center> 
10.   <h1>留言管理范例 —— MVC + DAO实现</h1> 
11.   <hr> 
12.   <br> 
13.   <% 
14.     // 编码转换 
15.     request.setCharacterEncoding("GB2312") ; 
16.     if(session.getAttribute("uname")!=null) 
17.     { 
18.       // 用户已登陆 
19.   %> 
20.   <% 
21.     // 如果有内容，则修改变量i，如果没有，则根据i的值进行无内容提示 
22.     int i = 0 ; 
23.     String keyword = request.getParameter("keyword") ; 
24.     List all = null ; 
25.     all = (List)request.getAttribute("all") ; 
26.   %> 
27. <form action="Note" method="POST"> 
28.   请输入查询内容：<input type="text" name="keyword"> 
29.   <input type="hidden" name="status" value="selectbylike"> 
30.   <input type="submit" value="查询"> 
31. </form> 
32. </h3><a href="insert.jsp">添加新留言</a></h3> 
33. <table width="80%" border="1"> 
34.   <tr> 
35.     <td>留言ID</td> 
36.     <td>标题</td> 
37.     <td>作者</td> 
38.     <td>内容</td> 
39.     <td>删除</td> 
40.   </tr> 
41.   <% 
42.       Iterator iter = all.iterator() ; 
43.       while(iter.hasNext()) 
44.       { 
45.         Note note = (Note)iter.next() ; 
46.         i++ ; 
47.         // 进行循环打印，打印出所有的内容，以表格形式 
48.         // 从数据库中取出内容 
49.         int id = note.getId() ; 
50.         String title = note.getTitle() ; 
51.         String author = note.getAuthor() ; 
52.         String content = note.getContent() ; 
53.           
54.         // 因为要关键字返红，所以此处需要接收查询关键字 
55.         // String keyword = request.getParameter("keyword") ; 
56.         if(keyword!=null) 
57.         { 
58.           // 需要将数据返红 
59.           title = title.replaceAll(keyword,"<font color="red">"+keyword+"</font>")   
60.   
61. ; 
62.           author = author.replaceAll(keyword,"<font color="red">"+keyword 
63.   
64. +"</font>") ; 
65.           content = content.replaceAll(keyword,"<font color="red">"+keyword 
66.   
67. +"</font>") ; 
68.         } 
69.   %> 
70.         <tr> 
71.           <td><%=id%></td> 
72.           <td><a href="Note?id=<%=id%>&status=selectid"><%=title%></a></td> 
73.           <td><%=author%></td> 
74.           <td><%=content%></td> 
75.           <td><a href="Note?id=<%=id%>&status=delete">删除</a></td> 
76.         </tr> 
77.   <% 
78.       } 
79.       // 判断i的值是否改变，如果改变，则表示有内容，反之，无内容 
80.       if(i==0) 
81.         { 
82.       // 进行提示 
83.   %> 
84.         <tr> 
85.           <td colspan="5">没有任何内容！！！</td> 
86.         </tr> 
87.   <% 
88.       } 
89.   %> 
90. </table> 
91.   
92.   <% 
93.     } 
94.     else 
95.     { 
96.       // 用户未登陆，提示用户登陆，并跳转 
97.       response.setHeader("refresh","2;URL=login.jsp") ; 
98.   %> 
99.       您还未登陆，请先登陆！！！<br> 
100.       两秒后自动跳转到登陆窗口！！！<br> 
101.       如果没有跳转，请按<a href="login.jsp">这里</a>！！！<br> 
102.   <% 
103.     } 
104.   %> 
105. </center> 
106. </body> 
107. </html>