stockshoppingtreat.java

是一个企业的进销存系统。账号问1001密码为123456

package com.jxc.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

import com.jxc.vo.Shopping;
import com.jxc.vo.StockShopping;
import com.jxc.vo.Vo;

public class StockShoppingTreat implements Dao {

	public boolean deleteById(Connection conn, int id) {
		// TODO Auto-generated method stub
		return false;
	}

	public boolean insert(Connection conn, Vo vo) {
		// TODO Auto-generated method stub
		boolean flat=false;
		StockShopping shop=(StockShopping)vo;
		PreparedStatement pstm=null;
		int rs=0;
		String sql="insert into stockshopping(sid,snum)values(?,?)";
		try {
			pstm=conn.prepareStatement(sql);
			pstm.setString(1, shop.getSid());
			pstm.setInt(2, shop.getSnum());
			rs=pstm.executeUpdate();
			if(rs!=0)
				flat=true;
			else 
				flat=false;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		return flat;
	}

	public ArrayList<StockShopping> selectAll(Connection conn) {
		ArrayList<StockShopping> arr=new ArrayList<StockShopping>();
		PreparedStatement pstm=null;
		ResultSet rs=null;
		String sql="select sid,snum from stockshopping";
		try {
			pstm=conn.prepareStatement(sql);
			rs=pstm.executeQuery();
			while(rs.next()){
				StockShopping stock=new StockShopping();
			    stock.setSid(rs.getString(1));
				stock.setSnum(rs.getInt(2));
				arr.add(stock);
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null)
					rs.close();
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return arr;
	}

	public Vo selectById(Connection conn, int id) {
		// TODO Auto-generated method stub
		return null;
	}


	public boolean updateById(Connection conn,String sid, int num) {
		// TODO Auto-generated method stub
		boolean flat=false;
		PreparedStatement pstm=null;
		int rs=0;
		String sql="update stockshopping set snum=((select snum from stockshopping where sid=?)+?) where sid=?";
		try {
			pstm=conn.prepareStatement(sql);
			pstm.setString(1, sid);
			pstm.setInt(2, num);
			pstm.setString(3, sid);
			rs=pstm.executeUpdate();
			if(rs!=0)
				flat=true;
			else
				flat=false;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return flat;
	}
	public boolean selectId(Connection conn,String sid){
		boolean flat=false;
		PreparedStatement pstm=null;
		ResultSet rs=null;
		String sql="select * from stockshopping where sid=?";
		try {
			pstm=conn.prepareStatement(sql);
			pstm.setString(1, sid);
			rs=pstm.executeQuery();
			if(rs.next())
				flat=true;
			else
				flat=false;
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null)
					rs.close();
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return flat;
		
	}
	public int selectsum(Connection conn,String sid){
		int i=0;
		PreparedStatement pstm=null;
		ResultSet rs=null;
		String sql="select snum from stockshopping where sid=?";
		try {
			pstm=conn.prepareStatement(sql);
			pstm.setString(1, sid);
			rs=pstm.executeQuery();
			if(rs.next())
				i=rs.getInt(1);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null)
					rs.close();
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		return i;
	}

	public ArrayList<StockShopping> selectJingbao(Connection conn) {
		ArrayList<StockShopping> arr=new ArrayList<StockShopping>();
		PreparedStatement pstm=null;
		ResultSet rs=null;
		String sql="select sid,snum from stockshopping where snum<10";
		try {
			pstm=conn.prepareStatement(sql);
			rs=pstm.executeQuery();
			while(rs.next()){
				StockShopping stock=new StockShopping();
			    stock.setSid(rs.getString(1));
				stock.setSnum(rs.getInt(2));
				arr.add(stock);
			}
		} catch (SQLException e) {
			
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null)
					rs.close();
				if(pstm!=null)
					pstm.close();
				if(conn!=null)
					conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return arr;
	}
}