shopopiniondao.java

一个仿造淘宝的jsp网站。功能比较完善

package com.jc.taobao.gjj.dao;

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

import com.jc.taobao.gjj.db.DBManager;
import com.jc.taobao.gjj.entity.ShopInfo;
import com.jc.taobao.gjj.entity.Shopopinion;

public class ShopopinionDAO {
	DBManager dm = new DBManager();
	public int delete(Integer id) {
		String sql = "delete from shopopinion where opinionid=" + id;
		return dm.updb(sql);
	}

	public int merge(Shopopinion shopop) {
		String sql = "update shopopinion set sid=" + shopop.getSid() + ",userid="
				+ shopop.getUserid() + ",title='" + shopop.getTitle()
				+ "',note='" + shopop.getNote() + "',rate='"
				+ shopop.getRate() +"','"+shopop.getOptime()+"' where opinionid=" + shopop.getOpinionid();
		return dm.updb(sql);
	}

	public int save(Shopopinion shopop) {
		String sql = "insert into shopopinion values("
				+ shopop.getSid() + "," + shopop.getUserid() + ",'"
				+ shopop.getTitle() + "','" + shopop.getNote() + "','"
				+ shopop.getRate()+"','"+shopop.getOptime()+"') ";
		return dm.updb(sql);
	}
	private List<Shopopinion> query(String sql) {//查询
		List<Shopopinion> list = new ArrayList<Shopopinion>();
		ResultSet rs = dm.getRs(sql);
		try {
			while (rs.next()) {
				Shopopinion shopop = new Shopopinion();
				shopop.setOpinionid(rs.getInt("opinionid"));
				shopop.setSid(rs.getInt("sid"));
				shopop.setUserid(rs.getInt("userid"));
				shopop.setTitle(rs.getString("title"));
				shopop.setNote(rs.getString("note"));
				shopop.setRate(rs.getString("rate"));
				shopop.setOptime(rs.getString("optime"));
				list.add(shopop);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return list;
	}
	
	public List<Shopopinion> queryallshopopinion()
	{
		String sql="select * from shopopinion";
		return query(sql);
	}
	public List<Shopopinion> querytop5shopopinion(Integer shopid)
	{
		String sql="select top 5 * from shopopinion where sid="+shopid+" order by optime desc";
		return query(sql);
	}
}