dz_model-1.1 源码

package PACKAGE_NAME.dao.JdbcImpl; import java.sql.Connection; import java.util.List; import java.util.ArrayList; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import PACKAGE_NAME.utils.JdbcUtils; import PACKAGE_NAME.dao.CLASS_NAMEDao; import PACKAGE_NAME.domain.CLASS_NAME; public class CLASS_NAMEDaoJdbcImpl implements CLASS_NAMEDao { public void add(CLASS_NAME CLASS_PARAMETER) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = JdbcUtils.getConnection(); String sql = "insert into TABLE_NAME (COLUMN_NAMES) " + "values (COLUMN_?S)"; ps = conn.prepareStatement(sql); PS_SETS ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } } public void delete(PK_PARAMETER) { Connection conn = null; ResultSet rs = null; PreparedStatement ps = null; try { conn = JdbcUtils.getConnection(); String sql = "delete from TABLE_NAME where PKCOLUMNS_S"; ps = conn.prepareStatement(sql); PK_PS_SETS ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } } public void update(CLASS_NAME CLASS_PARAMETER) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; try { conn = JdbcUtils.getConnection(); String sql = "update from TABLE_NAME set COLUMN_PARAMETERS"; ps = conn.prepareStatement(sql); PS_SETS ps.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } } public CLASS_NAME getCLASS_NAME(PK_PARAMETER) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; CLASS_NAME CLASS_PARAMETER = null; try { conn = JdbcUtils.getConnection(); String sql = "select * from TABLE_NAME where PK_COLUMNS"; ps = conn.prepareStatement(sql); PK_PS_SETS rs = ps.executeQuery(); while (rs.next()) { CLASS_PARAMETER = mappingCLASS_NAME(rs); } } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } return CLASS_PARAMETER; } public List<CLASS_NAME> getAllCLASS_NAME(int pageNo, int pageSize) { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; List<CLASS_NAME> CLASS_PARAMETERs = null; try { CLASS_PARAMETERs = new ArrayList<CLASS_NAME>(); conn = JdbcUtils.getConnection(); String sql = "select * from TABLE_NAME limit ?, ?"; ps = conn.prepareStatement(sql); PAGE_SETS rs = ps.executeQuery(); while (rs.next()) { CLASS_NAME CLASS_PARAMETER = new CLASS_NAME(); CLASS_PARAMETER = mappingCLASS_NAME(rs); CLASS_PARAMETERs.add(CLASS_PARAMETER); } } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } return CLASS_PARAMETERs; } public int getCLASS_NAMECount() { Connection conn = null; PreparedStatement ps = null; ResultSet rs = null; int count = 0; try { conn = JdbcUtils.getConnection(); String sql = "select count(*) from TABLE_NAME"; ps = conn.prepareStatement(sql); rs = ps.executeQuery(); while (rs.next()) { count = rs.getInt(1); } } catch (SQLException e) { e.printStackTrace(); } finally { JdbcUtils.free(conn, ps, rs); } return count; } private CLASS_NAME mappingCLASS_NAME(ResultSet rs) throws SQLException { CLASS_NAME CLASS_PARAMETER = new CLASS_NAME(); RS_GETS return CLASS_PARAMETER; } }