标签:
/*DbPro.class*/ public transient Record findFirst(String sql, Object paras[]{ List result = find(sql, paras); return result.size() <= 0 ? null : (Record)result.get(0); } public transient List find(String sql, Object paras[]) { Connection conn = null; List list; try { conn = config.getConnection(); list = find(config, conn, sql, paras); } catch(Exception e) { throw new ActiveRecordException(e); } config.close(conn); return list; Exception exception; exception; config.close(conn); throw exception; } transient List find(Config config, Connection conn, String sql, Object paras[]) throws SQLException { PreparedStatement pst = conn.prepareStatement(sql); config.dialect.fillStatement(pst, paras); ResultSet rs = pst.executeQuery(); List result = RecordBuilder.build(config, rs); //返回List<Record> DbKit.closeQuietly(rs, pst); return result; } /*RecordBuilder.class *把一条记录对象封装Record对象 */ public static final List build(Config config, ResultSet rs) throws SQLException { List result = new ArrayList(); ResultSetMetaData rsmd = rs.getMetaData(); int columnCount = rsmd.getColumnCount(); String labelNames[] = new String[columnCount + 1]; int types[] = new int[columnCount + 1]; buildLabelNamesAndTypes(rsmd, labelNames, types); Record record; for(; rs.next(); result.add(record)) { record = new Record(); record.setColumnsMap(config.containerFactory.getColumnsMap()); Map columns = record.getColumns(); for(int i = 1; i <= columnCount; i++) { Object value; if(types[i] < 2004) value = rs.getObject(i); else if(types[i] == 2005) value = ModelBuilder.handleClob(rs.getClob(i)); else if(types[i] == 2011) value = ModelBuilder.handleClob(rs.getNClob(i)); else if(types[i] == 2004) value = ModelBuilder.handleBlob(rs.getBlob(i)); else value = rs.getObject(i); columns.put(labelNames[i], value); } } return result; }
标签:
原文地址:http://www.cnblogs.com/chenweichu/p/5946078.html