original.java
@Test
public void passQueryAsJSONStringTest() throws Exception {
client().admin().indices().prepareCreate("test").setSettings(
ImmutableSettings.settingsBuilder().put("index.number_of_shards", 1)).execute().actionGet();
client().prepareIndex("test", "type1", "1")
.setSource("field1", "value1_1", "field2", "value2_1")
.setRefresh(true).execute().actionGet();
WrapperQueryBuilder wrapper
= new WrapperQueryBuilder("{ \"term\" : { \"field1\" : \"value1_1\" } }");
CountResponse countResponse = client().prepareCount()
.setQuery(wrapper).execute().actionGet();
assertHitCount(countResponse, 1l);
BoolQueryBuilder bool = new BoolQueryBuilder();
bool.must(wrapper);
bool.must(new TermQueryBuilder(
"field2", "value2_1"));
countResponse = client().prepareCount().setQuery(wrapper).execute().actionGet();
assertHitCount(countResponse, 1l);
}
modified.java
@Test
public void passQueryAsJSONStringTest() throws Exception {
assertAcked(prepareCreate("test").setSettings(SETTING_NUMBER_OF_SHARDS,
1));
client().prepareIndex("test", "type1", "1")
.setSource("field1", "value1_1", "field2", "value2_1")
.setRefresh(true).get();
WrapperQueryBuilder wrapper
= new WrapperQueryBuilder("{ \"term\" : { \"field1\" : \"value1_1\" } }");
assertHitCount(client().prepareCount()
.setQuery(wrapper).get(), 1l);
BoolQueryBuilder bool = boolQuery().must(wrapper).must(new TermQueryBuilder(
"field2", "value2_1"));
assertHitCount(client().prepareCount().setQuery(bool).get(), 1l);
}