favoritedao.java

来自「一个完整的网络订餐系统」· Java 代码 · 共 280 行

package com.favorite.dao;

import java.sql.*;
import java.util.*;
import com.common.*;
import com.favorite.form.FavoriteBean;



public class FavoriteDao
{
  public FavoriteDao()
  {
  }


   public java.util.ArrayList getFavoriteListByStore(String userID)
   {

     java.util.ArrayList  favoriteList = new java.util.ArrayList();

     DBConnection dbc = null;
     Connection conn = null;
     Statement stmt = null;
     ResultSet rs = null;

     String strSQL = null;

     try
     {
       dbc = new DBConnection();
       conn = dbc.getDBConnection();
       stmt = conn.createStatement();

       strSQL =  " SELECT b.storeID,b.storeName,a.createDate,a.favoriteName FROM Favorite a,store b";
       strSQL += " WHERE favoriteType=1 AND memberID='"+userID+"' AND a.favoriteID=b.storeID ORDER BY a.createDate,b.storeID";

       FavoriteBean favorite  = null;
       rs = stmt.executeQuery(strSQL);
       while(rs.next())
       {
         favorite  = new FavoriteBean();

         String storeID = rs.getString("storeID");
         String storeName = rs.getString("storeName");
         String memo = rs.getString("favoriteName");
         String createdate = rs.getString("createdate");

         favorite.setDate(createdate);
         favorite.setMemo(memo);
         favorite.setID(storeID);
         favorite.setName(storeName);

         favoriteList.add(favorite);
       }
     }
     catch (Exception e)
     {
       e.printStackTrace();
       System.out.println("\n" + e.toString() + "获得收藏信息" + strSQL); /////错误处理！
     }
     finally
     {
       try
       {
         if (stmt != null)  stmt.close();
         if (rs != null)  rs.close();
         if (conn != null)  dbc.closeDBConnection(conn);
       }
       catch (Exception ex) {}
     }

     return favoriteList;
   }

   public java.util.ArrayList getFavoriteListByFood(String userID)
   {

     java.util.ArrayList  favoriteList = new java.util.ArrayList();

     DBConnection dbc = null;
     Connection conn = null;
     Statement stmt = null;
     ResultSet rs = null;

     String strSQL = null;

     try
     {
       dbc = new DBConnection();
       conn = dbc.getDBConnection();
       stmt = conn.createStatement();

       strSQL =  " SELECT b.foodID,b.foodName,a.createDate,a.favoriteName FROM Favorite a,food b";
       strSQL += " WHERE favoriteType=2 AND memberID='"+userID+"' AND a.favoriteID=b.foodID ORDER BY a.createDate,b.foodID";

       FavoriteBean favorite  = null;
       rs = stmt.executeQuery(strSQL);
       while(rs.next())
       {
         favorite  = new FavoriteBean();

         String foodID = rs.getString("foodID");
         String foodName = rs.getString("foodName");
         String memo = rs.getString("favoriteName");
         String createdate = rs.getString("createdate");

         favorite.setDate(createdate);
         favorite.setMemo(memo);
         favorite.setID(foodID);
         favorite.setName(foodName);

         favoriteList.add(favorite);
       }
     }
     catch (Exception e)
     {
       e.printStackTrace();
       System.out.println("\n" + e.toString() + "获得收藏信息" + strSQL); /////错误处理！
     }
     finally
     {
       try
       {
         if (stmt != null)  stmt.close();
         if (rs != null)  rs.close();
         if (conn != null)  dbc.closeDBConnection(conn);
       }
       catch (Exception ex) {}
     }

     return favoriteList;
   }


   public java.util.ArrayList getFavoriteListByFoodSet(String userID)
   {

     java.util.ArrayList  favoriteList = new java.util.ArrayList();

     DBConnection dbc = null;
     Connection conn = null;
     Statement stmt = null;
     ResultSet rs = null;

     String strSQL = null;

     try
     {
       dbc = new DBConnection();
       conn = dbc.getDBConnection();
       stmt = conn.createStatement();

       strSQL =  " SELECT b.foodSetID,b.alias,a.createDate,a.favoriteName FROM Favorite a,foodSet b";
       strSQL += " WHERE favoriteType=3 AND memberID='"+userID+"' AND a.favoriteID=b.foodSetID ORDER BY a.createDate,b.foodSetID";

       FavoriteBean favorite  = null;
       rs = stmt.executeQuery(strSQL);
       while(rs.next())
       {
         favorite  = new FavoriteBean();

         String foodSetID = rs.getString("foodSetID");
         String foodSetName = rs.getString("alias");
         String memo = rs.getString("favoriteName");
         String createdate = rs.getString("createdate");

         favorite.setDate(createdate);
         favorite.setMemo(memo);
         favorite.setID(foodSetID);
         favorite.setName(foodSetName);

         favoriteList.add(favorite);
       }
     }
     catch (Exception e)
     {
       e.printStackTrace();
       System.out.println("\n" + e.toString() + "获得收藏信息" + strSQL); /////错误处理！
     }
     finally
     {
       try
       {
         if (stmt != null)  stmt.close();
         if (rs != null)  rs.close();
         if (conn != null)  dbc.closeDBConnection(conn);
       }
       catch (Exception ex) {}
     }

     return favoriteList;
   }



   public int delFavorite(String userID,String favoriteID)
   {
     int result = 0;

     DBConnection dbc = null;
     Connection conn = null;
     Statement stmt = null;


     String strSQL = null;

     try
     {
       dbc = new DBConnection();
       conn = dbc.getDBConnection();
       stmt = conn.createStatement();

       strSQL =  " DELETE Favorite  WHERE  memberID='"+userID+"' AND favoriteID='"+favoriteID+"'";

       result = stmt.executeUpdate(strSQL);
     }
     catch (Exception e)
     {
       result = -1;
       e.printStackTrace();
       System.out.println("\n" + e.toString() + "删除收藏信息" + strSQL); /////错误处理！
     }
     finally
     {
       try
       {
         if (stmt != null)  stmt.close();
         if (conn != null)  dbc.closeDBConnection(conn);
       }
       catch (Exception ex) {}
     }

     return result;
   }


   public int addFavorite(String userID,String favoriteID,String favoriteName,int type)
   {
     int result = 0;

     DBConnection dbc = null;
     Connection conn = null;
     Statement stmt = null;


     String strSQL = null;

     try
     {
       dbc = new DBConnection();
       conn = dbc.getDBConnection();
       stmt = conn.createStatement();

       strSQL =  " INSERT Favorite(favoriteID,memberID,createDate,favoriteName,favoriteType) ";
       strSQL += " VALUES('"+favoriteID+"','"+userID+"',getDate(),'"+favoriteName+"',"+type+")" ;

       result = stmt.executeUpdate(strSQL);
     }
     catch (Exception e)
     {
       result = -1;
       e.printStackTrace();
       System.out.println("\n" + e.toString() + "添加收藏信息" + strSQL); /////错误处理！
     }
     finally
     {
       try
       {
         if (stmt != null)  stmt.close();
         if (conn != null)  dbc.closeDBConnection(conn);
       }
       catch (Exception ex) {}
     }

     return result;
   }
}