carlinetabledao.java

基于j2ee的物流软件

package com.wuliu.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.wuliu.DBConnection.DBConnection;
import com.wuliu.entity.CarLineTable;

public class CarLineTableDAO
{
	
	private Connection conn = null;
	private PreparedStatement ps = null;
	private DBConnection DBC = null;

	/*
	 * @author 陈磊
	 * 查询所有的车队路线
	 * 
	 */
	//2.15崔斌添加连接数据库
	public CarLineTableDAO(){
		 this.DBC = new DBConnection();
	}
	
	public List<CarLineTable> selectAllCarLineTableMsg()
	{
		this.conn = this.DBC.getConnection();
		List<CarLineTable> list = new ArrayList<CarLineTable>();
		CarLineTable carLineTable = null;
		try
		{
			this.ps = this.conn
					.prepareStatement("select * from CarLineTable");
			ResultSet rs = this.ps.executeQuery();
			while (rs.next())
			{
				int id = rs.getInt("CarLineId");
				String carLineStart = rs.getString("CarLineStart");
				String carLineEnd = rs.getString("CarLineEnd");
				String carLinePass = rs.getString("CarLinePass");
				String carLineRemark = rs.getString("CarLineRemark");
				
				carLineTable = new CarLineTable(id,carLineStart,carLineEnd,carLinePass,carLineRemark);
				list.add(carLineTable);
			}
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		this.DBC.closeConnection(conn);
		return list;
	}

	/*
	 * 
	 * 插入路线
	 * 
	 */
	public void addCarLineTable(CarLineTable carLineTable)
	{
		this.conn = this.DBC.getConnection();
		try
		{
			this.ps = this.conn.prepareStatement("insert into CarLineTable (CarLineId,CarLineStart,CarLineEnd,CarLinePass,CarLineRemark)value(?,?,?,?,?)");
		
			this.ps.executeQuery();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		this.DBC.closeConnection(conn);
	}

	/*
	 * 
	 * 删除路线
	 * 
	 */
	public void deleteCarLineTable(int id)
	{
		this.conn = this.DBC.getConnection();
		try
		{
			this.ps = this.conn
					.prepareStatement("delete from CarLineTable where  CarLineId=? ");
			this.ps.setInt(1, id);
			this.ps.executeUpdate();
		} catch (SQLException e)
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		this.DBC.closeConnection(conn);
	}

	/*
	 * 
	 * 根据(终点)查找所有信息
	 * 
	 */
	public CarLineTable selectCarLineTableMsgByName(String CarLineEnd)
	{
		this.conn = this.DBC.getConnection();
		CarLineTable carLineTable = null;
		try
		{
			this.ps = conn
					.prepareStatement("select * from CarLineTable where CarLineEnd=?");
			ps.setString(1, CarLineEnd);
			ResultSet rs = this.ps.executeQuery();
			while (rs.next())
			{
				int id = rs.getInt("CarLineId");
				String carLineStart = rs.getString("CarLineStart");
				String carLineEnd = rs.getString("CarLineEnd");
				String carLinePass = rs.getString("CarLinePass");
				String carLineRemark = rs.getString("CarLineRemark");
				
				carLineTable = new CarLineTable(id,carLineStart,carLineEnd,carLinePass,carLineRemark);
				
			}
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		this.DBC.closeConnection(conn);
		return carLineTable;
	}

	/*
	 * 修改
	 */
	public void updateConsignee(CarLineTable c)
	{
		this.conn = this.DBC.getConnection();
		try
		{
			this.ps = this.conn
					.prepareStatement("update CarLineTable set CarLineStart=?,CarLineEnd=?,CarLinePass=?,CarLineRemark=? where CarLineId=?");
			this.ps.setString(1,c.getCarLineStart());
			this.ps.setString(2,c.getCarLineEnd());
			this.ps.setString(3,c.getCarLinePass());
			this.ps.setString(4,c.getCarLinePass());
			this.ps.setInt(5, c.getId());
			this.ps.executeUpdate();
		} catch (SQLException e)
		{
			e.printStackTrace();
		}
		this.DBC.closeConnection(conn);
	}

	public static void main(String[] args)
	{

	}
}