@@ -35,7 +35,7 @@ public void joinParseCheckSelectedFieldsSplitNL() throws SqlParseException, SQLF
35
35
}
36
36
37
37
private void joinParseCheckSelectedFieldsSplit (boolean useNestedLoops ) throws SqlParseException , SQLFeatureNotSupportedException , IOException {
38
- String query = "SELECT a.firstname ,a.lastname , a.gender ,d.name FROM elasticsearch-sql_test_index/people a " +
38
+ String query = "SELECT a.firstname ,a.lastname , a.gender ,d.dog_name FROM elasticsearch-sql_test_index/people a " +
39
39
" JOIN elasticsearch-sql_test_index/dog d on d.holdersName = a.firstname " +
40
40
" WHERE " +
41
41
" (a.age > 10 OR a.balance > 2000)" +
@@ -45,17 +45,17 @@ private void joinParseCheckSelectedFieldsSplit(boolean useNestedLoops) throws Sq
45
45
Assert .assertEquals (2 , hits .length );
46
46
47
47
Map <String ,Object > oneMatch = ImmutableMap .of ("a.firstname" , (Object ) "Daenerys" , "a.lastname" , "Targaryen" ,
48
- "a.gender" , "M" , "d.name " , "rex" );
48
+ "a.gender" , "M" , "d.dog_name " , "rex" );
49
49
Map <String ,Object > secondMatch = ImmutableMap .of ("a.firstname" , (Object ) "Hattie" , "a.lastname" , "Bond" ,
50
- "a.gender" , "M" , "d.name " , "snoopy" );
50
+ "a.gender" , "M" , "d.dog_name " , "snoopy" );
51
51
52
52
Assert .assertTrue (hitsContains (hits , oneMatch ));
53
53
Assert .assertTrue (hitsContains (hits ,secondMatch ));
54
54
}
55
55
56
56
@ Test
57
57
public void joinParseWithHintsCheckSelectedFieldsSplitHASH () throws SqlParseException , SQLFeatureNotSupportedException , IOException {
58
- String query = "SELECT /*! HASH_WITH_TERMS_FILTER*/ a.firstname ,a.lastname , a.gender ,d.name FROM elasticsearch-sql_test_index/people a " +
58
+ String query = "SELECT /*! HASH_WITH_TERMS_FILTER*/ a.firstname ,a.lastname , a.gender ,d.dog_name FROM elasticsearch-sql_test_index/people a " +
59
59
" JOIN elasticsearch-sql_test_index/dog d on d.holdersName = a.firstname " +
60
60
" WHERE " +
61
61
" (a.age > 10 OR a.balance > 2000)" +
@@ -418,22 +418,22 @@ public void joinWithOrNL() throws SQLFeatureNotSupportedException, IOException,
418
418
}
419
419
420
420
private void joinWithOr (boolean useNestedLoops ) throws SQLFeatureNotSupportedException , IOException , SqlParseException {
421
- String query = String .format ("select d.name , c.name.firstname from %s/gotCharacters c " +
421
+ String query = String .format ("select d.dog_name , c.name.firstname from %s/gotCharacters c " +
422
422
"JOIN %s/dog d on d.holdersName = c.name.firstname" +
423
423
" OR d.age = c.name.ofHisName"
424
424
, TEST_INDEX , TEST_INDEX );
425
425
if (useNestedLoops ) query = query .replace ("select" ,"select /*! USE_NL*/ " );
426
426
SearchHit [] hits = joinAndGetHits (query );
427
427
Assert .assertEquals (2 , hits .length );
428
- Map <String ,Object > oneMatch = ImmutableMap .of ("c.name.firstname" , (Object ) "Daenerys" , "d.name " , "rex" );
429
- Map <String ,Object > secondMatch = ImmutableMap .of ("c.name.firstname" , (Object ) "Brandon" , "d.name " , "snoopy" );
428
+ Map <String ,Object > oneMatch = ImmutableMap .of ("c.name.firstname" , (Object ) "Daenerys" , "d.dog_name " , "rex" );
429
+ Map <String ,Object > secondMatch = ImmutableMap .of ("c.name.firstname" , (Object ) "Brandon" , "d.dog_name " , "snoopy" );
430
430
Assert .assertTrue ("hits contains daenerys" ,hitsContains (hits , oneMatch ));
431
431
Assert .assertTrue ("hits contains brandon" ,hitsContains (hits , secondMatch ));
432
432
}
433
433
434
434
@ Test
435
435
public void joinWithOrWithTermsFilterOpt () throws SQLFeatureNotSupportedException , IOException , SqlParseException {
436
- String query = String .format ("select /*! HASH_WITH_TERMS_FILTER*/ d.name , c.name.firstname from %s/gotCharacters c " +
436
+ String query = String .format ("select /*! HASH_WITH_TERMS_FILTER*/ d.dog_name , c.name.firstname from %s/gotCharacters c " +
437
437
"JOIN %s/dog d on d.holdersName = c.name.firstname" +
438
438
" OR d.age = c.name.ofHisName"
439
439
, TEST_INDEX , TEST_INDEX );
0 commit comments