carmanagerdao.java

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

package com.wl.dao;

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.Carmanage;

/**
 * 
 * @author wangJianwei
 *车辆管理DAO
 */
public class CarmanagerDAO {

	public CarmanagerDAO() {
		
	}
	DBManager db = new DBManager();
	boolean flag;
	ResultSet rs = null;
	/**
	 * 添加一辆车
	 * @param car
	 * @return boolean
	 */
	public boolean insertCar(Carmanage car) {
		flag = db.openDB();
		if(flag) 
		{
			try {
				db.ps = db.conn.prepareStatement("insert into carmanagetable values(?,?,?)");
				db.ps.setString(1, car.getCardId());
				db.ps.setInt(2, car.getCarDriverId());
				db.ps.setInt(3, car.getCarTeamId());
				db.ps.executeUpdate();
			} catch (SQLException e) {
				e.printStackTrace();
				return false;
			}
			finally 
			{
				db.closeDB();
			}
			return true;
		}
		else 
		{
			return false;
		}
	}
	/**
	 * 查询所有的车的信息
	 * @return carList
	 */
	public List<Carmanage> queryCar() {
		List<Carmanage> list = new ArrayList<Carmanage>();
		flag = db.openDB();
		Carmanage car = null;
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement("select * from carmanagetable");
				ResultSet rs = db.ps.executeQuery();
				while(rs.next())
				{
					car = new Carmanage(rs.getString(2),rs.getInt(3),rs.getInt(4));
					list.add(car);
				}
			} catch (SQLException e) {
				System.out.println("查询出错");
			}
			finally {
				db.closeDB();
			}
		}
		return list;
	}
	//查询所有的车的really信息
public List<Carmanage> queryReallyCar() {
		
		List<Carmanage> list = new ArrayList<Carmanage>();
		flag = db.openDB();
		String sql="select c.id,cardid,CarDriverId,t.carTeamId,employeename,carteamname from carmanagetable as c join employeeinfotable as e on c.CarDriverId=e.id join carteaminfotable as t on c.CarTeamId=t.id";
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement(sql);
				ResultSet st = db.ps.executeQuery();
				while(st.next())
				{
					int id = st.getInt("id");
					String cardId = st.getString("cardId");
					int carDriverId = st.getInt("CarDriverId");
					String name = st.getString("employeename");
					int carTeamId = st.getInt("carTeamId");
					String carteamname = st.getString("carteamname");
					Carmanage car = new Carmanage(id,cardId,carDriverId,name,carTeamId,carteamname);
					list.add(car);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		else {
			System.out.println("db not open");
		}
		return list;
	}
	/**
	 * 根据车牌号查询车的一行记录
	 * @param carId
	 * @return carList
	 */
	public Carmanage queryCarId(int cardId) {
		flag = db.openDB();
		Carmanage car = null;
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement("select * from carmanagetable where Id=?");
				db.ps.setInt(1, cardId);
				rs = db.ps.executeQuery();
				while(rs.next()) {
				   car = new Carmanage(rs.getInt(1),rs.getString(2),rs.getInt(3),rs.getInt(4));
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		return car;
	}
	/**
	 * 根据车牌号删除一条记录
	 * @param carId
	 * @return boolean
	 */
	public boolean deleteCarId(int id) {
		flag = db.openDB();
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement("delete from carmanagetable where Id=?");
				db.ps.setInt(1, id);
				db.ps.executeUpdate();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			return true;
		}
		else {
			return false;
		}
	}
	/**
	 * 修改车辆信息
	 * @param args
	 */
	public int updateCar(Carmanage c)
	{
		flag = db.openDB();
		int rows = 0;
		if(flag)
		{
			String sql = "update carmanagetable set CardId=?,CarDriverId=?,CarTeamId=? where Id=?";
			try {
				db.ps = db.conn.prepareStatement(sql);
				db.ps.setString(1, c.getCardId());
				db.ps.setInt(2, c.getCarDriverId());
				db.ps.setInt(3, c.getCarTeamId());
				db.ps.setInt(4, c.getId());
			    rows = db.ps.executeUpdate();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		return rows;
	}
	/**
	 * 根据车牌号查询一行记录
	 * @param cardId
	 * @return
	 */
	public List<Carmanage> queryCarId1(String cardId) {
		List<Carmanage> list = new ArrayList<Carmanage>();
		flag = db.openDB();
		if(flag)
		{
			try {
				db.ps = db.conn.prepareStatement("select c.id,cardid,employeename,carteamname from carmanagetable as c join employeeinfotable as e on c.CarDriverId=e.id join carteaminfotable as t on c.CarTeamId=t.id where cardid like ?");
				db.ps.setString(1, "%"+cardId+"%");
				rs = db.ps.executeQuery();
				while(rs.next()) {
				   Carmanage c = new Carmanage(rs.getInt(1),rs.getString(2),rs.getString(3),rs.getString(4));
				   list.add(c);
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			finally{
				db.closeDB();
			}
		}
		return list;
	}
//	public static void main(String[] args) {
//		
//		CarmanagerDAO d = new CarmanagerDAO();
//		System.out.println(d.queryCarId1("豫A87627"));
//	}
}