products.java

购物系统~含其他会员下载一次您上载的源码

package com.beans;

import java.util.*;
import java.sql.*;
import com.utils.DBConnection;

public class Products {
  private static HashMap items = new HashMap();
  
  synchronized public Vector getItems(){
    return new Vector(items.values());
  } 

  synchronized public Item getItem(String itemId){
    return (Item)items.get(itemId);
  } 

  synchronized public void setItem(Item item, String itemId){
    //int index = Integer.parseInt(itemId);
    items.put(itemId, item);
  } 

  public Products(){   
		Connection con = null;
		Statement stmt=null;
		try{			
			con = DBConnection.getConnection();
			stmt = con.createStatement();
			ResultSet rs = stmt.executeQuery("SELECT * FROM bookInfo");
			System.out.println("Got results:");

			while (rs.next()){
				String itemId = rs.getString(1);
				String description = rs.getString(2);
				float price = rs.getFloat(3);
				boolean  available;
				if(rs.getInt(4)==0)
					available=false;
				else
					available=true;
				String producer = rs.getString(5);
				items.put(itemId,new Item(itemId, description, price, available, producer));
			}	
			System.out.println("finished!");
		}
		catch(Exception e){
			e.printStackTrace();
		}
		finally{
			try{
				stmt.close();
				con.close();
			}
			catch(Exception e){
				e.printStackTrace();
			}
		}
	}
  
   public int getSize(){
  	 return items.size();
   }
}