Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-512: set parameters on UpdateRequest 

git-svn-id: https://svn.apache.org/repos/asf/lucene/solr/trunk@641486 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Yonik Seeley 2008-03-26 19:03:08 +00:00
parent 493608377f
commit a04d84f27c
1 changed files with 37 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

60
client/java/solrj/src/org/apache/solr/client/solrj/request/UpdateRequest.java
View File

@ -47,17 +47,17 @@ public class UpdateRequest extends SolrRequest
OPTIMIZE
};
private boolean waitFlush = true;
private boolean waitSearcher = true;
private boolean allowDups = false;
private boolean overwriteCommitted = true;
private boolean overwritePending = true;
private ACTION action = null;
private List<SolrInputDocument> documents = null;
private List<String> deleteById = null;
private List<String> deleteQuery = null;
private ModifiableSolrParams params;
public UpdateRequest()
{
super( METHOD.POST, "/update" );
@ -121,13 +121,33 @@ public class UpdateRequest extends SolrRequest
return this;
}
/** Sets appropriate parameters for the given ACTION */
public UpdateRequest setAction(ACTION action, boolean waitFlush, boolean waitSearcher ) {
this.action = action;
this.waitFlush = waitFlush;
this.waitSearcher = waitSearcher;
if (params == null)
params = new ModifiableSolrParams();
if( action == ACTION.OPTIMIZE ) {
params.set( UpdateParams.OPTIMIZE, "true" );
}
else if( action == ACTION.COMMIT ) {
params.set( UpdateParams.COMMIT, "true" );
}
params.set( UpdateParams.WAIT_FLUSH, waitFlush+"" );
params.set( UpdateParams.WAIT_SEARCHER, waitSearcher+"" );
return this;
}
public void setParam(String param, String value) {
if (params == null)
params = new ModifiableSolrParams();
params.set(param, value);
}
/** Sets the parameters for this update request, overwriting any previous */
public void setParams(ModifiableSolrParams params) {
this.params = params;
}
//--------------------------------------------------------------------------
//--------------------------------------------------------------------------
@ -180,25 +200,14 @@ public class UpdateRequest extends SolrRequest
return (xml.length() > 0) ? xml : null;
}
//--------------------------------------------------------------------------
//--------------------------------------------------------------------------
@Override
public SolrParams getParams() {
if( action != null ) {
ModifiableSolrParams params = new ModifiableSolrParams();
if( action == ACTION.OPTIMIZE ) {
params.set( UpdateParams.OPTIMIZE, "true" );
}
else if( action == ACTION.COMMIT ) {
params.set( UpdateParams.COMMIT, "true" );
}
params.set( UpdateParams.WAIT_FLUSH, waitFlush+"" );
params.set( UpdateParams.WAIT_SEARCHER, waitSearcher+"" );
public ModifiableSolrParams getParams() {
return params;
}
return null;
}
@Override
public UpdateResponse process( SolrServer server ) throws SolrServerException, IOException
@ -225,15 +234,18 @@ public class UpdateRequest extends SolrRequest
//--------------------------------------------------------------------------
public boolean isWaitFlush() {
return waitFlush;
return params != null && params.getBool(UpdateParams.WAIT_FLUSH, false);
}
public boolean isWaitSearcher() {
return waitSearcher;
return params != null && params.getBool(UpdateParams.WAIT_SEARCHER, false);
}
public ACTION getAction() {
return action;
if (params==null) return null;
if (params.getBool(UpdateParams.COMMIT, false)) return ACTION.COMMIT;
if (params.getBool(UpdateParams.OPTIMIZE, false)) return ACTION.OPTIMIZE;
return null;
}
public boolean isAllowDups() {
@ -275,10 +287,10 @@ public class UpdateRequest extends SolrRequest
}
public void setWaitFlush(boolean waitFlush) {
this.waitFlush = waitFlush;
setParam( UpdateParams.WAIT_FLUSH, waitFlush+"" );
}
public void setWaitSearcher(boolean waitSearcher) {
this.waitSearcher = waitSearcher;
setParam( UpdateParams.WAIT_SEARCHER, waitSearcher+"" );
}
}