cqyxxdaoimpl.java

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