itemmanager.java

java编写小型超市管理系统+数据库.用于小型超市简单的货品进存销

package com.wish;

import java.util.Vector;
import java.sql.*;
//物品管理类
public class ItemManager 
{
	@SuppressWarnings("unchecked")
	public Vector getItem()
	{
		Vector v =new Vector();
		Connection cn=ConnectionDB.getCon();
		Statement st=null;
		ResultSet rs=null;
		
		try {
			String sql="select * from itemlist";
			st=cn.createStatement();
			rs=st.executeQuery(sql);
			while(rs.next())
			{	Item item=new Item();
				String item_id=rs.getString("item_id");
				String item_name=rs.getString("item_name");
				String item_dw=rs.getString("item_dw");
				String item_dj=rs.getString("item_dj");
				String item_kind=rs.getString("item_kind");
				
				item.setItem_id(item_id);
				item.setItem_name(item_name);
				item.setItem_dw(item_dw);
				item.setItem_dj(item_dj);
				item.setItem_kind(item_kind);
				
				v.add(item);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
			ConnectionDB.close(rs);
			ConnectionDB.close(st);
			ConnectionDB.close(cn);
		return v;
	}
	@SuppressWarnings("unchecked")
	//得到一条物品记录
	public Vector get1(String n)
	{
		Vector v =new Vector();
		Connection cn=ConnectionDB.getCon();
		Statement st=null;
		ResultSet rs=null;
		
		try {
			String sql="select item_name,item_dw,item_dj from itemlist where item_id='"+n+"'";
			st=cn.createStatement();
			rs=st.executeQuery(sql);
			while(rs.next())
			{	Item item=new Item();
			
				String item_name=rs.getString("item_name");
				String item_dw=rs.getString("item_dw");
				String item_dj=rs.getString("item_dj");

				item.setItem_name(item_name);
				item.setItem_dw(item_dw);
				item.setItem_dj(item_dj);
				
				v.add(item);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
			ConnectionDB.close(rs);
			ConnectionDB.close(st);
			ConnectionDB.close(cn);
		return v;
	}

	@SuppressWarnings("unchecked")
	//查询物品种类
	public Vector queryKind(String n)
	{
		Vector v =new Vector();
		Connection cn=ConnectionDB.getCon();
		Statement st=null;
		ResultSet rs=null;
		
		try {
			String sql="select * from itemlist where item_kind='"+n+"'";
			st=cn.createStatement();
			rs=st.executeQuery(sql);
			while(rs.next())
			{	Item item=new Item();
				String item_id=rs.getString("item_id");
				String item_name=rs.getString("item_name");
				String item_dw=rs.getString("item_dw");
				String item_dj=rs.getString("item_dj");
				String item_kind=rs.getString("item_kind");
				
				item.setItem_id(item_id);
				item.setItem_name(item_name);
				item.setItem_dw(item_dw);
				item.setItem_dj(item_dj);
				item.setItem_kind(item_kind);
				
				v.add(item);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
			ConnectionDB.close(rs);
			ConnectionDB.close(st);
			ConnectionDB.close(cn);
		return v;
	}
	@SuppressWarnings("unchecked")
	//查询某一条物品记录
	public Vector queryItem(String n)
	{
		Vector v =new Vector();
		Connection cn=ConnectionDB.getCon();
		Statement st=null;
		ResultSet rs=null;
		
		try {
			String sql="select * from itemlist where item_name='"+n+"'";
			st=cn.createStatement();
			rs=st.executeQuery(sql);
			while(rs.next())
			{	Item item=new Item();
				String item_id=rs.getString("item_id");
				String item_name=rs.getString("item_name");
				String item_dw=rs.getString("item_dw");
				String item_dj=rs.getString("item_dj");
				String item_kind=rs.getString("item_kind");
				
				item.setItem_id(item_id);
				item.setItem_name(item_name);
				item.setItem_dw(item_dw);
				item.setItem_dj(item_dj);
				item.setItem_kind(item_kind);
				
				v.add(item);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
			ConnectionDB.close(rs);
			ConnectionDB.close(st);
			ConnectionDB.close(cn);
		return v;
	}	
	//删除方法
	public boolean delItem(String item_id)
	   {
		   boolean flag = false;
		   Connection cn = ConnectionDB.getCon();
		   String delSql = "delete from itemlist where item_id= ?";
		   try {
			PreparedStatement ps = cn.prepareStatement(delSql);
			ps.setString(1,item_id);
			int n=ps.executeUpdate();
			if(n>0)flag = true;
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return flag;
	   }
	//查询种类方法
	
	//插入方法
	public boolean addItem(String[]data)
	   {
		   boolean flag = false;
		   Connection cn = ConnectionDB.getCon();
		   String addSql = "insert into itemlist values(?,?,?,?,?)";
		   try {
			PreparedStatement ps = cn.prepareStatement(addSql);
			for(int i=1;i<=5;i++)
			ps.setString(i,data[i-1]);
			int n=ps.executeUpdate();
			if(n>0)flag = true;
		} catch (SQLException e) {
			System.out.print("插入错误");
		}
		   return flag;
	   }
	   //更新方法
	   public void updateItem(Item item)
	   {
		   Connection con = ConnectionDB.getCon();
		   String updSql = "update itemlist set item_name=?,item_dw=?,item_dj=?,item_kind=? where item_id=?";
		   try {
			PreparedStatement ps = con.prepareStatement(updSql);
			ps.setString(1,item.getItem_name());
			ps.setString(2,item.getItem_dw());
			ps.setString(3,item.getItem_dj());
			ps.setString(4,item.getItem_kind());
			ps.setString(5,item.getItem_id());
			ps.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	   }
}