breeddao.java

来自「java编写的网络购物简洁版」· Java 代码 · 共 266 行

package shop;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Collection;

public class breedDAO implements breedInterface {

	DBTools dao = new DBTools();
	/* （非 Javadoc）
	 * @see shop.breedInterface#addleibie(shop.breedBean)
	 */
	
	public boolean addleibie(breedBean b)
	{
		 Connection con  = null;

	        PreparedStatement pstmt = null;

	        boolean flag = false;
	        try {

	            con = dao.getConnection();   

	            pstmt = con.prepareStatement(
	            "insert into breed(breedName,bewrite) values(?,?)");
	            pstmt.setString(1,b.getBreedName());
	            pstmt.setString(2,b.getBewrite());

	            int rows = pstmt.executeUpdate();

	            if(rows>0)
	            {
	                flag = true;
	            }
	            else
	            {
	                flag = false;
	            }

	        } catch (Exception ex) {

	            ex.printStackTrace();
	        }finally{
	        	dao.close(con,pstmt);
	        }

	        return flag;
		
	}
	/* （非 Javadoc）
	 * @see shop.breedInterface#selectLeibei()
	 */
	public Collection selectLeibei()
    {
    	 Connection con = null;
         PreparedStatement pstmt = null;
         ResultSet rs = null; 
         Collection <breedBean> LeibeiList = new ArrayList<breedBean>(); 
         try {
        	 con = dao.getConnection();
			pstmt = con.prepareStatement("select breedName from breed");
			rs = pstmt.executeQuery();
			while(rs.next())
			{
				breedBean s = new breedBean();
				s.setBreedName(rs.getString(1));
				LeibeiList.add(s);
			}
		} catch (Exception e) {
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{

			dao.close(con, pstmt, rs);

    }
         return LeibeiList;
    }
	/* （非 Javadoc）
	 * @see shop.breedInterface#selectleibeiID(java.lang.String)
	 */
	public breedBean selectleibeiID(String s)
    {
    	 Connection con = null;
         PreparedStatement pstmt = null;
         ResultSet rs = null; 
         breedBean bBean = new breedBean();
         try {
        	 con = dao.getConnection();
			pstmt = con.prepareStatement("select breedID from breed where breedName=?");
			 pstmt.setString(1,s);
			 rs = pstmt.executeQuery();
	        
	         if(rs.next())
	         {
	        	
	        	 bBean.setBreedID(rs.getInt(1));
	         }
		} catch (Exception e) {
			e.printStackTrace();
		}finally{

			dao.close(con, pstmt, rs);

    }
        
        
         return bBean;
    }
	/* （非 Javadoc）
	 * @see shop.breedInterface#selectbreedName(int)
	 */
	 public breedBean selectbreedName(int s)
	    {
	    	 Connection con = null;
	         PreparedStatement pstmt = null;
	         ResultSet rs = null; 
	         //Collection breedNameList = new ArrayList(); 
	         breedBean bBean = new breedBean();
	         try {
	        	 con = dao.getConnection();
				pstmt = con.prepareStatement(
						"select breedName from breed where breedID=(select breedID from product where productID = ?)");
				pstmt.setInt(1,s);
				 rs = pstmt.executeQuery();
		        
		        if(rs.next())
		        {
		        	
		        	bBean.setBreedName(rs.getString(1));
		        } 	 	        
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}finally{

	        	dao.close(con, pstmt, rs);

	    }
	        
	        
	         return bBean;
	    }
	 /* （非 Javadoc）
	 * @see shop.breedInterface#getAllLeibei()
	 */
	 public Collection getAllLeibei()
	    {
	    	 Connection con = null;
	         PreparedStatement pstmt = null;
	         ResultSet rs = null; 
	         Collection <breedBean> LeibeiList = new ArrayList<breedBean>();   
	         try {
	        	 con = dao.getConnection();
				pstmt = con.prepareStatement("select * from breed");
				rs = pstmt.executeQuery();
				while(rs.next())
				{
					breedBean s = new breedBean();
					s.setBreedID(rs.getInt(1));
					s.setBreedName(rs.getString(2));
					s.setBewrite(rs.getString(3));
					LeibeiList.add(s);
				}
			} catch (SQLException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}finally{

	        	dao.close(con, pstmt, rs);

	    }
	         return LeibeiList;
	    }
	 /* （非 Javadoc）
	 * @see shop.breedInterface#delleibie(java.lang.String)
	 */
	 public boolean delleibie(String name){
	    	
	        Connection con  = null;

	       PreparedStatement pstmt = null;

	       boolean flag = false;

	       try {

	           con = dao.getConnection();   

	           pstmt = con.prepareStatement(
	            "delete from breed where breedName = ?");

	           pstmt.setString(1,name);   

	           int rows = pstmt.executeUpdate();

	           if(rows>0)
	           {
	               flag = true;
	           }
	           else
	           {
	               flag = false;
	           }

	       } catch (Exception ex) {

	           ex.printStackTrace();
	       }finally{
	     	  
	         	  dao.close(con, pstmt);   
	       }

	       return flag;

	     }
	 public boolean delLeibie_chanpin(int leibieID)
	 {
		 Connection con  = null;
		 
		Statement stmt = null; 
		 
		 boolean flag = false;
		 
		
		 
		 con = dao.getConnection();   
		 try {
			 con.setAutoCommit(false);
			 
			 String sql1 = "delete from product where breedID = "+ leibieID;
			 String sql2 = "delete from breed where breedID = " + leibieID;
			stmt = con.createStatement();
			
			stmt .executeUpdate(sql1);
			
			stmt.executeUpdate(sql2);
			
			
			
			 stmt.executeBatch();
			
			con.commit();
			flag = true;
		} catch (Exception e) {
			try {
				con.rollback();
			} catch (SQLException e1) {
				// TODO 自动生成 catch 块
				e1.printStackTrace();
			}
			// TODO 自动生成 catch 块
			e.printStackTrace();
		}finally{
	     	  
       	  dao.close(con,stmt);   
     }
		
		 return flag;
	 }
}