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

package com.dao; 
 
import com.tool.SQLCode; 
import java.util.List; 
 
import com.tool.JDBConnection; 
import java.util.ArrayList; 
import java.sql.ResultSet; 
import java.sql.*; 
import com.domain.CqyxxForm; 
 
//对表tb_Client_qyxx的操作 
public class CqyxxDaoImpl 
    implements CqyxxDao { 
 
//查找的操作 
  public List qyxxSelect() { 
    List list = new ArrayList(); 
    String sql = SQLCode.getSQLCode("sql.qyxx.select"); 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
      while (rs.next()) { 
        CqyxxForm form = new CqyxxForm(); 
        form.setId(rs.getString(1)); 
        form.setQymc(rs.getString(2)); 
        form.setQyjb(rs.getString(3)); 
        form.setZscd(rs.getString(4)); 
        form.setQygml(rs.getString(5)); 
        form.setBz(rs.getString(6)); 
        list.add(form); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return list; 
  } 
 
//删除的操作 
  public void qyxxDelete(CqyxxForm qyxxForm) { 
    JDBConnection connection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qyxx.delete"); 
    sql = connection.editSqlCode(sql, qyxxForm.getId()); 
    connection.executeUpdate(sql); 
     
  } 
 
//插入操作 
  public void qyxxInsert(CqyxxForm qyxxForm) { 
    JDBConnection connection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qyxx.insert"); 
    sql = connection.editSqlCode(sql, qyxxForm.getId()); 
    sql = connection.editSqlCode(sql, qyxxForm.getQymc()); 
    sql = connection.editSqlCode(sql, qyxxForm.getQyjb()); 
    sql = connection.editSqlCode(sql, qyxxForm.getZscd()); 
    sql = connection.editSqlCode(sql, qyxxForm.getQygml()); 
    sql = connection.editSqlCode(sql, qyxxForm.getBz()); 
    connection.executeUpdate(sql); 
     
  } 
 
//单独查找操作 
  public CqyxxForm qyxxSelectOne(CqyxxForm qyxxForm) { 
    JDBConnection connection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qyxx.selectOne"); 
    sql = connection.editSqlCode(sql, qyxxForm.getId()); 
    CqyxxForm form = null; 
    ResultSet rs = null; 
    Connection conn=null; 
    Statement stmt=null; 
    try { 
      rs = JDBConnection.executeQuery(conn,stmt,sql); 
    while (rs.next()) { 
         form = new CqyxxForm(); 
         form.setId(rs.getString(1)); 
         form.setQymc(rs.getString(2)); 
         form.setQyjb(rs.getString(3)); 
         form.setZscd(rs.getString(4)); 
         form.setQygml(rs.getString(5)); 
         form.setBz(rs.getString(6)); 
      } 
    } 
    catch (SQLException ex) { 
    	ex.printStackTrace(); 
    }finally{ 
    	JDBConnection.close(rs,stmt,conn); 
    } 
     
    return form; 
  } 
 
//修改操作 
  public void qyxxUpdate(CqyxxForm qyxxForm) { 
    JDBConnection connection = new JDBConnection(); 
    String sql = SQLCode.getSQLCode("sql.qyxx.update"); 
 
    sql = connection.editSqlCode(sql, qyxxForm.getQymc()); 
    sql = connection.editSqlCode(sql, qyxxForm.getQyjb()); 
    sql = connection.editSqlCode(sql, qyxxForm.getZscd()); 
    sql = connection.editSqlCode(sql, qyxxForm.getQygml()); 
    sql = connection.editSqlCode(sql, qyxxForm.getBz()); 
    sql = connection.editSqlCode(sql, qyxxForm.getId()); 
    connection.executeUpdate(sql); 
     
  } 
 
 
//以数据库流水号查询的数量进行调用，利用到给区域编号中去,进行区域编号 
  public int qyxxCount() { 
    int iCount=0; 
    JDBConnection connection = null; 
     connection = new JDBConnection(); 
     String sql = SQLCode.getSQLCode("sql.qyxx.count"); 
     ResultSet rs = null; 
     Connection conn=null; 
     Statement stmt=null; 
     try { 
       rs = JDBConnection.executeQuery(conn,stmt,sql);; 
       while (rs.next()) { 
         CqyxxForm form = new CqyxxForm(); 
         iCount=rs.getInt("t"); 
       } 
     } 
     catch (SQLException ex) { 
     	ex.printStackTrace(); 
     }finally{ 
     	JDBConnection.close(rs,stmt,conn); 
     } 
      
     return iCount+1; 
   } 
}