[
https://issues.apache.org/jira/browse/IGNITE-6343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roman Kondakov reassigned IGNITE-6343:
--------------------------------------
Assignee: Roman Kondakov
> Index is not used properly if changing sort order.
> --------------------------------------------------
>
> Key: IGNITE-6343
> URL: https://issues.apache.org/jira/browse/IGNITE-6343
> Project: Ignite
> Issue Type: Improvement
> Components: sql
> Affects Versions: 2.0
> Reporter: Alexei Scherbakov
> Assignee: Roman Kondakov
> Labels: performance
>
> Unit test reproducer:
> {noformat}
> /*
> * 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.cache;
> import java.util.Calendar;
> import java.util.Collections;
> import java.util.Date;
> import java.util.LinkedHashMap;
> import java.util.List;
> import org.apache.ignite.IgniteCache;
> import org.apache.ignite.cache.CacheMode;
> import org.apache.ignite.cache.QueryEntity;
> import org.apache.ignite.cache.QueryIndex;
> import org.apache.ignite.cache.QueryIndexType;
> import org.apache.ignite.cache.query.SqlFieldsQuery;
> import org.apache.ignite.configuration.CacheConfiguration;
> import org.apache.ignite.configuration.IgniteConfiguration;
> import org.apache.ignite.configuration.MemoryConfiguration;
> import org.apache.ignite.configuration.MemoryPolicyConfiguration;
> import org.apache.ignite.internal.util.typedef.internal.U;
> import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
> import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
> import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
> import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
> import static org.apache.ignite.cache.CacheMode.PARTITIONED;
> import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
> import static java.util.Calendar.*;
> /**
> * Tests for cache query results serialization.
> */
> public class GridCacheQueryIndexUsageSelfTest extends GridCommonAbstractTest {
> /** */
> private static final int GRID_CNT = 1;
> /** */
> private static final String CACHE_NAME = "A";
> /** */
> private static final CacheMode CACHE_MODE = PARTITIONED;
> /** */
> private static TcpDiscoveryIpFinder ipFinder = new
> TcpDiscoveryVmIpFinder(true);
> /** {@inheritDoc} */
> @Override protected void beforeTest() throws Exception {
> startGridsMultiThreaded(GRID_CNT);
> }
> /** {@inheritDoc} */
> @Override protected void afterTest() throws Exception {
> stopAllGrids();
> }
> /** {@inheritDoc} */
> @Override protected IgniteConfiguration getConfiguration(String
> igniteInstanceName) throws Exception {
> IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName);
> MemoryPolicyConfiguration mpcfg = new MemoryPolicyConfiguration();
> //mpcfg.setMaxSize(2 * 1024 * 1024 * 1024L);
> mpcfg.setName("def");
> MemoryConfiguration mcfg = new MemoryConfiguration();
> mcfg.setDefaultMemoryPolicyName("def");
> mcfg.setMemoryPolicies(mpcfg);
> cfg.setMemoryConfiguration(mcfg);
> TcpDiscoverySpi disco = new TcpDiscoverySpi();
> disco.setIpFinder(ipFinder);
> cfg.setDiscoverySpi(disco);
> CacheConfiguration cacheCfg = defaultCacheConfiguration();
> cacheCfg.setName(CACHE_NAME);
> cacheCfg.setCacheMode(CACHE_MODE);
> cacheCfg.setWriteSynchronizationMode(FULL_SYNC);
> QueryEntity qe = new QueryEntity();
> qe.setKeyType(Long.class.getName());
> qe.setValueType(IndexedValue.class.getName());
> LinkedHashMap<String, String> fields = U.newLinkedHashMap(3);
> fields.put("id", Long.class.getName());
> fields.put("startDate", Date.class.getName());
> qe.setFields(fields);
> QueryIndex idx = new QueryIndex();
> idx.setIndexType(QueryIndexType.SORTED);
> LinkedHashMap<String, Boolean> idxFields = U.newLinkedHashMap(3);
> idxFields.put("startDate", Boolean.TRUE);
> idx.setFields(idxFields);
> qe.setIndexes(Collections.singleton(idx));
> cacheCfg.setQueryEntities(Collections.singleton(qe));
> cfg.setCacheConfiguration(cacheCfg);
> return cfg;
> }
> /** */
> public void testIndexUsageAscSort() {
> testIndexUsage0(true);
> }
> /** */
> public void testIndexUsageDescSort() {
> testIndexUsage0(false);
> }
> /** */
> private void testIndexUsage0(boolean asc) {
> Calendar start = Calendar.getInstance();
> start.set(2017, APRIL, 1, 0, 0, 0);
> IgniteCache<Object, Object> cache = ignite(0).cache(CACHE_NAME);
> int step = 50;
> for (long i = 0; i < step; i++) {
> Date date = start.getTime();
> for (long j = 0; j < step; j++)
> cache.put(i * step + j, new IndexedValue(i * step + j, date));
> start.add(Calendar.DAY_OF_MONTH, 1);
> }
> start.set(2017, APRIL, 10, 0, 0, 0);
> Date from = start.getTime();
> start.add(DAY_OF_MONTH, step * step / 2);
> int limit = 500;
> Date to = start.getTime();
> SqlFieldsQuery q = new SqlFieldsQuery("explain analyze select _KEY,
> _VAL, startdate " +
> "from IndexedValue where startDate >= ? and startDate < ? " +
> "order by startdate " + (asc ? "asc" : "desc") + " limit " +
> limit);
> q.setLocal(true);
> q.setArgs(from, to);
> List<List<?>> all = cache.query(q).getAll();
> String plan = all.toString();
> final String str = "scanCount: ";
> int off = plan.indexOf(str);
> assertTrue(off != -1);
> off += "scanCount:".length() + 1;
> int st = off;
> while(Character.isDigit(plan.charAt(off++)));
> int scanCnt = Integer.parseInt(plan.substring(st, off - 1));
> assertEquals(limit, scanCnt);
> }
> /** */
> public static class IndexedValue {
> /** */
> private Long id;
> /** */
> private Date startDate;
> /**
> * @param id Id.
> * @param startDate Start date.
> */
> public IndexedValue(Long id, Date startDate) {
> this.id = id;
> this.startDate = startDate;
> }
> /** */
> public Long getId() {
> return id;
> }
> /** */
> public void setId(Long id) {
> this.id = id;
> }
> /** */
> public Date getStartDate() {
> return startDate;
> }
> /** */
> public void setStartDate(Date startDate) {
> this.startDate = startDate;
> }
> }
> }
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
