package com.dao;

import com.tool.SQLCode;
import java.util.List;
import com.domain.CqyzxForm;
import com.tool.JDBConnection;
import java.util.ArrayList;
import java.sql.ResultSet;
import java.sql.*;

//修改的操作
public class CqyzxDaoImpl
    implements CqyzxDao {
  public List qyzxSelect() {
    JDBConnection connection = new JDBConnection();
    List list = new ArrayList();
    String sql = SQLCode.getSQLCode("sql.qyzx.select");
    CqyzxForm form = null;
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new CqyzxForm();
        form.setQyzx_id(rs.getString(1));
        form.setQyzx_zxjb(rs.getString(2));
        form.setQyzx_bz(rs.getString(3));
        list.add(form);
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return list;
  }

//刪除的操作
  public void qyzxDelete(CqyzxForm qyzx) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.qyzx.delete");
    sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
    connection.executeUpdate(sql);
    connection.close();
  }

//單獨(dú)查詢
  public CqyzxForm qyzxSelectOne(CqyzxForm qyzx) {
    JDBConnection connection = new JDBConnection();
    CqyzxForm form = null;
    String sql = SQLCode.getSQLCode("sql.qyzx.selectOne");
    sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new CqyzxForm();
        form.setQyzx_id(rs.getString(1));
        form.setQyzx_zxjb(rs.getString(2));
        form.setQyzx_bz(rs.getString(3));
      }
    }
    catch (SQLException ex) {
    }
    return form;
  }

//修改操作
  public void qyzxUpdate(CqyzxForm qyzx) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.qyzx.update");
    sql = connection.editSqlCode(sql, qyzx.getQyzx_zxjb());
    sql = connection.editSqlCode(sql, qyzx.getQyzx_bz());
    sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
    connection.executeUpdate(sql);
    connection.close();
  }

//以數(shù)據(jù)庫(kù)中的記錄數(shù)，查找出多少記錄計(jì)算,以便做帳號(hào)存貯--
  public int qyzxCount() {
    int iCount = 0;
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.qyzx.count");
    ResultSet rs = null;
    try {
      rs = connection.executeQuery(sql);
      while (rs.next()) {
        CqyzxForm form = new CqyzxForm();
        iCount = rs.getInt("t");
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return iCount + 1;
  }

//插入操作
  public void qyzxInsert(CqyzxForm qyzx) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.qyzx.insert");
    sql = connection.editSqlCode(sql, qyzx.getQyzx_id());
    sql = connection.editSqlCode(sql, qyzx.getQyzx_zxjb());
    sql = connection.editSqlCode(sql, qyzx.getQyzx_bz());
    connection.executeUpdate(sql);
    connection.close();
  }
}