reviewdao.java

java开发购物车+网上书城

package com.xaccp.aj3q8073.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import com.xaccp.aj3q8073.db.DBManager;
import com.xaccp.aj3q8073.db.RowMapper;
import com.xaccp.aj3q8073.vo.BookReviewVo;

public class ReviewDao {
	DBManager db=new DBManager();
	
	/**
	 * 查询所有的图书评论
	 * @return
	 */
	public List findAllReview(){
		String sql="select b.bookName,v.reviewId,v.reviewText,reviewTime,reviewContent from bookinfo as b inner join " +
				"bookreview as v on b.bookId=v.bookId order by reviewId desc";
		List list= db.queryForList(sql, null, new ReviewMapper());
		return list;
	}
	
	/**
	 * 根据输入信息查找恶意评论
	 * @param txt
	 * @return
	 */
	public List findBadReview(String txt){
		String sql="select b.bookName,v.reviewId,v.reviewText,reviewTime,reviewContent from bookInfo as b inner join bookreview as v " +
				"on b.bookId=v.bookId where v.reviewContent like ? order by reviewId desc";
		Object[] obj=new Object[]{"%"+txt+"%"};
		List list= db.queryForList(sql, obj, new ReviewMapper());
		return list;
	}
	
	/**
	 * 根据id删除评论信息
	 * @param id
	 * @return
	 */
	public int delReview(int id){
		String sql="delete from bookReview where reviewId=?";
		Object[] obj=new Object[]{id};
		int i= db.executeUpdate(sql, obj);
		return i;
	}
	
	class ReviewMapper implements RowMapper{
		
		public Object rowMapper(ResultSet rt) throws SQLException {
			BookReviewVo vo=new BookReviewVo();
			vo.setReviewId(rt.getInt("reviewId"));
//			vo.setBookId(rt.getInt("bookId"));
//			vo.setUserId(rt.getInt("userId"));
			vo.setReviewText(rt.getString("reviewText"));
			vo.setReviewContent(rt.getString("reviewContent"));
			vo.setReviewTime(rt.getString("reviewTime"));
			vo.setBookName(rt.getString("bookName"));
			return vo;
		}
		
	}
}