orderitems.java

网上商城

package store;
import java.sql.*;
import java.util.*;
public class OrderItems {
  public OrderItems(){}
  DBConn conn=new DBConn();
  public Vector getOrderItems(int orderid){
    String sql="SELECT * FROM  orders WHERE isorder=0 AND orderid="+orderid;
    Vector vc=new Vector();
    try{
      ResultSet rs = conn.query(sql);
      while(rs.next()){
        ProInfo PI=new ProInfo();
        PI.setId(rs.getInt("id"));
        PI.setPname(getPname(rs.getInt("pid"),conn));
        PI.setSold(rs.getInt("quantity"));
        PI.setPrice(rs.getFloat("price"));
        vc.add(PI);
      }
      rs.close();
      conn.DBclose();
      conn=null;
    }
    catch(Exception e){
      vc=null;
    }
    return vc;
  }
  public ProInfo getProInfo(int id) throws Exception {
   String sql2="SELECT * FROM  orders WHERE id="+id;
   ProInfo Pi=new ProInfo();
   ResultSet rs2=conn.query(sql2);
   rs2.next();
   Pi.setId(rs2.getInt("id"));
   Pi.setPname(getPname(rs2.getInt("pid"),conn));
   Pi.setSold(rs2.getInt("quantity"));
   Pi.setPrice(rs2.getFloat("price"));
   return Pi;
  }
  public String getPname(int pid,DBConn conn)throws Exception{
  String sql1="SELECT * FROM product WHERE id="+pid;
  ResultSet rs1=conn.query(sql1);
  rs1.next();
  String pname =rs1.getString("pname");
  rs1.close();
  return pname;
  }
}