[fix][dingo-calcite] Remove the case sensitivity restrictions on column and index names

wt0530 · githubgxll · commit 46abbb0da21b · 2025-05-15T18:23:43.000+08:00
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/DingoDdlExecutor.java b/dingo-calcite/src/main/java/io/dingodb/calcite/DingoDdlExecutor.java
@@ -471,7 +471,7 @@ public void execute(SqlCreateTable createT, CalcitePrepare.Context context) {
         }
 
         // Distinct column
-        long distinctColCnt = columns.stream().map(ColumnDefinition::getName).distinct().count();
+        long distinctColCnt = columns.stream().map(c -> c.getName().toUpperCase()).distinct().count();
         long realColCnt = columns.size();
         if (distinctColCnt != realColCnt) {
             throw DINGO_RESOURCE.duplicateColumn().ex();
@@ -1836,16 +1836,13 @@ public void execute(SqlAlterRenameIndex sqlAlterRenameIndex, CalcitePrepare.Cont
         }
         String originIndexName = sqlAlterRenameIndex.originIndexName;
         boolean hasIndex = table.getIndexes().stream()
-            .anyMatch(indexTable -> caseSensitive() ? indexTable.getName().equals(originIndexName)
-                : indexTable.getName().equalsIgnoreCase(originIndexName));
+            .anyMatch(indexTable -> indexTable.getName().equalsIgnoreCase(originIndexName));
         if (!hasIndex) {
             throw DingoErrUtil.newStdErr(ErrKeyDoesNotExist, originIndexName, tableName);
         }
 
         hasIndex = table.getIndexes().stream()
-            .anyMatch(indexTable -> caseSensitive() ? indexTable.getName()
-                .equals(sqlAlterRenameIndex.toIndexName)
-                : indexTable.getName().equalsIgnoreCase(sqlAlterRenameIndex.toIndexName));
+            .anyMatch(indexTable -> indexTable.getName().equalsIgnoreCase(sqlAlterRenameIndex.toIndexName));
         if (hasIndex) {
             throw DingoErrUtil.newStdErr(ErrDupKeyName, sqlAlterRenameIndex.toIndexName);
         }
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/DingoSqlToRelConverter.java b/dingo-calcite/src/main/java/io/dingodb/calcite/DingoSqlToRelConverter.java
@@ -233,6 +233,7 @@ private Blackboard createInsertBlackboard(
     ) {
         final Map<String, RexNode> nameToNameMap = new HashMap<>();
 
+        int j = 0;
         final List<ColumnStrategy> strategies = targetTable.getColumnStrategies();
         final List<String> targetFields = targetTable.getRowType().getFieldNames();
         for (String targetColumnName : targetColumnNames) {
@@ -243,7 +244,7 @@ private Blackboard createInsertBlackboard(
                     break;
                 default:
                     nameToNameMap.put(targetColumnName,
-                        rexBuilder.makeFieldAccess(sourceRef, i));
+                        rexBuilder.makeFieldAccess(sourceRef, j++));
             }
         }
         return createBlackboard(null, nameToNameMap, false);
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/DingoTable.java b/dingo-calcite/src/main/java/io/dingodb/calcite/DingoTable.java
@@ -63,7 +63,6 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.stream.Collectors;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
 import static io.dingodb.common.util.NameCaseUtils.convertName;
 
 @Slf4j
@@ -108,7 +107,7 @@ public SubSnapshotSchema getSchema() {
 
     public IndexTable getIndexDefinition(String name) {
         return indexTableDefinitions.stream()
-            .filter(i -> caseSensitive() ? i.getName().equals(name) : i.getName().equalsIgnoreCase(name))
+            .filter(i -> i.getName().equalsIgnoreCase(name))
             .findAny()
             .orElse(null);
     }
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/executor/ShowTableStatusExecutor.java b/dingo-calcite/src/main/java/io/dingodb/calcite/executor/ShowTableStatusExecutor.java
@@ -30,6 +30,8 @@
 import java.util.List;
 import java.util.stream.Collectors;
 
+import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
+
 public class ShowTableStatusExecutor extends QueryExecutor {
 
     String schema;
@@ -49,7 +51,7 @@ public Iterator<Object[]> getIterator() {
         return is.getSchemaMap()
             .entrySet()
             .stream()
-            .filter(e -> e.getKey().equalsIgnoreCase(schema))
+            .filter(e -> caseSensitive() ? e.getKey().equals(schema) : e.getKey().equalsIgnoreCase(schema))
             .flatMap(e -> {
                 Collection<Table> tables = e.getValue().getTables().values();
                 return tables.stream()
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/meta/DingoCostModelV1.java b/dingo-calcite/src/main/java/io/dingodb/calcite/meta/DingoCostModelV1.java
@@ -108,8 +108,7 @@ public static double getAvgRowSize(List<Column> selectionCds, Table td, String s
             AtomicBoolean hasStats = new AtomicBoolean(false);
             if (tableStats != null) {
                 tableStats.getStatsNormalList().forEach(statsNormal -> {
-                    if (caseSensitive() ? cd.getName().equals(statsNormal.getColumnName())
-                        : cd.getName().equalsIgnoreCase(statsNormal.getColumnName())) {
+                    if (cd.getName().equalsIgnoreCase(statsNormal.getColumnName())) {
                         avgRowSize.addAndGet(statsNormal.getAvgColSize());
                         hasStats.set(true);
                     }
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/rule/DingoGetByIndexRule.java b/dingo-calcite/src/main/java/io/dingodb/calcite/rule/DingoGetByIndexRule.java
@@ -18,7 +18,6 @@
 
 import io.dingodb.calcite.DingoParserContext;
 import io.dingodb.calcite.DingoTable;
-import io.dingodb.calcite.rel.DingoForUpdate;
 import io.dingodb.calcite.rel.DingoGetByIndex;
 import io.dingodb.calcite.rel.DingoGetByKeys;
 import io.dingodb.calcite.rel.LogicalDingoTableScan;
@@ -32,9 +31,7 @@
 import io.dingodb.common.CommonId;
 import io.dingodb.common.log.LogUtils;
 import io.dingodb.common.meta.SchemaState;
-import io.dingodb.common.mysql.scope.ScopeVariables;
 import io.dingodb.common.type.TupleMapping;
-import io.dingodb.meta.entity.Column;
 import io.dingodb.meta.entity.IndexTable;
 import io.dingodb.meta.entity.IndexType;
 import io.dingodb.meta.entity.Table;
@@ -44,7 +41,6 @@
 import org.apache.calcite.plan.RelTraitSet;
 import org.apache.calcite.rel.RelNode;
 import org.apache.calcite.rel.convert.ConverterRule;
-import org.apache.calcite.rel.hint.RelHint;
 import org.apache.calcite.rex.RexBuilder;
 import org.apache.calcite.rex.RexCall;
 import org.apache.calcite.rex.RexInputRef;
@@ -65,8 +61,6 @@
 import java.util.Set;
 import java.util.stream.Collectors;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
-
 @Slf4j
 public class DingoGetByIndexRule extends ConverterRule {
     public static final Config DEFAULT = Config.INSTANCE
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/rule/DingoVectorIndexRule.java b/dingo-calcite/src/main/java/io/dingodb/calcite/rule/DingoVectorIndexRule.java
@@ -297,7 +297,6 @@ default DingoVectorIndexRule toRule() {
 
     private static Pair<Integer, Integer> getVectorIndex(DingoTable dingoTable, int dimension) {
         List<IndexTable> indexes = dingoTable.getTable().getIndexes();
-        boolean caseSensitive = caseSensitive();
         for (IndexTable index : indexes) {
 
             if (!index.getIndexType().isVector) {
@@ -314,11 +313,9 @@ private static Pair<Integer, Integer> getVectorIndex(DingoTable dingoTable, int
             int vectorIndex = 0;
             for (int i = 0; i < dingoTable.getTable().getColumns().size(); i ++) {
                 Column column = dingoTable.getTable().getColumns().get(i);
-                if (caseSensitive ? column.getName().equals(vectorIdColName)
-                    : column.getName().equalsIgnoreCase(vectorIdColName)) {
+                if (column.getName().equalsIgnoreCase(vectorIdColName)) {
                     vectorIdIndex = i;
-                } else if (caseSensitive ? column.getName().equals(vectorColName)
-                    : column.getName().equalsIgnoreCase(vectorColName)) {
+                } else if (column.getName().equalsIgnoreCase(vectorColName)) {
                     vectorIndex = i;
                 }
             }
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/runtime/DingoResource.java b/dingo-calcite/src/main/java/io/dingodb/calcite/runtime/DingoResource.java
@@ -126,7 +126,7 @@ public interface DingoResource {
     @BaseMessage("Tenant ''{0}'' not found")
     ExInst<DingoSqlException> tenantNotFound(String a0);
 
-    @BaseMessage("Error 1060 (42S21): Duplicate column names are not allowed in table definition")
+    @BaseMessage("Error 1060 (42S21): Duplicate column names are not allowed in table definition, even if the cases are different")
     ExInst<DingoSqlException> duplicateColumn();
 
     @BaseMessage("Error 1105 (HY000): Check illegalArgumentException")
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/stats/SelectivityEstimator.java b/dingo-calcite/src/main/java/io/dingodb/calcite/stats/SelectivityEstimator.java
@@ -119,12 +119,14 @@ private static CalculateStatistic extractColStats(Pair<String, Column> statsIden
         if (StatsCache.statsMap.containsKey(statsIdentifier.getLeft())) {
             TableStats stats = StatsCache.statsMap.get(statsIdentifier.getLeft());
             for (int i = 0; i < stats.getHistogramList().size(); i ++) {
-                if (stats.getHistogramList().get(i).getColumnName().equals(statsIdentifier.getRight().getName())) {
+                if (stats.getHistogramList().get(i).getColumnName()
+                    .equalsIgnoreCase(statsIdentifier.getRight().getName())) {
                     return stats.getHistogramList().get(i);
                 }
             }
             for (int i = 0; i < stats.getCountMinSketchList().size(); i ++) {
-                if (stats.getCountMinSketchList().get(i).getColumnName().equals(statsIdentifier.getRight().getName())) {
+                if (stats.getCountMinSketchList().get(i).getColumnName()
+                    .equalsIgnoreCase(statsIdentifier.getRight().getName())) {
                     return stats.getCountMinSketchList().get(i);
                 }
             }
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/stats/task/AnalyzeTask.java b/dingo-calcite/src/main/java/io/dingodb/calcite/stats/task/AnalyzeTask.java
@@ -240,7 +240,8 @@ private void typeMetricAdaptor(Table td,
         AtomicInteger index = new AtomicInteger();
         td.getColumns().forEach(columnDefinition -> {
             index.incrementAndGet();
-            if (columnList != null && !columnList.isEmpty() && !columnList.contains(columnDefinition.getName())) {
+            if (columnList != null && !columnList.isEmpty() && !columnList.stream().map(String::toUpperCase).toList()
+                .contains(columnDefinition.getName().toUpperCase())) {
                 return;
             }
             boolean allowStats = false;
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoGetByIndexMergeVisitFun.java b/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoGetByIndexMergeVisitFun.java
@@ -58,9 +58,7 @@
 import java.util.NavigableMap;
 import java.util.Set;
 import java.util.function.Supplier;
-import java.util.stream.Collectors;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
 import static io.dingodb.common.util.Utils.calculatePrefixCount;
 import static io.dingodb.exec.utils.OperatorCodeUtils.CALC_DISTRIBUTION;
 import static io.dingodb.exec.utils.OperatorCodeUtils.GET_BY_INDEX;
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoGetByIndexVisitFun.java b/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoGetByIndexVisitFun.java
@@ -54,9 +54,7 @@
 import java.util.NavigableMap;
 import java.util.Objects;
 import java.util.Set;
-import java.util.stream.Collectors;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
 import static io.dingodb.common.util.Utils.calculatePrefixCount;
 import static io.dingodb.common.util.Utils.isNeedLookUp;
 import static io.dingodb.exec.utils.OperatorCodeUtils.CALC_DISTRIBUTION;
@@ -83,7 +81,6 @@ public static LinkedList<Vertex> visit(
         Map<CommonId, Set> indexSetMap = rel.getIndexSetMap();
         final Table td = Objects.requireNonNull(rel.getTable().unwrap(DingoTable.class)).getTable();
         boolean needLookup = indexSetMap.size() > 1;
-        List<String> originNames = td.getColumns().stream().map(Column::getName).toList();
         for (Map.Entry<CommonId, Set> indexValSet : indexSetMap.entrySet()) {
             CommonId idxId = indexValSet.getKey();
             Table indexTd = rel.getIndexTdMap().get(idxId);
@@ -132,9 +129,7 @@ public static LinkedList<Vertex> visit(
                 task.putVertex(distributionVertex);
 
                 List<String> columnNames = indexTd.getColumns().stream().map(Column::getName).toList();
-                TupleMapping tupleMapping = TupleMapping.of(
-                    caseSensitive() ? columnNames.stream().map(originNames::indexOf).collect(Collectors.toList())
-                        : td.getColumnIndices(columnNames)
+                TupleMapping tupleMapping = TupleMapping.of(td.getColumnIndices(columnNames)
                 );
                 if (!needLookup) {
                     needLookup = isNeedLookUp(rel.getSelection(), tupleMapping, td.columns.size());
diff --git a/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoIndexRangeScanVisitFun.java b/dingo-calcite/src/main/java/io/dingodb/calcite/visitor/function/DingoIndexRangeScanVisitFun.java
@@ -50,28 +50,21 @@
 import io.dingodb.expr.rel.op.RelOpBuilder;
 import io.dingodb.expr.runtime.expr.Expr;
 import io.dingodb.meta.MetaService;
-import io.dingodb.meta.entity.Column;
 import io.dingodb.meta.entity.Table;
 import io.dingodb.store.api.transaction.data.IsolationLevel;
-import org.apache.calcite.rex.RexBuilder;
-import org.apache.calcite.rex.RexCall;
 import org.apache.calcite.rex.RexNode;
 import org.apache.calcite.rex.RexUtil;
 import org.apache.calcite.sql.SqlKind;
-import org.apache.calcite.tools.RelBuilder;
 import org.apache.calcite.util.mapping.Mapping;
 import org.apache.calcite.util.mapping.Mappings;
 import org.checkerframework.checker.nullness.qual.NonNull;
 
-import java.util.ArrayList;
 import java.util.Collection;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.NavigableMap;
 import java.util.Objects;
-import java.util.stream.Collectors;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
 import static io.dingodb.exec.utils.OperatorCodeUtils.CALC_DISTRIBUTION_1;
 import static io.dingodb.exec.utils.OperatorCodeUtils.TXN_INDEX_RANGE_SCAN;
 
diff --git a/dingo-common/src/main/java/io/dingodb/common/util/NameCaseUtils.java b/dingo-common/src/main/java/io/dingodb/common/util/NameCaseUtils.java
@@ -81,10 +81,4 @@ public static boolean caseSensitive() {
         return DingoConfiguration.lowerCaseTableNames() == 0;
     }
 
-    public static void main(String[] args) {
-        DingoConfiguration.instance().getVariable().setLowerCaseTableNames(2);
-        String sql = "insert into mysql.DINGO_DDL_JOB(job_id, reorg, schema_ids, table_ids, job_meta, type, processing) values(1002, false, '50003', '60074', '{\"id\":1002,\"actionType\":\"ActionCreateTable\",\"schemaId\":50003,\"tableId\":60074,\"schemaName\":\"DINGO\",\"tableName\":\"t3\",\"state\":\"jobStateQueueing\",\"warning\":null,\"error\":null,\"errorCount\":0,\"rowCount\":0,\"lock\":null,\"schemaState\":null,\"snapshotVer\":0,\"realStartTs\":0,\"startTs\":0,\"dependencyId\":0,";
-        String s = convertSql(sql);
-        System.out.println(s);
-    }
 }
diff --git a/dingo-driver/host/src/main/java/io/dingodb/driver/DingoMeta.java b/dingo-driver/host/src/main/java/io/dingodb/driver/DingoMeta.java
@@ -141,7 +141,7 @@ private static Predicate<String> patToFilter(@NonNull Pat pat, boolean caseInSen
         }
         buf.append("$");
         Pattern regex;
-        if (caseInSensitive) {
+        if (!caseInSensitive) {
             regex = Pattern.compile(buf.toString(), Pattern.CASE_INSENSITIVE);
         } else {
             regex = Pattern.compile(buf.toString());
@@ -169,7 +169,7 @@ private Collection<CalciteSchema> getMatchedSubSchema(
         @NonNull CalciteSchema usedSchema,
         @NonNull Pat pat
     ) {
-        final Predicate<String> filter = patToFilter(pat, true);
+        final Predicate<String> filter = patToFilter(pat, caseSensitive());
         if (usedSchema.getSubSchemaMap().isEmpty()) {
             return Collections.emptyList();
         }
@@ -184,7 +184,7 @@ private Collection<CalciteSchema.TableEntry> getMatchedTables(
         @NonNull Collection<CalciteSchema> schemas,
         @NonNull Pat pat
     ) {
-        final Predicate<String> filter = patToFilter(pat, true);
+        final Predicate<String> filter = patToFilter(pat, caseSensitive());
         return schemas.stream()
             .map(schema -> (SubCalciteSchema)schema)
             .flatMap(s -> s.getTableNames().stream()
@@ -1132,7 +1132,7 @@ public MetaResultSet getColumns(
         final Collection<CalciteSchema.TableEntry> tables = getMatchedTables(
             getMatchedSubSchema(context.getRootSchema(), schemaPattern), tableNamePattern
         );
-        final Predicate<String> filter = patToFilter(columnNamePattern, true);
+        final Predicate<String> filter = patToFilter(columnNamePattern, false);
         List<MetaColumn> columns = tables.stream()
             .flatMap(t -> {
                 RelDataType rowType = t.getTable().getRowType(context.getTypeFactory());
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartDocumentOperator.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnPartDocumentOperator.java
@@ -118,7 +118,7 @@ public class TxnPartDocumentOperator extends FilterProjectSourceOperator {
                         ScalarField fieldValue = value.getFieldValue();
                         int idx = 0;
                         for (int i = 0; i < columns.size(); i++) {
-                            if (columns.get(i).getName().equals(key)) {
+                            if (columns.get(i).getName().equalsIgnoreCase(key)) {
                                 idx = i;
                                 break;
                             }
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnScanWithCacheOpOperator.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/TxnScanWithCacheOpOperator.java
@@ -34,10 +34,6 @@ public final class TxnScanWithCacheOpOperator extends TxnScanWithRelOpOperatorBa
     @Override
     protected @NonNull Scanner getScanner(@NonNull Context context, @NonNull Vertex vertex) {
         ScanWithRelOpParam param = vertex.getParam();
-        if (context.getDistribution().getId().seq != 80012) {
-            int i = 0;
-            LogUtils.debug(log, "for debug");
-        }
         if (param.getCoprocessor(context.getDistribution().getId()) != null) {
             return RelOpUtils::doScan;
         }
diff --git a/dingo-exec/src/main/java/io/dingodb/exec/operator/data/Context.java b/dingo-exec/src/main/java/io/dingodb/exec/operator/data/Context.java
@@ -33,6 +33,7 @@ public class Context {
 
     private int pin;
     private CommonId indexId;
+    private CommonId tablePartId;
     private RangeDistribution distribution;
     private List<Boolean> keyState;
     @Builder.Default
diff --git a/dingo-executor/src/main/java/io/dingodb/server/executor/ddl/DdlWorker.java b/dingo-executor/src/main/java/io/dingodb/server/executor/ddl/DdlWorker.java
@@ -629,8 +629,7 @@ public Pair<Long, String> onCreateIndex(DdlContext dc, DdlJob job) {
             return Pair.of(0L, "table not exists");
         }
         boolean exists = table.getIndexes().stream()
-            .anyMatch(indexTable -> (caseSensitive() ? indexTable.getName().equals(indexInfo.getName())
-                : indexTable.getName().equalsIgnoreCase(indexInfo.getName()))
+            .anyMatch(indexTable -> indexTable.getName().equalsIgnoreCase(indexInfo.getName())
                 && indexTable.getSchemaState() == SchemaState.SCHEMA_PUBLIC);
         if (exists) {
             job.setState(JobState.jobStateCancelled);
@@ -717,8 +716,7 @@ public static Pair<Long, String> onDropIndex(DdlContext dc, DdlJob job) {
             indexName = job.getArgs().get(0).toString();
         }
         boolean notExists = table.getIndexes().stream()
-            .noneMatch(indexTable -> caseSensitive() ? indexTable.getName().equals(indexName)
-                : indexTable.getName().equalsIgnoreCase(indexName));
+            .noneMatch(indexTable -> indexTable.getName().equalsIgnoreCase(indexName));
         if (notExists) {
             job.setState(JobState.jobStateCancelled);
             return Pair.of(0L, "index not exists");
@@ -1974,9 +1972,9 @@ public Pair<Long, String> onAlterIndexVisible(DdlContext dc, DdlJob job) {
         TableDefinitionWithId indexWithId = indexList.stream()
             .map(idxTable -> (TableDefinitionWithId)idxTable)
             .filter(idxTable ->
-                idxTable.getTableDefinition().getName().endsWith(indexName)
-                    || idxTable.getTableDefinition().getName().endsWith(indexName)).findFirst()
-                    .orElse(null);
+                idxTable.getTableDefinition().getName().toUpperCase().endsWith(indexName.toUpperCase()))
+            .findFirst()
+            .orElse(null);
         if (indexWithId == null) {
             job.setDingoErr(DingoErrUtil.newInternalErr(ErrKeyDoesNotExist, indexName, job.getTableName()));
             return Pair.of(0L, job.getDingoErr().errorMsg);
diff --git a/dingo-executor/src/main/java/io/dingodb/server/executor/ddl/IndexUtil.java b/dingo-executor/src/main/java/io/dingodb/server/executor/ddl/IndexUtil.java
@@ -33,8 +33,6 @@
 import io.dingodb.sdk.service.entity.meta.TableDefinitionWithId;
 import lombok.extern.slf4j.Slf4j;
 
-import static io.dingodb.common.util.NameCaseUtils.caseSensitive;
-
 @Slf4j
 public final class IndexUtil {
     public static final IndexUtil INSTANCE = new IndexUtil();
@@ -44,8 +42,7 @@ private IndexUtil() {
 
     public static TableDefinitionWithId getIndexWithId(Table table, String indexName) {
         long indexId = table.getIndexes().stream()
-            .filter(s -> caseSensitive() ? s.getName().equals(indexName)
-                : s.getName().equalsIgnoreCase(indexName))
+            .filter(s -> s.getName().equalsIgnoreCase(indexName))
             .map(s -> s.getTableId().seq)
             .findFirst().orElse(0L);
 
diff --git a/dingo-meta-api/src/main/java/io/dingodb/meta/entity/Table.java b/dingo-meta-api/src/main/java/io/dingodb/meta/entity/Table.java
@@ -186,8 +186,7 @@ public int getColumnIndex(String name) {
     public int getColumnIndex(Column column) {
         int i = 0;
         for (Column col : columns) {
-            if (caseSensitive() ? col.getName().equals(column.getName())
-                : col.getName().equalsIgnoreCase(column.getName())) {
+            if (col.getName().equalsIgnoreCase(column.getName())) {
                 return i;
             }
             ++i;
diff --git a/dingo-store-proxy/src/main/java/io/dingodb/store/proxy/ddl/DdlHandler.java b/dingo-store-proxy/src/main/java/io/dingodb/store/proxy/ddl/DdlHandler.java
diff --git a/dingo-store-proxy/src/main/java/io/dingodb/store/service/InfoSchemaService.java b/dingo-store-proxy/src/main/java/io/dingodb/store/service/InfoSchemaService.java

Original file line number	Diff line number	Diff line change
`@@ -119,12 +119,14 @@ private static CalculateStatistic extractColStats(Pair<String, Column> statsIden`
`119`	`119`	`if (StatsCache.statsMap.containsKey(statsIdentifier.getLeft())) {`
`120`	`120`	`TableStats stats = StatsCache.statsMap.get(statsIdentifier.getLeft());`
`121`	`121`	`for (int i = 0; i < stats.getHistogramList().size(); i ++) {`
`122`		`- if (stats.getHistogramList().get(i).getColumnName().equals(statsIdentifier.getRight().getName())) {`
	`122`	`+ if (stats.getHistogramList().get(i).getColumnName()`
	`123`	`+ .equalsIgnoreCase(statsIdentifier.getRight().getName())) {`
`123`	`124`	`return stats.getHistogramList().get(i);`
`124`	`125`	`}`
`125`	`126`	`}`
`126`	`127`	`for (int i = 0; i < stats.getCountMinSketchList().size(); i ++) {`
`127`		`- if (stats.getCountMinSketchList().get(i).getColumnName().equals(statsIdentifier.getRight().getName())) {`
	`128`	`+ if (stats.getCountMinSketchList().get(i).getColumnName()`
	`129`	`+ .equalsIgnoreCase(statsIdentifier.getRight().getName())) {`
`128`	`130`	`return stats.getCountMinSketchList().get(i);`
`129`	`131`	`}`
`130`	`132`	`}`