快速,持续,稳定,傻瓜式
支持Mysql,Sqlserver数据同步

sorl6.0+jetty+mysql搭建solr服务

在线QQ客服:1922638

专业的SQL Server、MySQL数据库同步软件

 导入  java.lang.reflect.Method;

导入 java.sql.Timestamp;

导入 org.apache.solr.client.solrj.SolrQuery;

导入 org.apache.solr.client.solrj.impl.HttpSolrServer;

导入 org.apache.solr.client.solrj.response.QueryResponse;

导入 org.apache.solr.common.SolrInputDocument;

导入 com.entity.Good;

@SuppressWarnings(" deprecation"

public Solr {

私有 静态 HttpSolrServer solrServer;

静态

// 请注意请求地址的格式:浏览器中的地址带有" #",必填删除"#"!

solrServer = new HttpSolrServer(" http://本地主机:8983/solr/hjz" );

solrServer.setConnectionTimeout( 5000 );

}

公共 静态 void 插入(很好,很好){

SolrInputDocument doc = 新建 SolrInputDocument();

doc.addField(" id" ,good.getId());

doc.addField(" name" ,good.getName());

doc.addField(" number" ,good.getNumber());

doc.addField(" updateTime" ,good.getUpdateTime());

试试

solrServer.add(doc);

solrServer.commit();

} catch (异常e){

e.printStackTrace();

}

}

公共 静态 void deleteById(字符串ID){

试试

solrServer.deleteById(id +"" );

solrServer.commit();

} catch (异常e){

e.printStackTrace();

}

}

公共 静态 void deleteAll(){

试试

solrServer.deleteByQuery(" *:*" );

solrServer.commit();

} catch (异常e){

e.printStackTrace();

}

}

公共 静态 void 更新(很好,很好){

插入(好);

}

公共 静态 \ lt; T T getById( int id,Class \ lt; T \ gt; clazz){

SolrQuery查询 = SolrQuery();

query.setQuery(" id:" + id);

试试

QueryResponse rsp = solrServer.query(查询);

return rsp.getBeans(clazz).get(0 );

} catch (异常e){

e.printStackTrace();

}

返回 null ;

}

公共 静态 void deleteByObject(对象obj,字符串idName){

试试

类 \ lt ; \ Gt; clazz = obj.getClass();

// 将idName的首字母大写

如果(Character.isLowerCase(idName.charAt(0)))idName = Character.toUpperCase(idName.charAt(0))+ idName.substring(1 );

方法方法 = clazz.getMethod(" get" + idName);

字符串idValue = (String)method.invoke(obj);

deleteById(idValue);

} catch (异常e){

e.printStackTrace();

}

}

public 静态 void main(字符串[] args){

好好 = 好(" 123",9999," hjzgg5211314", new 时间戳(System.currentTimeMillis()));

// Solr.update(良好);

// System.out.println(Solr.getById(123,Good.class) );

deleteByObject(good," id" );

}

}

相关推荐

咨询软件
 
QQ在线咨询
售前咨询热线
QQ1922638