1 @Test
 2 public void passQueryAsJSONStringTest() throws Exception {
 3     client().admin().indices().prepareCreate("test").setSettings(
 4         ImmutableSettings.settingsBuilder().put("index.number_of_shards", 1)).execute().actionGet();
 5 
 6     client().prepareIndex("test", "type1", "1")
 7         .setSource("field1", "value1_1", "field2", "value2_1")
 8         .setRefresh(true).execute().actionGet();
 9 
10     WrapperQueryBuilder wrapper
11          = new WrapperQueryBuilder("{ \"term\" : { \"field1\" : \"value1_1\" } }");
12     CountResponse countResponse = client().prepareCount()
13         .setQuery(wrapper).execute().actionGet();
14     assertHitCount(countResponse, 1l);
15 
16     BoolQueryBuilder bool = new BoolQueryBuilder();
17     bool.must(wrapper);
18     bool.must(new TermQueryBuilder(
19         "field2", "value2_1"));
20 
21     countResponse = client().prepareCount().setQuery(wrapper).execute().actionGet();
22     assertHitCount(countResponse, 1l);
23 }
24 

 1 @Test
 2 public void passQueryAsJSONStringTest() throws Exception {
 3     assertAcked(prepareCreate("test").setSettings(SETTING_NUMBER_OF_SHARDS,
 4           1));
 5 
 6     client().prepareIndex("test", "type1", "1")
 7         .setSource("field1", "value1_1", "field2", "value2_1")
 8         .setRefresh(true).get();
 9 
10     WrapperQueryBuilder wrapper
11          = new WrapperQueryBuilder("{ \"term\" : { \"field1\" : \"value1_1\" } }");
12     assertHitCount(client().prepareCount()
13         .setQuery(wrapper).get(), 1l);
   
   
   
14 
15     BoolQueryBuilder bool = boolQuery().must(wrapper).must(new TermQueryBuilder(
16         "field2", "value2_1"));
   
17     assertHitCount( client().prepareCount().setQuery(bool).get(), 1l);
   
18 }
19