CbankDaoImpl.java
上传用户:quasar007
上传日期:2022-08-11
资源大小:4067k
文件大小:3k
源码类别:

企业管理

开发平台:

Java

  1. package com.dao;
  2. import java.util.List;
  3. import com.domain.CbankForm;
  4. import com.tool.JDBConnection;
  5. import com.tool.SQLCode;
  6. import java.sql.ResultSet;
  7. import java.sql.SQLException;
  8. import java.util.ArrayList;
  9. //对客户银行表的操作(tb_Client_bank)
  10. public class CbankDaoImpl
  11.     implements CbankDao {
  12.   private JDBConnection connection = new JDBConnection();
  13.   //查询的操作
  14.   public List bankSelect() {
  15.     List list = new ArrayList();
  16.     String sql = SQLCode.getSQLCode("sql.bank.select");
  17.     CbankForm form = null;
  18.     try {
  19.       ResultSet rs = connection.executeQuery(sql);
  20.       while (rs.next()) {
  21.         form = new CbankForm();
  22.         form.setBank_id(rs.getString(1));
  23.         form.setBank_name(rs.getString(2));
  24.         form.setBank_bz(rs.getString(3));
  25.         list.add(form);
  26.       }
  27.     }
  28.     catch (SQLException ex) {
  29.     }
  30.     connection.close();
  31.     return list;
  32.   }
  33. //删除的操作
  34.   public void bankDelete(CbankForm bank) {
  35.     String sql = SQLCode.getSQLCode("sql.bank.delete");
  36.     sql = connection.editSqlCode(sql, bank.getBank_id());
  37.     connection.executeUpdate(sql);
  38.     connection.close();
  39.   }
  40. //修改操作
  41.   public void bankUpdate(CbankForm bank) {
  42.     String sql = SQLCode.getSQLCode("sql.bank.update");
  43.     sql = connection.editSqlCode(sql, bank.getBank_name());
  44.     sql = connection.editSqlCode(sql, bank.getBank_bz());
  45.     sql = connection.editSqlCode(sql, bank.getBank_id());
  46.     connection.executeUpdate(sql);
  47.     connection.close();
  48.   }
  49. //插入的操作
  50.   public void bankInsert(CbankForm bank) {
  51.     String sql = SQLCode.getSQLCode("sql.bank.insert");
  52.     sql = connection.editSqlCode(sql, bank.getBank_id());
  53.     sql = connection.editSqlCode(sql, bank.getBank_name());
  54.     sql = connection.editSqlCode(sql, bank.getBank_bz());
  55.     connection.executeUpdate(sql);
  56.     connection.close();
  57.   }
  58. //以数据库中的记录数,查找出多少记录计算,以便做帐号存贮
  59.   public int bankCountId() {
  60.     int iCount = 0;
  61.     String sql = SQLCode.getSQLCode("sql.bank.count");
  62.     ResultSet rs = null;
  63.     try {
  64.       rs = connection.executeQuery(sql);
  65.       while (rs.next()) {
  66.         CbankForm form = new CbankForm();
  67.         iCount = rs.getInt("t");
  68.       }
  69.     }
  70.     catch (SQLException ex) {
  71.     }
  72.     connection.close();
  73.     return iCount + 1;
  74.   }
  75. //单独查询的操作
  76.   public CbankForm bankSelectOne(CbankForm bank) {
  77.      String sql = SQLCode.getSQLCode("sql.bank.selectOne");
  78.      sql=connection.editSqlCode(sql,bank.getBank_id());
  79.      CbankForm form = null;
  80.      try {
  81.        ResultSet rs = connection.executeQuery(sql);
  82.        while (rs.next()) {
  83.          form = new CbankForm();
  84.          form.setBank_id(rs.getString(1));
  85.          form.setBank_name(rs.getString(2));
  86.          form.setBank_bz(rs.getString(3));
  87.        }
  88.      }
  89.      catch (SQLException ex) {
  90.      }
  91.      connection.close();
  92.      return form;
  93.   }
  94. }