?? bookcarddao.java
字號:
package com.sxit.wap.bookcard;import java.sql.*;import java.util.*;import com.sxit.wap.common.*;import com.sxit.wap.exception.*;public class BookCardDao { public static String tableName = "WAP_BOOK_CARD"; public static BookCardModel insert(BookCardModel model) throws SysException,UpdateException,AppException { if (!BookCardBean.isValidData(model)) { Debug.println(model.toString() + "\n" + "Illegal data values for insert"); throw new AppException("Illegal data values for insert"); } String sql = getInsertSQL(model); Connection dbConnection = null; Statement stmt = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in INSERT !! resultCount = " + resultCount); throw new UpdateException("ERROR in INSERT !! resultCount = " + resultCount); } return model; } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute insert method :\n" + e); throw new SysException("SQLException while execute insert method :\n" + e); } finally { closeStatement(stmt); closeConnection(dbConnection); } } public static BookCardModel insert(BookCardModel model, Connection dbConnection) throws SysException,UpdateException,AppException { if (!BookCardBean.isValidData(model)) { Debug.println(model.toString() + "\n" + "Illegal data values for insert"); throw new AppException("Illegal data values for insert"); } String sql = getInsertSQL(model); Statement stmt = null; try { stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in INSERT !! resultCount = " + resultCount); throw new UpdateException("ERROR in INSERT !! resultCount = " + resultCount); } return model; } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute insert method :\n" + e); throw new SysException("SQLException while execute insert method :\n" + e); } finally { closeStatement(stmt); } } public static BookCardModel update(BookCardModel model) throws SysException,UpdateException,AppException { if (!BookCardBean.isValidData(model)) { Debug.println(model.toString() + "\n" + "Illegal data values for update"); throw new AppException("Illegal data values for update"); } String sql = getUpdateSQL(model); Connection dbConnection = null; Statement stmt = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in UPDATE !! resultCount = " + resultCount); throw new UpdateException("ERROR in UPDATE !! resultCount = " + resultCount); } return model; } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute update mothod :\n" + e); throw new SysException("SQLException while execute update mothod :\n" + e); } finally { closeStatement(stmt); closeConnection(dbConnection); } } public static BookCardModel update(BookCardModel model, Connection dbConnection) throws SysException,UpdateException,AppException { if (!BookCardBean.isValidData(model)) { Debug.println(model.toString() + "\n" + "Illegal data values for update"); throw new AppException("Illegal data values for update"); } String sql = getUpdateSQL(model); Statement stmt = null; try { stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in UPDATE !! resultCount = " + resultCount); throw new UpdateException("ERROR in UPDATE !! resultCount = " + resultCount); } return model; } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute update mothod :\n" + e); throw new SysException("SQLException while execute update mothod :\n" + e); } finally { closeStatement(stmt); } } public static void delete(long id) throws SysException,UpdateException,AppException { String sql = getDeleteSQL(id); Connection dbConnection = null; Statement stmt = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount); throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount); } } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e); throw new SysException("SQLException while execute delete mothod :\n" + e); } finally { closeStatement(stmt); closeConnection(dbConnection); } } public static void delete(long id, Connection dbConnection) throws SysException,UpdateException,AppException { String sql = getDeleteSQL(id); Statement stmt = null; try { stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != 1 ) { Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount); throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount); } } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e); throw new SysException("SQLException while execute delete mothod :\n" + e); } finally { closeStatement(stmt); } } public static void delete(long[] ids) throws SysException,UpdateException,AppException { String sql = getDeleteSQL(ids); Connection dbConnection = null; Statement stmt = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != ids.length ) { Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount); throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount); } } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e); throw new SysException("SQLException while execute delete mothod :\n" + e); } finally { closeStatement(stmt); closeConnection(dbConnection); } } public static void delete(long[] ids, Connection dbConnection) throws SysException,UpdateException,AppException { String sql = getDeleteSQL(ids); Statement stmt = null; try { stmt = dbConnection.createStatement(); int resultCount = stmt.executeUpdate(sql); if ( resultCount != ids.length ) { Debug.println(sql + "\n" + "ERROR in DELETE !! resultCount = " + resultCount); throw new UpdateException("ERROR in DELETE !! resultCount = " + resultCount); } } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute delete mothod :\n" + e); throw new SysException("SQLException while execute delete mothod :\n" + e); } finally { closeStatement(stmt); } } public static BookCardModel findByPK(long id) throws SysException,FinderException { String sql = getFindByPKSQL(id); Connection dbConnection = null; Statement stmt = null; ResultSet rs = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); rs = stmt.executeQuery(sql); if ( !rs.next() ) { Debug.println(sql + "\n" + "No record for primary key " + id); throw new FinderException("No record for primary key " + id); } BookCardModel model = new BookCardModel(); model.setId(rs.getLong("ID")); model.setUserMdn(Function.readDBEncode(rs.getString("USER_MDN"))); model.setUserName(Function.readDBEncode(rs.getString("USER_NAME"))); model.setUserJob(Function.readDBEncode(rs.getString("USER_JOB"))); model.setUserCom(Function.readDBEncode(rs.getString("USER_COM"))); model.setUserTel(Function.readDBEncode(rs.getString("USER_TEL"))); model.setUserFax(Function.readDBEncode(rs.getString("USER_FAX"))); model.setUserEmail(Function.readDBEncode(rs.getString("USER_EMAIL"))); model.setUserAdress(Function.readDBEncode(rs.getString("USER_ADRESS"))); model.setUserPost(Function.readDBEncode(rs.getString("USER_POST"))); return model; } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute findByPK mothod :\n" + e); throw new SysException("SQLException while execute findByPK mothod :\n" + e); } finally { closeResultSet(rs); closeStatement(stmt); closeConnection(dbConnection); } } public static int updateBySql(String sql) throws SysException { Connection dbConnection = null; Statement stmt = null; try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); return stmt.executeUpdate(sql); } catch(SQLException e) { Debug.println(sql + "\n" + "SQLException while execute updateBySql mothod :\n" + e); throw new SysException("SQLException while execute updateBySql mothod :\n" + e); } finally { closeStatement(stmt); closeConnection(dbConnection); } } public static int updateBySql(String sql, Connection dbConnection) throws SysException { Statement stmt = null; try { stmt = dbConnection.createStatement(); return stmt.executeUpdate(sql); } catch(SQLException e) { Debug.println(sql + "\nSQLException while execute updateBySql mothod :\n" + e); throw new SysException("SQLException while execute updateBySql mothod :\n" + e); } finally { closeStatement(stmt); } } public static Collection queryBySql(String sql) throws SysException { Connection dbConnection = null; Statement stmt = null; ResultSet rs = null; ArrayList list = new ArrayList(); try { dbConnection = getDBConnection(); stmt = dbConnection.createStatement(); rs = stmt.executeQuery(sql); ResultSetMetaData rsmd = rs.getMetaData(); while ( rs.next() ) { Hashtable element = new Hashtable(); for (int i = 1; i <= rsmd.getColumnCount(); i++) { String columnName = rsmd.getColumnName(i); String fieldName = Function.format(columnName); String fieldType = ColumnType.getFieldType(Database.dbType, rsmd, i); if (fieldType == null) continue; if ("Timestamp".equals(fieldType)) { element.put(fieldName, rs.getTimestamp(columnName)); } else if ("String".equals(fieldType)) { String value = Function.readDBEncode(rs.getString(columnName)); if (value == null) value = ""; element.put(fieldName, value); } else if ("int".equals(fieldType)) { element.put(fieldName, String.valueOf(rs.getInt(columnName))); } else if ("long".equals(fieldType)) { element.put(fieldName, String.valueOf(rs.getLong(columnName)));
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -