commcatedao.java

老牌java开发的物流管理系统 详细的我也没有怎么看 好像是恒基的

package com.wl.dao;
/**
 * @author tianxiaoshun
 */
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.wl.dbconnection.DBManager;

import com.wl.entity.GoodsType;

public class CommcateDAO {
   DBManager dbmanager=new DBManager();
   boolean flage;
	/**
	 * 封装插入数据方法
	 * @param commcate
	 * @return boolean
 	 */
   public boolean insertCommcate(GoodsType commcate){
	  flage=dbmanager.openDB();
	  if(flage){
		  try{
		  dbmanager.ps=dbmanager.conn.prepareStatement("insert into Commcatetable values(?,?)");  
		  dbmanager.ps.setString(1,commcate.getCommodityId());
		  dbmanager.ps.setString(2, commcate.getCommodityName());
		  dbmanager.ps.executeUpdate();
		  }
		  catch(Exception e){
			  return false;
		  }
		  finally{
			  dbmanager.closeDB();
		  }
	   return true;
	  }
	  else{
		  return false;
	  }
	  }
   /**
    * 封装查询所有商品分类表信息
    * @return list
    */
	public List<GoodsType> selectCommcate(){
		List<GoodsType> list=new ArrayList<GoodsType>();
		flage=dbmanager.openDB();
		GoodsType commcate;
     if(flage){
    	 try{
    		 dbmanager.ps=dbmanager.conn.prepareStatement("select * from Commcatetable");
    		 ResultSet  st=dbmanager.ps.executeQuery();
    		 while(st.next()){
    			 commcate=new GoodsType(st.getInt(1),st.getString(2),st.getString(3));
    			 list.add(commcate);
    		 }
    	 }
    	 catch(Exception e){
    		 System.out.print("数据库连接失败！");
    	 }
    	 finally
    	 {
    		 dbmanager.closeDB();
    	 }
    	 
     }
     else
     {
    	 System.out.print("数据库打开失败！");
     }
     return list;
	}
	/**
	 * 根据商品分类名称查询商品分类信息（袁新锋修改 2009.2.11）
	 * @param name
	 * @return list
	 */
	public List<GoodsType> selectCommcateByName(String name){
		List<GoodsType> list=new ArrayList<GoodsType>();
		flage=dbmanager.openDB();
		GoodsType commcate;
     if(flage){
    	 try{
    		 dbmanager.ps=dbmanager.conn.prepareStatement("select * from commcatetable where CommodityName=?");
    		 dbmanager.ps.setString(1, name);
    		 ResultSet  st=dbmanager.ps.executeQuery();
    		 while(st.next()){
    			 commcate=new GoodsType(st.getInt(1),st.getString(2),st.getString(3));
    			 list.add(commcate);
    		 }
    	 }
    	 catch(Exception e){
    		 System.out.print("数据库连接失败！");
    	 }
    	 finally
    	 {
    		 dbmanager.closeDB();
    	 }
    	 
     }
     else
     {
    	 System.out.print("数据库打开失败！");
     }
     return list;
	}
	/**
	 * 根据Id查询商品类型信息
	 * @param id
	 * @return
	 */
	public GoodsType selectCommcateByName(int id){
		flage=dbmanager.openDB();
		GoodsType commcate=null;
     if(flage){
    	 try{
    		 dbmanager.ps=dbmanager.conn.prepareStatement("select * from commcatetable where id=?");
    		 dbmanager.ps.setInt(1, id);
    		 ResultSet  st=dbmanager.ps.executeQuery();
    		 while(st.next()){
    			 commcate=new GoodsType(st.getInt(1),st.getString(2),st.getString(3));
    		 }
    	 }
    	 catch(Exception e){
    		 System.out.print("数据库连接失败！");
    	 }
    	 finally
    	 {
    		 dbmanager.closeDB();
    	 }
    	 
     }
     else
     {
    	 System.out.print("数据库打开失败！");
     }
     return commcate;
	}
	//根据id查询信息
	public GoodsType queryId(int id) {
		flage = dbmanager.openDB();
		GoodsType g = null;
		if(flage)
		{
		   String sql = "select * from commcatetable where id=?";
		   try {
			dbmanager.ps = dbmanager.conn.prepareStatement(sql);
			dbmanager.ps.setInt(1, id);
			ResultSet rs = dbmanager.ps.executeQuery();
			while(rs.next()) {
				g = new GoodsType(rs.getInt(1),rs.getString(2),rs.getString(3));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally {
			dbmanager.closeDB();
		}
		}
		return g;
	}
	//删除
	public boolean deleteGoodsId(int id) {
		flage = dbmanager.openDB();
		if(flage)
		{
			try {
				dbmanager.ps = dbmanager.conn.prepareStatement("delete from commcatetable where Id=?");
				dbmanager.ps.setInt(1, id);
				dbmanager.ps.executeUpdate();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			return true;
		}
		else {
			return false;
		}
	}
	/**
	 * 修改车辆信息
	 * @param args
	 */
	public int updateCar(GoodsType c)
	{
		flage = dbmanager.openDB();
		int rows = 0;
		if(flage)
		{
			String sql = "update commcatetable set commodityid=?,commodityname=? where Id=?";
			try {
				dbmanager.ps = dbmanager.conn.prepareStatement(sql);
				dbmanager.ps.setString(1, c.getCommodityId());
				dbmanager.ps.setString(2, c.getCommodityName());
				dbmanager.ps.setInt(3, c.getId());
			    rows = dbmanager.ps.executeUpdate();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			finally{
				dbmanager.closeDB();
			}
		}
		return rows;
	}
	public static void main(String[] args) {
		CommcateDAO c  = new CommcateDAO();
		
		System.out.println(c.queryId(2));
	}
}