cqylxdaoimpl.java

使用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;
  }
}