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

企业管理

开发平台:

Java

  1. package com.dao;
  2. import com.tool.SQLCode;
  3. import java.util.List;
  4. import com.domain.CkhjbForm;
  5. import com.tool.JDBConnection;
  6. import java.util.ArrayList;
  7. import java.sql.SQLException;
  8. import java.sql.ResultSet;
  9. //对客户级别表的操作(tb_Client_khjb)
  10. public class CkhjgDaoImpl
  11.     implements CkhjgDao {
  12. //查询操作
  13.   public List khjgSelect() {
  14.     JDBConnection connection = new JDBConnection();
  15.     List list = new ArrayList();
  16.     CkhjbForm form = null;
  17.     String sql = SQLCode.getSQLCode("sql.khjb.select");
  18.     try {
  19.       ResultSet rs = connection.executeQuery(sql);
  20.       while (rs.next()) {
  21.         form = new CkhjbForm();
  22.         form.setKhjb_id(rs.getString(1));
  23.         form.setKhjb_jbmc(rs.getString(2));
  24.         form.setKhjb_zdyml(Float.valueOf(rs.getString(3)));
  25.         form.setKhjb_bz(rs.getString(4));
  26.         list.add(form);
  27.       }
  28.     }
  29.     catch (SQLException ex) {
  30.     }
  31.     connection.close();
  32.     return list;
  33.   }
  34. //删除操作
  35.   public void khjgDelete(CkhjbForm khjb) {
  36.     JDBConnection connection = new JDBConnection();
  37.     String sql = SQLCode.getSQLCode("sql.khjb.delete");
  38.     sql = connection.editSqlCode(sql, khjb.getKhjb_id());
  39.     int aa = connection.executeUpdate(sql);
  40.     connection.close();
  41.   }
  42. //单独查找
  43.   public CkhjbForm khjgSelectOne(CkhjbForm khjb) {
  44.     JDBConnection connection = new JDBConnection();
  45.     CkhjbForm form = null;
  46.     String sql = SQLCode.getSQLCode("sql.khjb.selectOne");
  47.     sql = connection.editSqlCode(sql, khjb.getKhjb_id());
  48.     try {
  49.       ResultSet rs = connection.executeQuery(sql);
  50.       while (rs.next()) {
  51.         form = new CkhjbForm();
  52.         form.setKhjb_id(rs.getString(1));
  53.         form.setKhjb_jbmc(rs.getString(2));
  54.         form.setKhjb_zdyml(Float.valueOf(rs.getString(3)));
  55.         form.setKhjb_bz(rs.getString(4));
  56.       }
  57.     }
  58.     catch (SQLException ex) {
  59.     }
  60.     connection.close();
  61.     return form;
  62.   }
  63. //修改操作
  64.   public void khjbUpdate(CkhjbForm khjb) {
  65.     JDBConnection connection = new JDBConnection();
  66.     String sql = SQLCode.getSQLCode("sql.khjb.update");
  67.     sql = connection.editSqlCode(sql, khjb.getKhjb_jbmc());
  68.     sql = connection.editSqlCode(sql, khjb.getKhjb_zdyml());
  69.     sql = connection.editSqlCode(sql, khjb.getKhjb_bz());
  70.     sql = connection.editSqlCode(sql, khjb.getKhjb_id());
  71.     System.out.print("sql="+sql);
  72.     connection.executeUpdate(sql);
  73.     connection.close();
  74.   }
  75. //以数据库中的记录数,查找出多少记录计算,以便做帐号存贮--
  76.   public int khjbCount() {
  77.     int iCount = 0;
  78.     JDBConnection connection = null;
  79.     connection = new JDBConnection();
  80.     String sql = SQLCode.getSQLCode("sql.khjb.count");
  81.     ResultSet rs = null;
  82.     try {
  83.       rs = connection.executeQuery(sql);
  84.       while (rs.next()) {
  85.         CkhjbForm form = new CkhjbForm();
  86.         iCount = rs.getInt("t");
  87.       }
  88.     }
  89.     catch (SQLException ex) {
  90.     }
  91.     connection.close();
  92.     return iCount + 1;
  93.   }
  94. //插入操作
  95.   public void khjbInsert(CkhjbForm khjb) {
  96.     JDBConnection connection = new JDBConnection();
  97.     String sql = SQLCode.getSQLCode("sql.khjb.insert");
  98.     sql = connection.editSqlCode(sql, khjb.getKhjb_id());
  99.     sql = connection.editSqlCode(sql, khjb.getKhjb_jbmc());
  100.     sql = connection.editSqlCode(sql, khjb.getKhjb_zdyml());
  101.     sql = connection.editSqlCode(sql, khjb.getKhjb_bz());
  102.     connection.executeUpdate(sql);
  103.     connection.close();
  104.   }
  105. }