www.pudn.com > ClientManager.rar > CbankDaoImpl.java

package com.dao; 
 
import java.util.List; 
import com.domain.CbankForm; 
import com.tool.JDBConnection; 
import com.tool.SQLCode; 
 
import java.sql.Connection; 
import java.sql.ResultSet; 
import java.sql.SQLException; 
import java.sql.Statement; 
import java.util.ArrayList; 
 
//对客户银行表的操作（tb_Client_bank） 
public class CbankDaoImpl 
    implements CbankDao { 
  //查询的操作 
  public List bankSelect() { 
    List list = new ArrayList(); 
    String sql = SQLCode.getSQLCode("sql.bank.select"); 
    CbankForm form = null; 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new CbankForm(); 
        form.setBank_id(rs.getString(1)); 
        form.setBank_name(rs.getString(2)); 
        form.setBank_bz(rs.getString(3)); 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    } 
//     
    return list; 
  } 
 
//删除的操作 
  public void bankDelete(CbankForm bank) { 
    String sql = SQLCode.getSQLCode("sql.bank.delete"); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_id()); 
    JDBConnection.executeUpdate(sql); 
//     
  } 
 
//修改操作 
  public void bankUpdate(CbankForm bank) { 
    String sql = SQLCode.getSQLCode("sql.bank.update"); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_name()); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_bz()); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_id()); 
    JDBConnection.executeUpdate(sql); 
//     
  } 
 
//插入的操作 
  public void bankInsert(CbankForm bank) { 
    String sql = SQLCode.getSQLCode("sql.bank.insert"); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_id()); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_name()); 
    sql = JDBConnection.editSqlCode(sql, bank.getBank_bz()); 
    JDBConnection.executeUpdate(sql); 
//     
 
  } 
 
//以数据库中的记录数，查找出多少记录计算,以便做帐号存贮 
  public int bankCountId() { 
    int iCount = 0; 
    String sql = SQLCode.getSQLCode("sql.bank.count"); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        CbankForm form = new CbankForm(); 
        iCount = rs.getInt("t"); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    }  
    return iCount + 1; 
  } 
 
//单独查询的操作 
  public CbankForm bankSelectOne(CbankForm bank) { 
     String sql = SQLCode.getSQLCode("sql.bank.selectOne"); 
     sql=JDBConnection.editSqlCode(sql,bank.getBank_id()); 
     CbankForm form = null; 
     Connection conn=null; 
     Statement stmt=null; 
     ResultSet rs = null; 
     try { 
       rs = JDBConnection.executeQuery(conn,stmt,sql); 
       while (rs.next()) { 
         form = new CbankForm(); 
         form.setBank_id(rs.getString(1)); 
         form.setBank_name(rs.getString(2)); 
         form.setBank_bz(rs.getString(3)); 
       } 
     } 
     catch (SQLException ex) { 
    	 ex.printStackTrace(); 
     }finally{ 
     	JDBConnection.close(rs,stmt,conn); 
     } 
//      
     return form; 
  } 
}