JSP论坛完整版~~~~~~

package com.accp800.dao; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.util.ArrayList; import java.util.List; import com.microsoft.sqlserver.jdbc.SQLServerDriver; public class BasicDao<T> { public Connection getConnection() throws SQLException { DriverManager.registerDriver(new SQLServerDriver()); conn = DriverManager.getConnection(URL, USER, PASSWORD); return conn; } public long count(String sql, Object... args) throws SQLException { try { getConnection(); ResultSet rs = executeQuery(sql, args); if(rs.next()) { return rs.getLong(1); } return 0; } finally { close(); } } public T findById(String sql, RowMapper<T> mapper, Object id) throws SQLException { try { getConnection(); ResultSet rs = executeQuery(sql, id); if(rs.next()) { return mapper.mapRow(rs); } else { return null; } } finally { close(); } } public List<T> find(String sql, RowMapper<T> mapper, Object... args) throws SQLException { List<T> list = new ArrayList<T>(); try { getConnection(); ResultSet rs = executeQuery(sql, args); while(rs.next()) { list.add(mapper.mapRow(rs)); } return list; } finally { close(); } } public ResultSet executeQuery(String sql, Object... args) throws SQLException { setPreparedStatement(sql, args); return ps.executeQuery(); } public int executeUpdate(String sql, Object... args) throws SQLException { try { getConnection(); setPreparedStatement(sql, args); return ps.executeUpdate(); } finally { close(); } } private void setPreparedStatement(String sql, Object... args) throws SQLException { ps = conn.prepareStatement(sql); for(int i = 0; i < args.length; i++) { if(args[i] instanceof String) { ps.setString(i + 1, (String) args[i]); } else if(args[i] instanceof Integer) { ps.setInt(i + 1, (Integer) args[i]); } else if(args[i] instanceof Double) { ps.setDouble(i + 1, (Double) args[i]); } else if(args[i] instanceof Timestamp) { ps.setTimestamp(i + 1, (Timestamp) args[i]); } else { ps.setObject(i + 1, args[i]); } } } public void close() throws SQLException { if(conn != null) { conn.close(); } } private Connection conn; private PreparedStatement ps; public static final String DATABASE = "bbs"; public static final String USER = "sa"; public static final String PASSWORD = "123"; public static final String URL = "jdbc:sqlserver://localhost:1433;databaseName=" + DATABASE; }