itementity.java

信息发布 发布系统 动态的菜单 和 信息统计

package com.xuntian.material.bean.entity;

import com.xuntian.material.sql.baseinfo.ItemSQL;
import com.xuntian.material.util.DateTools;

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

import com.xuntian.material.bean.ItemBean;
import com.xuntian.material.bean.UserBean;
import com.xuntian.material.exception.ConnectPoolException;

public class ItemEntity extends BaseEntity {
    private ItemBean item;

    public ItemEntity(ItemBean item) {
        this.item = item;
    }

    public ItemBean getItemBean() {
        return item;
    }

    public List<ItemBean> queryList() throws ConnectPoolException,
            SQLException {
    	List<ItemBean> list = new ArrayList<ItemBean>();
        ResultSet rs=getDatabase().executeQuery(ItemSQL.QUERY_ITEM,null);
        while (rs.next()) {
            item = new ItemBean();
            fill(rs);
            list.add(item);
        }
        rs.close();
        return list;
    
    }

    public List<List<String>> queryAll() throws ConnectPoolException {
        return getDatabase().query(ItemSQL.QUERY_ITEM);
    }

    public List<List<String>> queryAll(String[] columns, UserBean user)
            throws ConnectPoolException {
        
        return null;
    }

    public void fill() throws ConnectPoolException, SQLException {
        String itemID = item.getItemID();
        fill(itemID);
    }

    private void fill(String itemID) throws ConnectPoolException, SQLException {
        List<String> parameterList = new ArrayList<String>();
        parameterList.add(itemID);
        ResultSet rs = getDatabase().executeQuery(ItemSQL.QUERY_ITEM_WITH_ID,
                parameterList);
        if (rs.next()) {
            fill(rs);
        }
        rs.close();
    }

    private void fill(ResultSet rs) throws SQLException {
        item.setItemID(rs.getString(ItemSQL.COLUMN_ID));
        
        item.setItemName(rs.getString(ItemSQL.COLUMN_NAME));
        
    }

    public int save() throws ConnectPoolException {
        List<String> parameterList = new ArrayList<String>();
        parameterList.add(item.getItemName());
        String itemID = item.getItemID();
        if(item.getItemName()==null || item.getItemName().equals("")){
        	return -2;
        }else{
        if (itemID == null || itemID.equals("")) {
            return getDatabase().executeUpdate(ItemSQL.INSERT_ITEM,
                    parameterList);
        } else {
            parameterList.add(itemID);
            return getDatabase().executeUpdate(ItemSQL.UPDATE_ITEM,
                    parameterList);
        }
        }
    }

    public int delete(String[] itemIDs) throws ConnectPoolException {
        return getDatabase().executeUpdate(ItemSQL.getDeleteItem(itemIDs));
    }
    
}