JSP页面查询显示常用模式 (附源代码)

背景：1．    需要将数据库查询结果在JSP中以列表方式显示2．    在一个良好的J2EE模式中数据库查询一般用DAO实现（Data Access Object）， JSP仅用于显示数据

问题：    通过JDBC ResultSet可获取查询结果（存在于数据库缓冲区内），但在Statement、Connection关闭后ResultSet即不可用。因此需要一种方式取出所有查询结果并传递至JSP页面。

解决方法一：    使用Value Object。将每条记录均封装成JavaBean对象，把这些对象装入Collection传送给JSP显示。这种方法的缺点是每一种查询都需要定义一个java class，并且将记录数据封装成java对象时也需要很多额外的代码。示例代码：

 

//查询数据代码   Connection conn = DBUtil.getConnection();   PreparedStatement pst = null;   ResultSet rs = null;   try{     String sql=“select emp_code, real_name from t_employee where organ_id=?”;     pst = conn.preparedStatement(sql);     pst.setString(1, “101”);     ResultSet rs = pst.executeQuery();     List list = new ArrayList();     Employee emp;     while (rs.next()){       emp = new Employee();       emp.setReakName(rs.getString(“real_name”));       emp.setEmpCode(rs.getString(“emp_code”));       …       list.add(emp);     }     return list;   }finally{     DBUtil.close(rs, pst ,conn);   }

 

//jsp显示部分代码 <%   List empList = (List)request.getAttribute(“empList”);   if (empList == null) empList = Collections.EMPTY_LIST; %> … <table  cellspacing="0" width=”90%”>     <tr>  <td>代码</td> <td>姓名</td>  </tr> <%   Employee emp;   for (int i=0; i< empList.size(); i++){     emp = (Employee) empList.get(i); %>     <tr>         <td><%= emp.getEmpCode()%></td>        <td><%= emp.getRealName()%></td>       </tr> <%   }// end for %> </table>

解决方法二：    遍历ResultSet取出所有数据封装进Collection。具体做法：1．    生成一个List对象(List list = new ArrayList() )。2．    生成一个Map对象(Map map = new HashMap() )。使用Map封装一行数据，key为各字段名，value为对应的值。(map.put(“USER_NAME”), rs.getString(“USER_NAME”))3．    将第2 步生成的Map对象装入第1步的list对象中(list.add(map) )。4．    重复2、3步直到ResultSet遍历完毕在DBUtil. resultSetToList(ResultSet rs)方法中实现了上述过程（所有列名均使用大写），可参考使用。

示例代码：

 

//查询数据部分代码：   …   Connection conn = DBUtil.getConnection();   PreparedStatement pst = null;   ResultSet rs = null;   try{     String sql=“select emp_code, real_name from t_employee where organ_id=?”;     pst = conn.preparedStatement(sql);     pst.setString(1, “101”);     rs = pst.executeQuery();     List list = DBUtil. resultSetToList(ResultSet rs);     return list;   }finally{     DBUtil.close(rs, pst ,conn);   }

 

 

//JSP显示部分代码 <%   List empList = (List)request.getAttribute(“empList”);   if (empList == null) empList = Collections.EMPTY_LIST; %> … <table  cellspacing="0" width=”90%”>     <tr>  <td>代码</td> <td>姓名</td>  </tr> <%   Map colMap;   for (int i=0; i< empList.size(); i++){     colMap = (Map) empList.get(i); %>   <tr>       <td><%=colMap.get(“EMP_CODE”)%></td>      <td><%=colMap.get(“REAL_NAME”)%></td>     </tr> <%   }// end for %> </table>

解决方法三：    使用RowSet。RowSet是JDBC2.0 中提供的接口,Oracle对该接口有相应实现，其中很有用的是oracle.jdbc.rowset.OracleCachedRowSet。  OracleCachedRowSet实现了ResultSet中的所有方法，但与ResultSet不同的是，OracleCachedRowSet 中的数据在Connection关闭后仍然有效。

oracle的rowset实现在http://otn.oracle.com/software/content.html的jdbc下载里有，名称是ocrs12.zip

示例代码：

//查询数据部分代码：   import javax.sql.RowSet;   import oracle.jdbc.rowset.OracleCachedRowSet;   …   Connection conn = DBUtil.getConnection();   PreparedStatement pst = null;   ResultSet rs = null;   try{……     String sql=“select emp_code, real_name from t_employee where organ_id=?”;     pst = conn.preparedStatement(sql);     pst.setString(1, “101”);     rs = pst.executeQuery();     OracleCachedRowSet ors = newOracleCachedRowSet();     //将ResultSet中的数据封装到RowSet中     ors.populate(rs);     return ors;   }finally{     DBUtil.close(rs, pst, conn);   }

 

//JSP显示部分代码 <%   javax.sql.RowSet empRS = (javax.sql.RowSet) request.getAttribute(“empRS”); %> … <table  cellspacing="0" width=”90%”>     <tr>  <td>代码</td> <td>姓名</td>  </tr> <%   if (empRS != null) while (empRS.next() ) { %>   <tr>       <td><%= empRS.get(“EMP_CODE”)%></td>      <td><%= empRS.get(“REAL_NAME”)%></td>     </tr> <%   }// end while %> </table>

适用场合：  方法一使用于定制的查询操作  方法二适用于多条查询语句或需要对查询结果进行处理的情况。  方法三适合于单条查询语句，适用于快速开发。

相关链接：    如果需要分页显示请参考：JSP分页技术实现    如果查询结果需要生成WORD或者EXCEL，请参考：使用jsp实现word、excel格式报表打印

附：DBUtil代码：

import java.util.List; import java.util.ArrayList; import java.util.Map; import java.util.HashMap; import java.util.Properties; import java.util.Collections;

import java.sql.Connection; import java.sql.SQLException; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.Statement; import java.sql.PreparedStatement;

import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException;

import javax.sql.DataSource;

public class DBUtil{

    private static final String JDBC_DATA_SOURCE = "java:comp/env/jdbc/DataSource";

    /**      enableLocalDebug: 是否在本地调试。<br>      值为true时如果查找数据源失败则使用DriverManager与数据库建立连接；      如果为false则只查找数据源建立数据库连接。      默认为false。<br>      可通过系统属性jdbc.enable_local_debug=true设置enableLocalDebug为true，启用本地调试：<br>      增加JVM parameter： -Djdbc.enable_local_debug=true      */     private static boolean enableLocalDebug = false;

    static{         enableLocalDebug = Boolean.getBoolean ("jdbc.enable_local_debug");     }

 

    private static Context ctx = null;     private static javax.sql.DataSource ds = null;

 

    private static void initDataSource() throws Exception{         // Put connection properties in to a hashtable.

 

        if (ctx == null) {             ctx = new InitialContext();         }         if (ds == null) {             ds = (javax.sql.DataSource) ctx.lookup(JDBC_DATA_SOURCE);         }     }        

    /**      * 查找应用服务器数据源，从数据源中获得数据库连接。<br><br>      * 在本地调试时如果查找数据源失败并且enableLocalDebug==true      * 则根据系统属性使用java.sql.DriverManager建立连接。<br>      * 本地调试时可配置的系统属性如下：<br>      * <p>      *     #jdbc驱动程序名 <br>      *     jdbc.driver=<i>oracle.jdbc.driver.OracleDriver</i> <br> <br>      *     #数据库连接串<br>      *     jdbc.url=<i>jdbc:oracle:thin:@10.1.1.1:1521:ocrl</i> <br> <br>      *     #数据库用户名<br>      *     jdbc.username=<i>scott</i> <br> <br>      *     #数据库用户密码<br>      *     jdbc.password=<i>tiger</i> <br>      * </p>      * 可通过JVM参数设置上述系统属性：<br>      * -Djdbc.driver=oracle.jdbc.driver.OracleDriver       *  -Djdbc.url=jdbc:oracle:thin:@10.1.1.1:1521:ocrl      *  -Djdbc.username=scott -Djdbc.password=tiger      * @return Connection      * @throws NamingException 如果数据源查找失败      * @throws SQLException 如果建立数据库连接失败      */     public static Connection getConnection() throws  SQLException{         try{             initDataSource();             return ds.getConnection();         }catch(SQLException sqle){             throw sqle;         }catch(Exception ne){             if (enableLocalDebug){                 return getTestConn();             }else{                 throw new RuntimeException(ne.toString());             }         }     }

 

    //通过DriverManager建立本地测试连接     private static Connection getTestConn(){       try {           String driver = System.getProperty("jdbc.driver");           System.out.println("jdbc.driver="+driver);

          String url = System.getProperty("jdbc.url");           System.out.println("jdbc.url="+url);

          String userName = System.getProperty("jdbc.username");           System.out.println("jdbc.username="+userName);

          String password = System.getProperty("jdbc.password");           System.out.println("jdbc.password="+password);

          Class.forName(driver).newInstance();           return java.sql.DriverManager.getConnection(url, userName, password);       }       catch (Exception ex) {         ex.printStackTrace();         throw new RuntimeException(ex.getMessage());       }     }

    /**      * 将查询结果封装成List。<br>      * List中元素类型为封装一行数据的Map，Map key为字段名（大写），value为相应字段值      * @param rs ResultSet      * @return List      * @throws java.sql.SQLException      */     public static List resultSetToList(ResultSet rs) throws java.sql.SQLException{         if (rs==null) return Collections.EMPTY_LIST;

        ResultSetMetaData md = rs.getMetaData();         int columnCount = md.getColumnCount();

        List list = new ArrayList();         Map rowData;         while (rs.next()){             rowData = new HashMap(columnCount);             for (int i=1; i<=columnCount; i++){                 rowData.put(md.getColumnName(i),rs.getObject(i));             }             list.add(rowData);         }         return list;     }

    /**      * 关闭ResultSet、Statement和Connection      * @param rs ResultSet to be closed      * @param stmt Statement or PreparedStatement  to be closed      * @param conn Connection  to be closed      */     public static void close(ResultSet rs, Statement stmt, Connection conn){             if (rs != null) try{                 rs.close();             }catch(java.sql.SQLException ex){                 ex.printStackTrace();             }             if (stmt != null) try{                  stmt.close();             }catch(java.sql.SQLException ex){                 ex.printStackTrace();             }             if (conn != null) try{                 conn.close();             }catch(java.sql.SQLException ex){                 ex.printStackTrace();             }     }

}// end of DBUti