quaryentity.java

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

package com.xuntian.material.bean.entity;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import com.xuntian.material.bean.MsgBean;
import com.xuntian.material.exception.ConnectPoolException;
import com.xuntian.material.sql.baseinfo.ItemSQL;

public class QuaryEntity extends BaseEntity {
	private MsgBean item;

    public QuaryEntity(MsgBean item) {
        this.item = item;
    }

    public MsgBean getMsgBean() {
        return item;
    }

    public List<List<String>> queryList() throws ConnectPoolException,
            SQLException {
    	List<List<String>> list = null;
        list=getDatabase().query(setSql(item),null);
    	//System.out.println(setSql(item));
        return list;
    
    }
     private String setSql(MsgBean bean){
    	 StringBuffer sql=new StringBuffer("select msg_id,msg_name,msg_date,item_name from view_msg_list where 1=1 ");
    	 if(bean.getItemId()!=null && bean.getItemId().trim().length()>0){
    		 sql.append(" and item_id="+bean.getItemId());
    	 }
    	 if(bean.getMsgName()!=null && bean.getMsgName().trim().length()>0){
    		 sql.append(" and msg_name like '%"+bean.getMsgName().trim()+"%'");
    	 }
    	 if(bean.getMsgContent()!=null && bean.getMsgContent().trim().length()>0){
    		 sql.append(" and msg_content like '%"+bean.getMsgContent().trim()+"%'");
    	 }
    	 if(bean.getMsgDate()!=null && bean.getMsgDate().length()>0){
    		 sql.append(" and msg_date='"+bean.getMsgDate().trim()+"'");
    	 }
    	 return sql.toString();
     }
     public void fill() throws ConnectPoolException, SQLException {
         String itemID = item.getMsgId();
         fill(itemID);
     }
     private void fill(String itemID) throws ConnectPoolException, SQLException {
         List<String> parameterList = new ArrayList<String>();
         parameterList.add(itemID);
         ResultSet rs = getDatabase().executeQuery("select * from view_msg_list where 1=1  AND msg_id=?",
                 parameterList);
         if (rs.next()) {
             fill(rs);
         }
         rs.close();
     }
     private void fill(ResultSet rs) throws SQLException {
         item.setMsgId(rs.getString("msg_id"));
         item.setMsgName(rs.getString("msg_name"));
         item.setMsgContent(rs.getString("msg_content"));
         item.setMsgDate(rs.getString("msg_date"));
         item.setItemName(rs.getString("item_name"));
     }

}