contentsmanagerdao.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.BookInfoVo;
import com.xaccp.aj3q8073.vo.BookShelfVo;

/**
 * 栏目管理的dao
 * 
 * @author Administrator
 * 
 */
public class ContentsManagerDao {
	DBManager db = new DBManager();

	/**
	 * 根据shelfId查找出货架名称
	 * @param shelfId
	 * @return
	 */
	public BookShelfVo findShelfName(int shelfId){
		String sql="select * from bookshelf where shelfId=?";
		Object obj[]=new Object[]{shelfId};
		BookShelfVo vo=  (BookShelfVo) db.queryForObject(sql, obj, new BookshelfMapper());
		return vo;
	}
	/**
	 * 查找一级目录
	 * 
	 * @return
	 */
	public List findOneBookshelf() {
		String sql = "select * from bookshelf where parentShelfId=?";
		Object[] obj = new Object[] { 0 };
		List list = db.queryForList(sql, obj, new BookshelfMapper());
		return list;
	}

	/**
	 * 查找二级目录
	 * @param name
	 * @return
	 */
	public List findTwoBookshelfName(int shelfId) {
		String sql = "select * from bookshelf where parentShelfId=?" ;
//				"(select shelfId from bookshelf where parentShelfId=? and shelfName=?) ";
		Object obj[]=new Object[]{shelfId};
		List list= db.queryForList(sql, obj, new BookshelfMapper());
		return list;
	}
	
	/**
	 * 添加新栏目
	 * @param parentId
	 * @param shelfName
	 * @return
	 */
	public int saveContent(BookShelfVo vo){
		String sql="insert into bookshelf values(default,?,?)";
		Object obj[]=new Object[]{vo.getParentShelfId(),vo.getShelfName()};
		int i= db.executeUpdate(sql, obj);
		return i;
	}
	
	/**
	 * 添加新栏目之前先查询是否存在该名称
	 * @param name
	 * @return
	 */
	public List findContentName(String name){
		String sql="select * from bookshelf where shelfName=?";
		Object[] obj=new Object[]{name};
		List list= db.queryForList(sql, obj, new BookshelfMapper());
		return list;
	}
	
	/**
	 * 添加一级目录
	 * @param shelfName
	 * @return
	 */
	public int saveBrotherContent(String shelfName){
		String sql="insert into bookshelf values(default,?,?)";
		Object obj[]=new Object[]{0,shelfName};
		int i= db.executeUpdate(sql, obj);
		return i;
	}
	
	/**
	 * 更新一级目录的名称
	 * @param shelfName
	 * @param shelfId
	 * @return
	 */
	public int editContent(String shelfName,int shelfId){
		String sql="update bookshelf set shelfName=? where shelfId=?";
		Object[] obj=new Object[]{shelfName,shelfId};
		//TODO...图书表中的名称也要修改
		int i= db.executeUpdate(sql, obj);
		return i;
	}
	
	/**
	 * 根据shelfId删除一级目录
	 * @param shelfId
	 * @return
	 */
	public int removeOneContentByShelfId(int shelfId){
		String sql="delete from bookshelf where shelfId=?";
		Object[] obj=new Object[]{shelfId};
		int i=db.executeUpdate(sql, obj);
		return i;
	}
	
	/**
	 * 在删除二级目录前先查询它有没有被其它数引用
	 * @param shelfId
	 * @return
	 */
	public List findBook(int shelfId){
		String sql="select bookId from bookInfo where shelfId=?";
		Object[] obj=new Object[]{shelfId};
		List list= db.queryForList(sql, obj, new BookInfoMapper());
		return list;
	}
	
	class BookInfoMapper implements RowMapper{

		public Object rowMapper(ResultSet rt) throws SQLException {
			BookInfoVo vo=new BookInfoVo();
			vo.setBookId(rt.getInt("bookId"));
			return vo;
		}
		
	}
	
}
class BookshelfMapper implements RowMapper {

	public Object rowMapper(ResultSet rt) throws SQLException {
		BookShelfVo vo = new BookShelfVo();
		vo.setShelfId(rt.getInt("shelfId"));
		vo.setParentShelfId(rt.getInt("parentShelfId"));
		vo.setShelfName(rt.getString("shelfName"));
		return vo;
	}
}