prodstoredaoimpl.java

利用java swing实现简单的单机版仓库管理

package control.dao.prodstore;

import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.util.ArrayList;

import utils.Keys;
import beans.ProdStore;

public class ProdStoreDAOImpl{
    public static String flag="";
    
    private Connection conn;
    private Statement stmt;
    private ResultSet rs;
    
    public ProdStoreDAOImpl(){
        
    }
    
   public ArrayList showAll(){
        ArrayList al=new ArrayList();
        ResultSet rs2=null;
        Statement stmt2=null;
        String pName2="";
        try{
            conn=this.getConn();
            stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_UPDATABLE);
            stmt2=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_UPDATABLE);
            rs=stmt.executeQuery("select * from ProdStore");
            int pSID=0,pID=0,pINum=0,pONum=0,pSNum=0;
            String pDate="";
            String pName="";
            while(rs.next()){
                pSID=rs.getInt("PSID");
                pID=rs.getInt("PID");
                pINum=rs.getInt("PINum");
                pONum=rs.getInt("PONum");
                pSNum=rs.getInt("PSNum");
                pDate=rs.getString("PSDate");
                
                rs2=stmt2.executeQuery("select pName from products where pID="+pID);
                if(rs2.next())
                    pName=rs2.getString("PName");
                else
                    pName="(没有相关产品)";

                ProdStore pd=new ProdStore(pSID,pName,pINum,pONum,pSNum,pDate);

                al.add(pd);
                
            }
            if(rs2 != null)
                rs2.close();
            if(stmt2 != null)
                stmt2.close();
            
        }catch(SQLException se){
            System.out.println(se.getMessage());
            return null;
        }finally{
           this.closeConn();
        }
        
        return al;
    }
    
   public Connection getConn(){
        try{
            Class.forName(Keys.connDriver);
            return DriverManager.getConnection(Keys.connUrl,Keys.connUsername,Keys.connPassword);
        }catch(ClassNotFoundException e){
            return null;
        }catch(SQLException se){
            return null;
        }
    }
    
    public void closeConn(){
        try{
            if(rs != null){
                rs.close();
            }
            if(stmt != null){
                stmt.close();
            }
            if(conn != null){
                conn.close();
            }
            
        }catch(SQLException e){
            System.out.println(e.getMessage());
        }
    }

}