goodsstoremanager.java

关于商品的进、销、存管理系统

package supercms;
import java.sql.*;

import superdb.*;
import supershopmanager.*;

import java.util.*;
/*
 * 完成对库存信息的插入，修改，删除，
 * 并可对库存商品进行查询和统计
 * 
 * 
 * */
public class GoodsStoreManager {
	private SuperDBConn sdb;
	private SuperInfoManager sim;
	private Statement stmt;
	public GoodsStoreManager()
	{
		sdb=new SuperDBConn();
		sim=new SuperInfoManager(sdb.getConn());
		stmt=sim.getStmt();
	}

	/*----------完成对库存信息的插入----------*/
	public void addGoodsStore(GoodsStore goodsStore)
	{
		String sql="insert into goodsstore(goodsid,storesum," +
				"safestoresum," +
				"remarks)values('"+goodsStore.getGoodsid()+"','"+goodsStore.getStoresum()+"','"+goodsStore.getSafestoresum()+"','"+goodsStore.getRemarks()+"')";
	
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("库存信息插入--------成功！！！！");
		}catch(Exception e)
		{
			System.out.println("库存信息插入--------失败！！！！");
		}
	}
	/*----------完成对库存信息的查询----------*/
	public Vector selectGoodsStore(GoodsStore goodsStore,int type)
	{
		Vector allGoodsStore=new Vector();
		String sql="";
		if(type==1)//说明按库存编号查询
		{
		 sql="select * from goodsstore where id="+goodsStore.getId();
		}
		if(type==2)//说明按商编号进行查询
		{
			sql="select * from goodsstore where goodsid='"+goodsStore.getGoodsid()+"'";
		}
		try
		{
			ResultSet rs=stmt.executeQuery(sql);//执行查询
			while(rs.next())
			{
				GoodsStore gs=new GoodsStore();
				gs.setId(rs.getInt("id"));
				gs.setGoodsid(rs.getInt("goodsid"));
				gs.setStoresum(rs.getInt("storesum"));
				gs.setSafestoresum(rs.getInt("safestoresum"));
				gs.setRemarks(rs.getString("remarks"));
				allGoodsStore.add(gs);
				System.out.println("库存信息查询------成功！！！！");
				
			}
			
		}catch(Exception e)
		{
			e.printStackTrace();
			System.out.println("库存信息查询------失败！！！！");
		}
		
		return allGoodsStore;
		
	}
	
	/*--------------完成对库存信息的修改----------*/
	public void updateGoodsStore(GoodsStore goodsStore)
	{
		String sql="update goodsstore set goodsid='"+goodsStore.getGoodsid()+"'," +
				"storesum='"+goodsStore.getStoresum()+"',safestoresum='"+goodsStore.getSafestoresum()+"'," +
				"remarks='"+goodsStore.getRemarks()+"' where id="+goodsStore.getId();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("库存信息修改------成功!!!!");
		}catch(Exception e)
		{
			System.out.println("库存信息修改------失败!!!!");
		}
	}
	/*-----------------完成对库存信息的删除------------------*/
	public void deleteGoodsStore(GoodsStore goodsStore)
	{
		String sql="delete from goodsstore where id="+goodsStore.getId();
		try
		{
		stmt.executeUpdate(sql);
		System.out.println("库存信息删除------成功!!!!");
		}catch(Exception e)
		{
			System.out.println("库存信息删除------失败!!!!");
		}
	}
	/*------------------完成对库存信息的统计------------------*/
	
	
	 /*------查询分页-----*/
	  
	public List getAllInfo(int pagesize,int nowpage) throws Exception
	{List allinfo=new ArrayList();
	String sql="select * from goodsstore order by id";	
	  ResultSet rs=stmt.executeQuery(sql);
	  rs.last();// 定位到最后一条记录
	  int rows=rs.getRow();
	  int num=pagesize;
	  int pagecount=rows/pagesize;//总页数
	  if(rows%pagesize>0){pagecount++;}
	  if(nowpage>0&&nowpage<=pagecount)
	  {
		if(nowpage==1){rs.beforeFirst();}
		if(nowpage>1){rs.absolute((nowpage-1)*pagesize);}
	  while(rs.next()&&num>0)
	  { 
		  GoodsStore gs=new GoodsStore();
		  gs.setId(rs.getInt("id"));
		  gs.setGoodsid(rs.getInt("goodsid"));
		  gs.setSafestoresum(rs.getInt("storesum"));
		gs.setSafestoresum(rs.getInt("safestoresum"));
		 gs.setRemarks(rs.getString("remarks"));
		 
		  
	    num--;
	    allinfo.add(gs);
	  }
	  return allinfo;
	 }
	  return null;
	}
  
	public int getcount()throws Exception
	{
		int count=0;
		String sql="select * from goodsstore order by id";
		 ResultSet rs=stmt.executeQuery(sql);
		 rs.last();
		 count=rs.getRow();
		return count;
	}
}