Go语言视频零基础入门到精通

javalearner

title: JSP页面查询显示常用模式

author: evan

email: evan_zhao@hotmail.com



  
  背景：
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 DBUtil


   
     
     
      
      

        
      

        
      
     
   
  
  


  



                        function TempSave(ElementID)
                        {
                                CommentsPersistDiv.setAttribute("CommentContent",document.getElementById(ElementID).value);
                                CommentsPersistDiv.save("CommentXMLStore");
                        }
                        function Restore(ElementID)
                        {
                                CommentsPersistDiv.load("CommentXMLStore");
                                document.getElementById(ElementID).value=CommentsPersistDiv.getAttribute("CommentContent");
                        }