korlov42 commented on a change in pull request #8490:
URL: https://github.com/apache/ignite/pull/8490#discussion_r575805700
##########
File path:
modules/core/src/main/java/org/apache/ignite/internal/cache/query/index/sorted/IndexKeyImpl.java
##########
@@ -15,41 +15,48 @@
* limitations under the License.
*/
-package org.apache.ignite.internal.processors.query.h2.database.io;
+package org.apache.ignite.internal.cache.query.index.sorted;
-import org.apache.ignite.internal.pagemem.PageUtils;
+import java.util.Arrays;
+import org.apache.ignite.cache.query.index.sorted.IndexKey;
/**
- *
+ * Complex index key that represents a user index query.
*/
-class H2MvccExtrasInnerIO extends AbstractH2ExtrasInnerIO {
- /**
- * @param type Page type.
- * @param ver Page format version.
- * @param payloadSize Payload size.
- */
- H2MvccExtrasInnerIO(short type, int ver, int payloadSize) {
- super(type, ver, 28, payloadSize);
+public class IndexKeyImpl implements IndexKey {
Review comment:
is it used anywhere?
##########
File path:
modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/index/QueryIndexSchema.java
##########
@@ -0,0 +1,210 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.query.h2.index;
+
+import org.apache.ignite.cache.query.index.sorted.NullsOrder;
+import org.apache.ignite.cache.query.index.sorted.Order;
+import org.apache.ignite.cache.query.index.sorted.SortOrder;
+import org.apache.ignite.internal.binary.BinaryObjectImpl;
+import org.apache.ignite.internal.cache.query.index.sorted.IndexKeyDefinition;
+import org.apache.ignite.internal.cache.query.index.sorted.JavaObjectKey;
+import org.apache.ignite.internal.cache.query.index.sorted.NullKey;
+import org.apache.ignite.internal.cache.query.index.sorted.SortedIndexSchema;
+import
org.apache.ignite.internal.cache.query.index.sorted.inline.IndexKeyTypes;
+import org.apache.ignite.internal.processors.cache.CacheObject;
+import org.apache.ignite.internal.processors.cache.CacheObjectContext;
+import org.apache.ignite.internal.processors.cache.KeyCacheObject;
+import org.apache.ignite.internal.processors.cache.persistence.CacheDataRow;
+import org.apache.ignite.internal.processors.query.GridQueryTypeDescriptor;
+import org.apache.ignite.internal.processors.query.QueryUtils;
+import org.apache.ignite.internal.processors.query.h2.opt.GridH2RowDescriptor;
+import org.apache.ignite.internal.processors.query.h2.opt.GridH2Table;
+import org.h2.table.IndexColumn;
+
+/**
+ * Schema for QueryIndex.
+ */
+public class QueryIndexSchema implements SortedIndexSchema {
+ /** Key definitions. */
+ private final IndexKeyDefinition[] idxKeyDefinitions;
+
+ /** H2 index columns. */
+ private final IndexColumn[] h2IdxColumns;
+
+ /** Cache descriptor. */
+ private final GridH2RowDescriptor cacheDesc;
+
+ /** Table. */
+ private final GridH2Table table;
+
+ /** */
+ public QueryIndexSchema(GridH2Table table, IndexColumn[] h2IndexColumns) {
+ this.table = table;
+
+ cacheDesc = table.rowDescriptor();
+
+ idxKeyDefinitions = new IndexKeyDefinition[h2IndexColumns.length];
+
+ this.h2IdxColumns = h2IndexColumns.clone();
+
+ for (int i = 0; i < h2IndexColumns.length; ++i)
+ addKeyDefinition(i, h2IndexColumns[i]);
+
+ IndexColumn.mapColumns(h2IndexColumns, table);
+ }
+
+ /** */
+ private void addKeyDefinition(int i, IndexColumn c) {
+ GridQueryTypeDescriptor type = cacheDesc.type();
+
+ Class<?> idxKeyCls;
+
+ int colId = c.column.getColumnId();
+
+ if (cacheDesc.isKeyColumn(colId) || cacheDesc.isKeyAliasColumn(colId))
+ idxKeyCls = type.keyClass();
+ else if (cacheDesc.isValueColumn(colId) ||
cacheDesc.isKeyAliasColumn(colId))
+ idxKeyCls = type.valueClass();
+ else
+ idxKeyCls = type.property(c.columnName).type();
+
+ idxKeyDefinitions[i] = new IndexKeyDefinition(
+ c.columnName, c.column.getType(), idxKeyCls,
getSortOrder(c.sortType));
+ }
+
+ /** Maps H2 column order to Ignite index order. */
+ private Order getSortOrder(int sortType) {
+ SortOrder sortOrder = (sortType & 1) != 0 ? SortOrder.DESC :
SortOrder.ASC;
+
+ NullsOrder nullsOrder = (sortType & 2) != 0 ? NullsOrder.NULLS_FIRST :
NullsOrder.NULLS_LAST;
+
+ return new Order(sortOrder, nullsOrder);
+ }
+
+
+ /** {@inheritDoc} */
+ @Override public IndexKeyDefinition[] getKeyDefinitions() {
+ return idxKeyDefinitions.clone();
+ }
+
+ /** {@inheritDoc} */
+ @Override public Object getIndexKey(int idx, CacheDataRow row) {
+ Object o = getKey(idx, row);
+
+ if (o == null)
+ return NullKey.INSTANCE;
+
+ if (idxKeyDefinitions[idx].getIdxType() == IndexKeyTypes.JAVA_OBJECT)
+ return new JavaObjectKey(o);
+
+ return o;
+ }
+
+ /** */
+ private Object getKey(int idx, CacheDataRow row) {
+ int cacheIdx = h2IdxColumns[idx].column.getColumnId();
+
+ switch (cacheIdx) {
+ case QueryUtils.KEY_COL:
+ return key(row);
+
+ case QueryUtils.VAL_COL:
+ return value(row);
+
+ default:
+ if (cacheDesc.isKeyAliasColumn(cacheIdx))
+ return key(row);
+
+ else if (cacheDesc.isValueAliasColumn(cacheIdx))
+ return value(row);
+
+ // columnValue ignores default columns (_KEY, _VAL), so make
this shift.
+ return cacheDesc.columnValue(row.key(), row.value(), cacheIdx
- QueryUtils.DEFAULT_COLUMNS_COUNT);
+ }
+ }
Review comment:
```suggestion
private Object getKey(int idx, CacheDataRow row) {
int cacheIdx = h2IdxColumns[idx].column.getColumnId();
if (cacheDesc.isKeyColumn(cacheIdx))
return key(row);
else if (cacheDesc.isValueColumn(cacheIdx))
return value(row);
// columnValue ignores default columns (_KEY, _VAL), so make this
shift.
return cacheDesc.columnValue(row.key(), row.value(), cacheIdx -
QueryUtils.DEFAULT_COLUMNS_COUNT);
}
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
