import java.lang.reflect.Method;
import java.sql.Timestamp;
import org.apache.solr.client.solrj.SolrQuery;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.common.SolrInputDocument;
import com.entity.Good;

@SuppressWarnings("deprecation")
public class Solr {
        private static HttpSolrServer solrServer;

        static {
            //注意请求地址格式：浏览器中的地址有 ‘#’，需要把‘#’去掉！
            solrServer = new HttpSolrServer("http://localhost:8983/solr/hjz");
            solrServer.setConnectionTimeout(5000);
        }

        /**
         * 添加单个文档 。
         * 
         * @param article 文章对象
         * @param articleAddon 文章正文对象
         */
        public static void insert(Good good) {
            SolrInputDocument doc = new SolrInputDocument();
            doc.addField("id", good.getId());
            doc.addField("name", good.getName());
            doc.addField("number", good.getNumber());
            doc.addField("updateTime", good.getUpdateTime());
            
            try {
                solrServer.add(doc);
                solrServer.commit();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        /**
         * 根据文档id删除文档 。
         */
        public static void deleteById(String id) {
            try {
                solrServer.deleteById(id+"");
                solrServer.commit();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        /**
         * 删除所有文档，为安全起见，使用时再解注函数体 。
         */
        public static void deleteAll() {
            try {
                solrServer.deleteByQuery("*:*");
                solrServer.commit();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        /**
         * 更新文档，其实也是通过insert操作来完成 。
         * 
         * @param article 文章对象
         * @param articleAddon 文章内容对象，如果不更新正文，可以为null。
         */
        public static void update(Good good) {
            insert(good);
        }
        
        /**
         * 根据文档id查询单个文档 。
         * @return 
         */
        public static <T> T getById(int id, Class<T> clazz) {
            SolrQuery query = new SolrQuery();
            query.setQuery("id:" + id);
            
            try {
                QueryResponse rsp = solrServer.query(query);
                return rsp.getBeans(clazz).get(0);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }    
        
        /**
         * @param obj 对象索引
         * @param idName 主键名称
         */
        public static void deleteByObject(Object obj, String idName){
            try {
                Class<?> clazz = obj.getClass();
                //将idName的首字母变成大写
                if(Character.isLowerCase(idName.charAt(0))) idName = Character.toUpperCase(idName.charAt(0)) + idName.substring(1);
                Method method = clazz.getMethod("get"+idName);
                String idValue = (String) method.invoke(obj);
                deleteById(idValue);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        public static void main(String[] args){
            Good good = new Good("123", 9999, "hjzgg5211314", new Timestamp(System.currentTimeMillis()));
            //Solr.update(good);
            //System.out.println(Solr.getById(123, Good.class));
            deleteByObject(good, "id");
        }
}

import java.sql.Timestamp;

import org.apache.solr.client.solrj.beans.Field;

public class Good{
    @Field("id")
    private String id;
    @Field("number")
    private int number;
    @Field("name")
    private String name;
    @Field("updateTime")
    private Timestamp updateTime;
    
    @Override
    public String toString() {
        return "Good [id=" + id + ", number=" + number + ", name=" + name + ", updateTime=" + updateTime + "]";
    }
    
    public Good(){}
    
    public Good(String id, int number, String name, Timestamp updateTime) {
        super();
        this.id = id;
        this.number = number;
        this.name = name;
        this.updateTime = updateTime;
    }
     
    public String getId() {
        return id;
    }

    public void setId(String id) {
        this.id = id;
    }

    public int getNumber() {
        return number;
    }
    public void setNumber(int number) {
        this.number = number;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public Timestamp getUpdateTime() {
        return updateTime;
    }
    public void setUpdateTime(Timestamp updateTime) {
        this.updateTime = updateTime;
    }
    
}