SQL: Fix incorrect message for aliases (#31792)

* SQL: Fix incorrect message for aliases

Fix the naming in the verification message thrown for aliases over
multiple indices with different mappings.
This commit is contained in:
Costin Leau 2018-07-05 19:49:58 +03:00 committed by GitHub
parent 1099060735
commit 6e9bd2652f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 77 additions and 1 deletions

View File

@ -253,7 +253,7 @@ public class IndexResolver {
// need the same mapping across all resolutions // need the same mapping across all resolutions
if (!merged.get().mapping().equals(resolution.get().mapping())) { if (!merged.get().mapping().equals(resolution.get().mapping())) {
return IndexResolution.invalid( return IndexResolution.invalid(
"[" + indexWildcard + "] points to indices [" + resolution.get().name() + "] " "[" + indexWildcard + "] points to indices [" + merged.get().name() + "] "
+ "and [" + resolution.get().name() + "] which have different mappings. " + "and [" + resolution.get().name() + "] which have different mappings. "
+ "When using multiple indices, the mappings must be identical."); + "When using multiple indices, the mappings must be identical.");
} }

View File

@ -0,0 +1,60 @@
/*
* Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
* or more contributor license agreements. Licensed under the Elastic License;
* you may not use this file except in compliance with the Elastic License.
*/
package org.elasticsearch.xpack.sql.analysis.index;
import org.elasticsearch.test.ESTestCase;
import org.elasticsearch.xpack.sql.type.EsField;
import org.elasticsearch.xpack.sql.type.TypesTests;
import java.util.Arrays;
import java.util.Map;
public class IndexResolverTests extends ESTestCase {
public void testMergeSameMapping() throws Exception {
Map<String, EsField> oneMapping = TypesTests.loadMapping("mapping-basic.json", true);
Map<String, EsField> sameMapping = TypesTests.loadMapping("mapping-basic.json", true);
assertNotSame(oneMapping, sameMapping);
assertEquals(oneMapping, sameMapping);
String wildcard = "*";
IndexResolution resolution = IndexResolver.merge(
Arrays.asList(IndexResolution.valid(new EsIndex("a", oneMapping)), IndexResolution.valid(new EsIndex("b", sameMapping))),
wildcard);
assertTrue(resolution.isValid());
EsIndex esIndex = resolution.get();
assertEquals(wildcard, esIndex.name());
assertEquals(sameMapping, esIndex.mapping());
}
public void testMergeDifferentMapping() throws Exception {
Map<String, EsField> oneMapping = TypesTests.loadMapping("mapping-basic.json", true);
Map<String, EsField> sameMapping = TypesTests.loadMapping("mapping-basic.json", true);
Map<String, EsField> differentMapping = TypesTests.loadMapping("mapping-numeric.json", true);
assertNotSame(oneMapping, sameMapping);
assertEquals(oneMapping, sameMapping);
assertNotEquals(oneMapping, differentMapping);
String wildcard = "*";
IndexResolution resolution = IndexResolver.merge(
Arrays.asList(IndexResolution.valid(new EsIndex("a", oneMapping)),
IndexResolution.valid(new EsIndex("b", sameMapping)),
IndexResolution.valid(new EsIndex("diff", differentMapping))),
wildcard);
assertFalse(resolution.isValid());
MappingException ex = expectThrows(MappingException.class, () -> resolution.get());
assertEquals(
"[*] points to indices [a] and [diff] which have different mappings. "
+ "When using multiple indices, the mappings must be identical.",
ex.getMessage());
}
}

View File

@ -0,0 +1,16 @@
{
"properties" : {
"byte" : {
"type" : "byte"
},
"short" : {
"type" : "short"
},
"integer" : {
"type" : "integer"
},
"long" : {
"type" : "long"
}
}
}