www.pudn.com > ClientManager.rar > 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; 
 
// 
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"); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs =JDBConnection.executeQuery(conn,stmt,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) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
    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); 
     
  } 
 
//修改操作 
  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); 
     
  } 
 
//单独查询操作 
  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()); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,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) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    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); 
     
  } 
 
//#--以数据库中的记录数，查找出多少记录计算,以便做帐号存贮-- 
  public int khmydCount() { 
    int iCount = 0; 
       JDBConnection connection = null; 
       connection = new JDBConnection(); 
       String sql = SQLCode.getSQLCode("sql.khmyd.count"); 
       Connection conn=null; 
       Statement stmt=null; 
       ResultSet rs = null; 
       try { 
         rs = JDBConnection.executeQuery(conn,stmt,sql); 
         while (rs.next()) { 
           CkhmydForm form = new CkhmydForm(); 
           iCount = rs.getInt("t"); 
         } 
       } 
       catch (SQLException ex) { 
    	   ex.printStackTrace(); 
       }finally{ 
       	JDBConnection.close(rs,stmt,conn); 
       } 
        
       return iCount+1; 
     } 
}