转载

JSP页面查询显示的常用模式(1)

背景：

1.需要将数据库查询结果在JSP中以列表方式显示

2.在一个良好的J2EE模式中数据库查询一般用DAO实现（Data Access Object）， 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;
%>
…

  代码 姓名  
<%
Employee emp;
for (int i=0; i< empList.size(); i++){
emp = (Employee) empList.get(i);
%>

<%= emp.getEmpCode()%>
<%= emp.getRealName()%>

<%
}// end for
%>

内容导航

解决方法二：

遍历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;
%>
…

  代码 姓名  
<%
Map colMap;
for (int i=0; i< empList.size(); i++){
colMap = (Map) empList.get(i);
%>

<%=colMap.get(“EMP_CODE”)%>
<%=colMap.get(“REAL_NAME”)%>

<%
}// end for
%>

解决方法三：

使用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”);
%>
…

  代码 姓名  
<%
if (empRS != null) while (empRS.next() ) {
%>

<%= empRS.get(“EMP_CODE”)%>
<%= empRS.get(“REAL_NAME”)%>

<%
}// end while
%>

附：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: 是否在本地调试。

     值为true时如果查找数据源失败则使用DriverManager与数据库建立连接；
     如果为false则只查找数据源建立数据库连接。
     默认为false。

     可通过系统属性jdbc.enable_local_debug=true设置enableLocalDebug为true，启用本地调试：

     增加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);
        }
    }
    /**
     * 查找应用服务器数据源，从数据源中获得数据库连接。

     * 在本地调试时如果查找数据源失败并且enableLocalDebug==true
     * 则根据系统属性使用java.sql.DriverManager建立连接。

     * 本地调试时可配置的系统属性如下：

     * 

     *     #jdbc驱动程序名 

     *     jdbc.driver=oracle.jdbc.driver.OracleDriver 

     *     #数据库连接串

     *     jdbc.url=jdbc:oracle:thin:@10.1.1.1:1521:ocrl 

     *     #数据库用户名

     *     jdbc.username=scott 

     *     #数据库用户密码

     *     jdbc.password=tiger 

     * 

     * 可通过JVM参数设置上述系统属性：

     * -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。

     * 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