cbankdaoimpl.java

使用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;
  }
}