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

package com.dao; 
 
import java.util.List; 
import java.util.ArrayList; 
import com.tool.JDBConnection; 
import com.tool.SQLCode; 
import java.sql.*; 
 
import javax.management.j2ee.statistics.JDBCConnectionStats; 
 
import com.domain.CqylxForm; 
 
//对表tb_Client_qylx的操作 
public class CqylxDaoImpl 
    implements CqylxDao { 
//查询的操作 
  public List qylxSelect() { 
    CqylxForm form = null; 
    List list = new ArrayList(); 
    String sql = SQLCode.getSQLCode("sql.qylx.select"); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs=null; 
    try { 
    	rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new CqylxForm(); 
        form.setQylx_id(rs.getString(1)); 
        form.setQylx_lxmc(rs.getString(2)); 
        form.setQylx_bz(rs.getString(3)); 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return list; 
  } 
 
//删除操作 
  public void qylxDelete(CqylxForm qylx) { 
    JDBConnection JDBConnection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qylx.delete"); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_id()); 
    JDBConnection.executeUpdate(sql); 
     
  } 
 
//修改操作 
  public void qylxupdate(CqylxForm qylx) { 
    JDBConnection JDBConnection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qylx.update"); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_lxmc()); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_bz()); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_id()); 
    JDBConnection.executeUpdate(sql); 
     
 
  } 
 
//单独查找 
  public CqylxForm qylxSelectOne(CqylxForm qylx) { 
//    JDBConnection JDBConnection = new JDBConnection(); 
    CqylxForm form = null; 
    List list = new ArrayList(); 
    String sql = SQLCode.getSQLCode("sql.qylx.selectOne"); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_id()); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs=null; 
    try { 
       rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        form = new CqylxForm(); 
        form.setQylx_id(rs.getString(1)); 
        form.setQylx_lxmc(rs.getString(2)); 
        form.setQylx_bz(rs.getString(3)); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs, stmt, conn); 
    } 
     
    return form; 
  } 
 
//插入操作 
  public void qylxInsert(CqylxForm qylx) { 
    JDBConnection JDBConnection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qylx.insert"); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_id()); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_lxmc()); 
    sql = JDBConnection.editSqlCode(sql, qylx.getQylx_bz()); 
    JDBConnection.executeUpdate(sql); 
     
  } 
 
//以数据库中的记录数，查找出多少记录计算,以便做帐号存贮 
  public int qulxCount() { 
    int iCount = 0; 
//    JDBConnection JDBConnection = null; 
//    JDBConnection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qylx.count"); 
    Connection conn=null; 
    Statement stmt=null; 
    ResultSet rs = null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        CqylxForm form = new CqylxForm(); 
        iCount = rs.getInt("t"); 
      } 
    } 
    catch (SQLException ex) { 
    }finally{ 
    	JDBConnection.close(rs, stmt, conn); 
    } 
     
    return iCount+1; 
  } 
}