package com.dao;

import com.tool.JDBConnection;
import java.util.*;
import com.domain.BankVO;
import java.sql.*;
//對銀行信息的操作
public class BankDao {
  private JDBConnection connection = null;
  public BankDao() {
    connection = new JDBConnection();
    this.connection.creatConnection(); //利用構(gòu)造方法調(diào)用類中的對象對數(shù)據(jù)庫創(chuàng)建連接
  }

//查詢所有銀行的信息
  public List bankSelect() {
    List list = new ArrayList();
    BankVO bank = null;
    String sql = "select * from tb_bank order by id";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        bank = new BankVO();
        bank.setId(Integer.valueOf(rs.getString(1)));
        bank.setBank_number(rs.getString(2));
        bank.setBank_name(rs.getString(3));
        bank.setBank_remark(rs.getString(4));
        list.add(bank);
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return list;
  }

  //以數(shù)據(jù)庫流水號(hào)為條件查詢銀行信息
  public BankVO BankSelectOne(String number) {
    BankVO bank = null;
    String sql = "select * from tb_bank where bank_number='" + number + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        bank = new BankVO();
        bank.setId(Integer.valueOf(rs.getString(1)));
        bank.setBank_number(rs.getString(2));
        bank.setBank_name(rs.getString(3));
        bank.setBank_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return bank;
  }
  //銀行名稱為條件查詢銀行信息
  public BankVO BankSelectName(String name) {
    BankVO bank = null;
    String sql = "select * from tb_bank where bank_name='" + name + "'";
    ResultSet rs = connection.executeQuery(sql);
    try {
      while (rs.next()) {
        bank = new BankVO();
        bank.setId(Integer.valueOf(rs.getString(1)));
        bank.setBank_number(rs.getString(2));
        bank.setBank_name(rs.getString(3));
        bank.setBank_remark(rs.getString(4));
      }
    }
    catch (SQLException ex) {
    }
    connection.closeConnection();
    return bank;
  }

  //刪除銀行信息
  public void bankDelete(Integer id) {
    String sql = "delete from tb_bank where id='" + id + "'";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//添加銀行信息
  public void bankInsert(BankVO vo) {
    String sql = "insert into tb_bank values ('" + vo.getBank_number() + "','" +
        vo.getBank_name() + "','" + vo.getBank_remark() + "')";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//修改銀行信息
  public void bankUpdate(BankVO vo) {
    String sql =
        "update tb_bank set bank_name='" + vo.getBank_name() +
        "',bank_remark='" +
        vo.getBank_remark() + "' where id=" + vo.getId() + "";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

//修改銀行編號(hào)
  public void bankUpdateNumber(String number,Integer id) {
    String sql =
        "update tb_bank set bank_number='" + number +
        "' where id=" + id + "";
    connection.executeUpdate(sql);
    connection.closeConnection();
  }

}