开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 企业管理 > 查看源码
KhtsDaoImpl.java
资源名称：clientManager.rar　[点击查看]
上传用户：quasar007
上传日期：2022-08-11
资源大小：4067k
文件大小：5k
源码类别：

企业管理

开发平台：

Java

KhtsDaoImpl.java：源码内容
  1. package com.dao;
  3. import java.util.List;
  4. import com.domain.KhtsForm;
  5. import java.util.ArrayList;
  6. import com.tool.JDBConnection;
  7. import java.sql.ResultSet;
  8. import com.tool.SQLCode;
  9. import java.sql.*;
  10. import com.domain.CountForm;
  12. //客户投诉
  13. public class KhtsDaoImpl
  14.     implements KhtsDao {
  15.   private JDBConnection connection = new JDBConnection();
  16.   //查询操作
  17.   public List select() {
  18.     List list = new ArrayList();
  19.     KhtsForm khts = null;
  20.     String sql = SQLCode.getSQLCode("sql.khts.select");
  22.     try {
  23.       ResultSet rs = connection.executeQuery(sql);
  24.       while (rs.next()) {
  25.         khts = new KhtsForm();
  26.         khts.setKhts_id(rs.getString(1));
  27.         khts.setKhts_qymc(rs.getString(2));
  28.         khts.setKhts_tsr(rs.getString(3));
  29.         khts.setKhts_tszt(rs.getString(4));
  30.         khts.setKhts_tsnr(rs.getString(5));
  31.         khts.setKhts_tsrq(rs.getString(6));
  32.         khts.setKhts_clbf(rs.getString(7));
  33.         khts.setKhts_khmyd(rs.getString(8));
  34.         khts.setKhts_tsslr(rs.getString(9));
  35.         khts.setKhts_bz(rs.getString(10));
  36.         khts.setId(Integer.valueOf(rs.getString(11)));
  37.         list.add(khts);
  38.       }
  39.     }
  40.     catch (SQLException ex) {
  41.     }
  42.     return list;
  43.   }
  45. //插入操作
  46.   public void Insert(KhtsForm form) {
  47.     String sql = SQLCode.getSQLCode("sql.khts.insert");
  48.     sql = connection.editSqlCode(sql, form.getKhts_id());
  50.     sql = connection.editSqlCode(sql, form.getKhts_qymc());
  52.     sql = connection.editSqlCode(sql, form.getKhts_tsr());
  54.     sql = connection.editSqlCode(sql, form.getKhts_tszt());
  56.     sql = connection.editSqlCode(sql, form.getKhts_tsnr());
  58.     sql = connection.editSqlCode(sql, form.getKhts_tsrq());
  60.     sql = connection.editSqlCode(sql, form.getKhts_clbf());
  62.     sql = connection.editSqlCode(sql, form.getKhts_khmyd());
  64.     sql = connection.editSqlCode(sql, form.getKhts_tsslr());
  66.     sql = connection.editSqlCode(sql, form.getKhts_bz());
  68.     connection.executeUpdate(sql);
  69.     connection.close();
  71.   }
  73. //删除操作
  74.   public void Delete(KhtsForm form) {
  75.     String sql = SQLCode.getSQLCode("sql.khts.delete");
  76.     sql = connection.editSqlCode(sql, form.getId());
  77.     connection.executeUpdate(sql);
  78.     connection.close();
  79.   }
  81. //修改操作
  82.   public void Update(KhtsForm form) {
  83.     String sql = SQLCode.getSQLCode("sql.khts.update");
  84.     sql = connection.editSqlCode(sql, form.getKhts_id());
  85.     sql = connection.editSqlCode(sql, form.getKhts_qymc());
  86.     sql = connection.editSqlCode(sql, form.getKhts_tsr());
  87.     sql = connection.editSqlCode(sql, form.getKhts_tszt());
  88.     sql = connection.editSqlCode(sql, form.getKhts_tsnr());
  89.     sql = connection.editSqlCode(sql, form.getKhts_tsrq());
  90.     sql = connection.editSqlCode(sql, form.getKhts_clbf());
  91.     sql = connection.editSqlCode(sql, form.getKhts_khmyd());
  92.     sql = connection.editSqlCode(sql, form.getKhts_tsslr());
  93.     sql = connection.editSqlCode(sql, form.getKhts_bz());
  94.     sql = connection.editSqlCode(sql, form.getId());
  95.     connection.executeUpdate(sql);
  96.     connection.close();
  97.   }
  99. //单一查询操作
  100.   public KhtsForm SelectOne(KhtsForm form) {
  101.     KhtsForm khts = null;
  102.     String sql = SQLCode.getSQLCode("sql.khts.selectOne");
  103.     sql = connection.editSqlCode(sql, form.getId());
  104.     try {
  105.       ResultSet rs = connection.executeQuery(sql);
  106.       while (rs.next()) {
  107.         khts = new KhtsForm();
  108.         khts.setKhts_id(rs.getString(1));
  109.         khts.setKhts_qymc(rs.getString(2));
  110.         khts.setKhts_tsr(rs.getString(3));
  111.         khts.setKhts_tszt(rs.getString(4));
  112.         khts.setKhts_tsnr(rs.getString(5));
  113.         khts.setKhts_tsrq(rs.getString(6));
  114.         khts.setKhts_clbf(rs.getString(7));
  115.         khts.setKhts_khmyd(rs.getString(8));
  116.         khts.setKhts_tsslr(rs.getString(9));
  117.         khts.setKhts_bz(rs.getString(10));
  118.         khts.setId(Integer.valueOf(rs.getString(11)));
  120.       }
  121.     }
  122.     catch (SQLException ex) {
  123.     }
  124.     return khts;
  126.   }
  128. //唯一性
  129.   public int countID() {
  130.     int iCount = 0;
  131.     String sql = SQLCode.getSQLCode("sql.khts.countID");
  132.     ResultSet rs = null;
  133.     try {
  134.       rs = connection.executeQuery(sql);
  135.       while (rs.next()) {
  137.         iCount = rs.getInt("t");
  138.       }
  139.     }
  140.     catch (SQLException ex) {
  141.     }
  142.     connection.close();
  143.     return iCount + 1;
  145.   }
  147.   //删除受理
  148.   public void DeleteSl(KhtsForm form) {
  149.     String sql = SQLCode.getSQLCode("sql.khts.deleteSl");
  151.     sql = connection.editSqlCode(sql, form.getKhts_clbf());
  152.     sql = connection.editSqlCode(sql, form.getKhts_khmyd());
  153.     sql = connection.editSqlCode(sql, form.getKhts_tsslr());
  155.     sql = connection.editSqlCode(sql, form.getId());
  156.     connection.executeUpdate(sql);
  157.     connection.close();
  158.   }
  159.   //根据客户的满意程度去查找数据
  160.   public List skhfkMyd() {
  161.     List list = new ArrayList();
  162.     String sql = SQLCode.getSQLCode("sql.khts.pricture");
  164.     CountForm form = null;
  165.     ResultSet rs = null;
  166.     try {
  167.       rs = connection.executeQuery(sql);
  168.       while (rs.next()) {
  169.         form = new CountForm();
  170.         form.setMyd(rs.getString(1));
  171.         form.setNumber(Integer.valueOf(rs.getString(2)));
  172.         list.add(form);
  173.       }
  174.     }
  175.     catch (SQLException ex) {
  176.     }
  177.     connection.close();
  178.     return list;
  180.   }
  182. }