www.pudn.com > ClientManager.rar > SkhfkDaoImpl.java

package com.dao; 
 
import com.tool.SQLCode; 
import java.util.List; 
import com.tool.JDBConnection; 
import com.domain.SkhfkForm; 
import java.util.ArrayList; 
import java.sql.ResultSet; 
import java.sql.*; 
import com.domain.CountForm; 
 
//对客户服务的操作 
//客户反馈信息（tb_Client_khfk） 
public class SkhfkDaoImpl 
    implements SkhfkDao { 
  private JDBConnection connection = new JDBConnection(); 
 
  //查询操作 
  public List skhfkSelect() { 
    List list = new ArrayList(); 
    SkhfkForm form = null; 
    String sql = SQLCode.getSQLCode("sql.khfk.select"); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new SkhfkForm(); 
        form.setKhfk_id(rs.getString(1)); 
         form.setKhfk_fkbt(rs.getString(2)); 
         form.setKhfk_khmc(rs.getString(3)); 
         form.setKhfk_fknr(rs.getString(4)); 
         form.setKhfk_fkrq(rs.getString(5)); 
         form.setKhfk_fkslr(rs.getString(6)); 
         form.setKhfk_khmyd(rs.getString(7)); 
         form.setKhfk_bz(rs.getString(8)); 
         form.setId(Integer.valueOf(rs.getString(9))); 
 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return list; 
  } 
 
//以客户反馈编号去查询的操作 
  public SkhfkForm skhfkSelectOne(SkhfkForm skhfk) { 
    SkhfkForm form = null; 
    String sql = SQLCode.getSQLCode("sql.khfk.selectOne"); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id()); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new SkhfkForm(); 
        form.setKhfk_id(rs.getString(1)); 
        form.setKhfk_fkbt(rs.getString(2)); 
        form.setKhfk_khmc(rs.getString(3)); 
        form.setKhfk_fknr(rs.getString(4)); 
        form.setKhfk_fkrq(rs.getString(5)); 
        form.setKhfk_fkslr(rs.getString(6)); 
        form.setKhfk_khmyd(rs.getString(7)); 
        form.setKhfk_bz(rs.getString(8)); 
        form.setId(Integer.valueOf(rs.getString(9))); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return form; 
  } 
 
//删除操作 
  public void skhfkDelete(SkhfkForm skhfk) { 
    String sql = SQLCode.getSQLCode("sql.khfk.delete"); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id()); 
    connection.executeUpdate(sql); 
     
  } 
 
//修改操作 
  public void skhfkUpdate(SkhfkForm skhfk) { 
    String sql = SQLCode.getSQLCode("sql.khfk.update"); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkbt()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmc()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fknr()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkrq()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkslr()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_bz()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id()); 
    connection.executeUpdate(sql); 
     
  } 
 
//插入操作 
  public void skhfkInsert(SkhfkForm skhfk) { 
    String sql = SQLCode.getSQLCode("sql.khfk.insert"); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_id()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkbt()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmc()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fknr()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkrq()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_fkslr()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd()); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_bz()); 
    connection.executeUpdate(sql); 
  } 
 
//#--查出流水号，以便做帐号存贮-- 
  public int skhfkCount() { 
    int iCount = 0; 
    String sql = SQLCode.getSQLCode("sql.khfk.count"); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
 
        iCount = rs.getInt("t"); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return iCount + 1; 
  } 
 
//根据客户的满意度去查询 
  public List skhfkSelectMyd(SkhfkForm skhfk) { 
    List list = new ArrayList(); 
    SkhfkForm form = null; 
    String sql = SQLCode.getSQLCode("sql.khfk.myd"); 
    sql = connection.editSqlCode(sql, skhfk.getKhfk_khmyd()); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new SkhfkForm(); 
        form.setKhfk_id(rs.getString(1)); 
        form.setKhfk_fkbt(rs.getString(2)); 
        form.setKhfk_khmc(rs.getString(3)); 
        form.setKhfk_fknr(rs.getString(4)); 
        form.setKhfk_fkrq(rs.getString(5)); 
        form.setKhfk_fkslr(rs.getString(6)); 
        form.setKhfk_khmyd(rs.getString(7)); 
        form.setKhfk_bz(rs.getString(8)); 
        form.setId(Integer.valueOf(rs.getString(9))); 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return list; 
  } 
 
//根据客户的满意程度去查找数据 
  public List skhfkMyd() { 
    List list = new ArrayList(); 
    String sql = SQLCode.getSQLCode("sql.khfk.mydAnthor"); 
    System.out.println("sql=" + sql); 
    CountForm form = null; 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new CountForm(); 
        form.setMyd(rs.getString(1)); 
        form.setNumber(Integer.valueOf(rs.getString(2))); 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return list; 
 
  } 
 
//查询多少记录 
  public int skhfkNumber() { 
    int iCount = 0; 
    String sql = SQLCode.getSQLCode("sql.khfk.number"); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        iCount = rs.getInt("t"); 
        System.out.println("iCount="+iCount); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
 
    return iCount; 
 
  } 
 
}