ckhmyddaoimpl.java

客户管理系统是一个典型的数据库开发应用程序

package com.dao;

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

//<!--对客户满意表的操作tb_Client_khmyd-->
public class CkhmydDaoImpl
    implements CkhmydDao {
  public List khmydSelect() {
    List list = new ArrayList();
    JDBConnection connection = new JDBConnection();
    CkhmydForm form = null;
    String sql = SQLCode.getSQLCode("sql.khmyd.select");
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new CkhmydForm();
        form.setKhmyd_id(rs.getString(1));
        form.setKhmyd_myd(rs.getString(2));
        form.setKhmyd_bz(rs.getString(3));
        list.add(form);
      }
    }
    catch (SQLException ex) {
    }
    return list;
  }

//删除操作
  public void khmydDelete(CkhmydForm khmyd) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.khmyd.delete");
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_id());
    connection.executeUpdate(sql);
    connection.close();
  }

//修改操作
  public void khmydUpdate(CkhmydForm khmyd) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.khmyd.update");
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_myd());
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_bz());
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_id());
    connection.executeUpdate(sql);
    connection.close();
  }

//单独查询操作
  public CkhmydForm khmydSelectOne(CkhmydForm khmyd) {
    CkhmydForm form = null;
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.khmyd.selectOne");
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_id());
    try {
      ResultSet rs = connection.executeQuery(sql);
      while (rs.next()) {
        form = new CkhmydForm();
        form.setKhmyd_id(rs.getString(1));
        form.setKhmyd_myd(rs.getString(2));
        form.setKhmyd_bz(rs.getString(3));
      }
    }
    catch (SQLException ex) {
    }
    connection.close();
    return form;
  }

//插入操作
  public void khmydInsert(CkhmydForm khmyd) {
    JDBConnection connection = new JDBConnection();
    String sql = SQLCode.getSQLCode("sql.khmyd.insert");
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_id());
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_myd());
    sql = connection.editSqlCode(sql, khmyd.getKhmyd_bz());
    connection.executeUpdate(sql);
    connection.close();
  }

//#--以数据库中的记录数，查找出多少记录计算,以便做帐号存贮--
  public int khmydCount() {
    int iCount = 0;
       JDBConnection connection = null;
       connection = new JDBConnection();
       String sql = SQLCode.getSQLCode("sql.khmyd.count");
       ResultSet rs = null;
       try {
         rs = connection.executeQuery(sql);
         while (rs.next()) {
           CkhmydForm form = new CkhmydForm();
           iCount = rs.getInt("t");
         }
       }
       catch (SQLException ex) {
       }
       connection.close();
       return iCount+1;
     }
}