db_orders.java

张新曼 精通JSP Web 开发技术与典型应用 随书光盘源码

package ch24.JavaBean;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.io.PrintWriter;
import java.util.Vector;
import ch24.JavaBean.DB_Conn;
import ch24.JavaBean.Orders;
public class DB_orders
{
	DB_Conn db_conn=new DB_Conn();
	PrintWriter out=null;
	
	//存储订单信息，包括收货人、收货地址、邮政编码、联系电话等信息
	public boolean store_orders(Orders orders)
	{
		db_conn.ConnectDB();
		try
		{
			String orderid=orders.getOrderid(); 
			int userid=orders.getUserid();
			String username=orders.getUsername();
			String orderdate=orders.getOrderdate();
			String address=orders.getAddress();
			String contactman=orders.getContactman();
			String postcode=orders.getPostcode();
			float ordersum=orders.getOrdersum();
			String dealdate=orders.getDealdate();
			String status=orders.getStatus();
			String note=orders.getNote();
			String sql="insert into Orders values('"+orderid+"',"+userid+",'"+username+"','"+orderdate+"','"+address+"','"+
			contactman+"','"+postcode+"',"+ordersum+",null,'"+status+"','"+note+"')";
			db_conn.sm.executeUpdate(sql);
			return true;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return false;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return false;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
	
	public boolean update_orders(String orderid,String dealdate)
	{
		db_conn.ConnectDB();
		try
		{
			String sql="update Orders set dealdate='"+dealdate+"' where orderid='"+orderid+"'";
			db_conn.sm.executeUpdate(sql);
			return true;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return false;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return false;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
	
	
	//获取订单表中最大订单号，以便产生下一个订单号
	public String get_orderid(String orderid)
	{
		db_conn.ConnectDB();
		ResultSet rs=null;
		try
		{
			String querysql="select max(orderid) as orderid from Orders";
			rs=db_conn.sm.executeQuery(querysql);
			String max_orderid="";
			rs.next();
			max_orderid=rs.getString("orderid");
			
			
			//如果库表中存在数据，则在检索到的最大订单号的基础上加1产生下一个订单号，
            //否则以当前日期加’0001’作为下一个订单号
			if(max_orderid!=null)
			{
				
				long id=Long.parseLong(max_orderid);
				id=id+1;
				max_orderid=String.valueOf(id);
				
			}
			else
		    {
				max_orderid=orderid.concat("0001");
			}
			return max_orderid;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return "";
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return "";
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
	public Vector orders_list()
	{
		db_conn.ConnectDB();
		ResultSet rs=null;
		try
		{
			Vector vector=new Vector();
			
			String sql="select * from orders order by status";
			rs=db_conn.sm.executeQuery(sql);
			while(rs.next())
			{
				Orders orders=new Orders();
				orders.setOrderid(rs.getString("orderid"));
				orders.setUserid(rs.getInt("userid"));
				orders.setUsername(rs.getString("username"));
				orders.setOrderdate(rs.getString("orderdate"));
				orders.setAddress(rs.getString("address"));
				orders.setContactman(rs.getString("contactman"));
				orders.setPostcode(rs.getString("postcode"));
				orders.setOrdersum(rs.getFloat("ordersum"));
				orders.setDealdate(rs.getString("dealdate"));
				orders.setStatus(rs.getString("status"));
				orders.setNote(rs.getString("note"));
				vector.addElement(orders);
			}
			return vector;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return null;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return null;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
	
	//取得订单列表
	public Vector orders_list(String orderid)
	{
		db_conn.ConnectDB();
		ResultSet rs=null;
		try
		{
			Vector vector=new Vector();
			
			String sql="select * from orders where orderid='"+orderid+"' order by status";
			rs=db_conn.sm.executeQuery(sql);
			while(rs.next())
			{
				Orders orders=new Orders();
				orders.setOrderid(rs.getString("orderid"));
				orders.setUserid(rs.getInt("userid"));
				orders.setUsername(rs.getString("username"));
				orders.setOrderdate(rs.getString("orderdate"));
				orders.setAddress(rs.getString("address"));
				orders.setContactman(rs.getString("contactman"));
				orders.setPostcode(rs.getString("postcode"));
				orders.setOrdersum(rs.getFloat("ordersum"));
				orders.setDealdate(rs.getString("dealdate"));
				orders.setStatus(rs.getString("status"));
				orders.setNote(rs.getString("note"));
				vector.addElement(orders);
			}
			return vector;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return null;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return null;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
	
	//修改订单状态为‘预定’，此时客户提交的任何信息均将不能修改
	public boolean mod_status(String orderid)
	{
		db_conn.ConnectDB();
		try
		{
			String sql="update orders set status='预定' where orderid='"+orderid+"'";
			db_conn.sm.executeUpdate(sql);
			return true;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return false;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return false;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
   //修改订单状态，对上述函数进行重载
	public boolean mod_status(String orderid,String status)
	{
		db_conn.ConnectDB();
		try
		{
			String sql="update orders set status='"+status+"' where orderid='"+orderid+"'";
			db_conn.sm.executeUpdate(sql);
			return true;
		}
		catch (SQLException SqlE) 
		{
			SqlE.printStackTrace();
			return false;
		} 
		catch (Exception E) 
		{
			E.printStackTrace();
			return false;
		}
		finally 
		{
			// 关闭连接，释放数据库资源：
			db_conn.CloseDB();
		}
	}
}