背景：
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; %> …
| 代码 | 姓名 |
| <%= emp.getEmpCode()%> | <%= emp.getRealName()%> |
//查询数据部分代码： … 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; %> …
| 代码 | 姓名 |
| <%=colMap.get(“EMP_CODE”)%> | <%=colMap.get(“REAL_NAME”)%> |
//查询数据部分代码： 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”); %> …
| 代码 | 姓名 |
| <%= empRS.get(“EMP_CODE”)%> | <%= empRS.get(“REAL_NAME”)%> |
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