favoritedao.java

大象购物管理程序

package com.shopping.dao;

import java.sql.*;
import java.util.*;

import com.comm.db.*;
import com.comm.vo.*;

public class FavoriteDao {

    public void add(GenericVO gvo) throws SQLException {
        String userId = gvo.getItemStr("USER_ID");
        String goods_id = gvo.getItemStr("GOODS_ID");

        Vector param = new Vector();
        String sql = "INSERT INTO favorite (user_id, goods_id) VALUES (?, ?)";
        param.addElement(userId);
        param.addElement(goods_id);

        DBFactory.getDBI().execute(sql, param);
    }

    public void delete(int favoriteId) throws SQLException {
        String sql = "DELETE FROM favorite WHERE favorite_id=" + favoriteId;

        DBFactory.getDBI().execute(sql);
    }

    public ListVO search(GenericVO gvo) throws SQLException {
        String userId = gvo.getItemStr("USER_ID");

        Vector param = new Vector();
        StringBuffer sb = new StringBuffer();

        sb.append("SELECT f.*, gs.name, gs.price2, gs.sphoto, b.logo1 " +
                  "FROM favorite f, goods gs, brand b " +
                  "WHERE f.goods_id=gs.goods_id AND gs.brand_id=b.brand_id ");
        if (userId.length() > 0) {
            sb.append(" AND user_id = ? ");
            param.addElement(userId);
        }
        sb.append(" ORDER BY favorite_id DESC");
        return DBFactory.getDBI().getResult(sb.toString(), param,
                                            gvo.getListVO());
    }
}