storeinfordao.java

功能是公安和学校的管理系统,用struts+hibernate+spring等匡架组成,在eclepse就能编译

package com.comingnet.bean;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;

import com.db.DBUtils;
import com.db.KeyGenerator;

public class StoreInforDAO {

	Connection conn = null ;
	PreparedStatement stmt = null ;
	ResultSet rs = null ;
	 
////////查找指定编号的信息
	public StoreInfor QueryById(int cfdbh){
	  StoreInfor si=null;
	  String sqlStr="SELECT *  FROM assets_cfd  WHERE cfdbh = ?";
	  
  try{
	   conn = DBUtils.getConnection() ;
	   stmt = conn.prepareStatement(sqlStr) ;
	   stmt.setInt(1,cfdbh) ;	   
	   rs = stmt.executeQuery();
	   while(rs.next()){
			si = new StoreInfor() ;
			si.setCfdbh(rs.getInt("cfdbh"));
			si.setCfdmc(rs.getString("cfdmc"));
			si.setCfddz(rs.getString("cfddz"));
			si.setCfdzrr(rs.getString("cfdzrr"));
			si.setCfdbz(rs.getString("cfdbz"));
			}
		DBUtils.closeResultSet(rs) ;
		DBUtils.closeStatement(stmt) ;
		} catch (Exception e) {
			System.out.println("StoreInforDAO.queryById"+e) ;
	} finally{
		DBUtils.closeResultSet(rs) ;
		DBUtils.closeStatement(stmt) ;
		DBUtils.closeConnection(conn) ;
	}
	return si ;
	}
////////查找所有和根据条件查询
	public ArrayList<StoreInfor> queryAll(int pageno, int recordPerPage,String cond){
	    StoreInfor si = null ;
		ArrayList<StoreInfor> resultList = new ArrayList<StoreInfor>() ;
		String sqlStr ="" ; 
		sqlStr  ="select top "+recordPerPage+" * from assets_cfd where cfdbh not in (select top "+(pageno-1)*recordPerPage+" cfdbh from assets_cfd where "+cond+" order by cfdbh) and "+cond+" order by cfdbh" ;
		Statement stmt1 = null ;
		
		try {
			conn = DBUtils.getConnection() ;
			stmt1 = conn.createStatement() ;
			rs = stmt1.executeQuery(sqlStr) ;
			
			while(rs.next()){
				si = new StoreInfor() ;
				si.setCfdbh(rs.getInt("cfdbh"));
				si.setCfdmc(rs.getString("cfdmc"));
				si.setCfddz(rs.getString("cfddz"));
				si.setCfdzrr(rs.getString("cfdzrr"));
				si.setCfdbz(rs.getString("cfdbz"));
	 		
				resultList.add(si) ;
			}
			DBUtils.closeResultSet(rs) ;
			DBUtils.closeStatement(stmt) ;
			
		} catch (Exception e) {
			System.out.println("StoreInforDAO.queryAll---->"+e) ;
		}finally{
			DBUtils.closeResultSet(rs) ;
			DBUtils.closeStatement(stmt) ;
			DBUtils.closeConnection(conn) ;	
		}
		
		return resultList ;	
	}
	///////////增加
	public boolean AddStore(StoreInfor si){
		boolean flag = false ;
		String sqlSrt ="insert into assets_cfd (cfdbh,cfdmc,cfddz,cfdzrr,cfdbz) values(?,?,?,?,?)"  ;
		
		try {
			int cfdbh = KeyGenerator.getInstance().getNextKey("assets_cfd");
		
			conn = DBUtils.getConnection() ;
			stmt = conn.prepareStatement(sqlSrt) ;
			stmt.setInt(1,cfdbh) ;
			stmt.setString(2, si.getCfdmc());
			stmt.setString(3, si.getCfddz());
			stmt.setString(4, si.getCfdzrr());
			stmt.setString(5, si.getCfdbz());
			stmt.executeUpdate() ;
			
			DBUtils.closeStatement(stmt) ;
		} catch (Exception e) {
			System.out.println("StoreInforDAO.AddStore"+e) ;
			return flag ;
		}finally{
			DBUtils.closeStatement(stmt) ;
			DBUtils.closeConnection(conn) ; 
		}
		flag = true ;
		return flag ;
	}
	////////////////////删除	
	public boolean DeleteStore(int cfdbh){
		boolean flag=false;
		String sqlStr="DELETE 	FROM   assets_cfd  WHERE cfdbh= ? ";
	try {
			 
			conn = DBUtils.getConnection() ;
			stmt = conn.prepareStatement(sqlStr) ;
			stmt.setInt(1,cfdbh) ;
 		    stmt.executeUpdate() ;
			
			DBUtils.closeStatement(stmt) ;
		} catch (Exception e) {
			System.out.println("StoreInforDAO.DeleteStore"+e) ;
			return flag ;
		}finally{
			DBUtils.closeStatement(stmt) ;
			DBUtils.closeConnection(conn) ; 
		}
		flag = true ;
		return flag ;
	}	
//////////////////修改
	public boolean UpdateStore(StoreInfor si){
		boolean flag = false ;
		String sqlStr = "UPDATE assets_cfd SET  cfdmc = ? ,  cfddz = ? , cfdzrr = ?  , cfdbz = ? "+
		"WHERE  cfdbh = ? " ;
		
		try {
			conn = DBUtils.getConnection() ;
			stmt = conn.prepareStatement(sqlStr) ;
			
			stmt.setString(1, si.getCfdmc());
			stmt.setString(2, si.getCfddz());
			stmt.setString(3, si.getCfdzrr());
			stmt.setString(4, si.getCfdbz());
			stmt.setInt(5, si.getCfdbh());
			
		    stmt.executeUpdate() ;
			
			DBUtils.closeStatement(stmt) ;
			
		} catch (Exception e) {
			System.out.println("StoreInforDAO.UpdateStore"+e) ;
			return flag ;	
		} finally{
			DBUtils.closeStatement(stmt) ;
			DBUtils.closeConnection(conn) ;
		}
		flag = true ;
		return flag ;
	}
/////////////////查询记录条数
	public int getCountsOfAll(){
		String sqlStr = "select count(*) from assets_cfd" ;
		int count = 0 ;
		try {
			conn = DBUtils.getConnection() ;
			stmt = conn.prepareStatement(sqlStr) ;
			rs = stmt.executeQuery() ;
			if(rs.next()){
				count = rs.getInt(1) ;
			}
			
			DBUtils.closeResultSet(rs) ;
			DBUtils.closeStatement(stmt) ;
		} catch (Exception e) {
			System.out.println("StoreInforDAO----->"+e) ;
		} finally{
			DBUtils.closeResultSet(rs) ;
			DBUtils.closeStatement(stmt) ;
			DBUtils.closeConnection(conn) ;
		}
		System.out.println("count-------------------------->"+count) ;
 		return count ; 		
	}
}