content: /*
   * 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.cassandra.db.filter;
  
  import java.nio.ByteBuffer;
  import java.util.ArrayList;
  import java.util.Collections;
  import java.util.concurrent.atomic.AtomicBoolean;
  
  import com.google.common.collect.ImmutableList;
  import org.junit.Test;
  
  import org.apache.cassandra.cql3.ColumnIdentifier;
  import org.apache.cassandra.cql3.Operator;
  import org.apache.cassandra.db.Clustering;
  import org.apache.cassandra.db.DecoratedKey;
  import org.apache.cassandra.db.DeletionTime;
  import org.apache.cassandra.db.LivenessInfo;
  import org.apache.cassandra.db.RegularAndStaticColumns;
  import org.apache.cassandra.db.marshal.Int32Type;
  import org.apache.cassandra.db.marshal.UTF8Type;
  import org.apache.cassandra.db.partitions.SingletonUnfilteredPartitionIterator;
  import org.apache.cassandra.db.partitions.UnfilteredPartitionIterator;
  import org.apache.cassandra.db.rows.BTreeRow;
  import org.apache.cassandra.db.rows.BufferCell;
  import org.apache.cassandra.db.rows.Cell;
  import org.apache.cassandra.db.rows.EncodingStats;
  import org.apache.cassandra.db.rows.Row;
  import org.apache.cassandra.db.rows.Rows;
  import org.apache.cassandra.db.rows.Unfiltered;
  import org.apache.cassandra.db.rows.UnfilteredRowIterator;
  import org.apache.cassandra.schema.ColumnMetadata;
  import org.apache.cassandra.schema.TableMetadata;
  import org.apache.cassandra.utils.ByteBufferUtil;
  import org.apache.cassandra.utils.btree.BTree;
  
  import static org.junit.Assert.assertFalse;
  import static org.junit.Assert.assertTrue;
  
  public class RowFilterTest
  {
  
      @Test
      public void testCQLFilterClose()
      {
          // CASSANDRA-15126
          TableMetadata metadata = TableMetadata.builder("testks", "testcf")
                                                .addPartitionKeyColumn("pk", Int32Type.instance)
                                                .addStaticColumn("s", Int32Type.instance)
                                                .addRegularColumn("r", Int32Type.instance)
                                                .offline()
                                                .build();
          ColumnMetadata s = metadata.getColumn(new ColumnIdentifier("s", true));
          ColumnMetadata r = metadata.getColumn(new ColumnIdentifier("r", true));
  
          ByteBuffer one = Int32Type.instance.decompose(1);
          RowFilter filter = RowFilter.none().withNewExpressions(new ArrayList<>());
          filter.add(s, Operator.NEQ, one);
          AtomicBoolean closed = new AtomicBoolean();
          UnfilteredPartitionIterator iter = filter.filter(new SingletonUnfilteredPartitionIterator(new UnfilteredRowIterator()
          {
              public DeletionTime partitionLevelDeletion() { return null; }
              public EncodingStats stats() { return null; }
              public TableMetadata metadata() { return metadata; }
              public boolean isReverseOrder() { return false; }
              public RegularAndStaticColumns columns() { return null; }
              public DecoratedKey partitionKey() { return null; }
              public boolean hasNext() { return false; }
              public Unfiltered next() { return null; }
              public Row staticRow()
              {
                  return BTreeRow.create(Clustering.STATIC_CLUSTERING,
                                         LivenessInfo.EMPTY,
                                         Row.Deletion.LIVE,
                                         BTree.singleton(new BufferCell(s, 1, Cell.NO_TTL, Cell.NO_DELETION_TIME, one, null)));
              }
              public void close()
              {
                  closed.set(true);
              }
          }), 1);
          assertFalse(iter.hasNext());
          assertTrue(closed.get());
  
          filter = RowFilter.none().withNewExpressions(new ArrayList<>());
          filter.add(r, Operator.NEQ, one);
          closed.set(false);
          iter = filter.filter(new SingletonUnfilteredPartitionIterator(new UnfilteredRowIterator()
          {
              boolean hasNext = true;
              public DeletionTime partitionLevelDeletion() { return null; }
              public EncodingStats stats() { return null; }
              public TableMetadata metadata() { return metadata; }
              public boolean isReverseOrder() { return false; }
              public RegularAndStaticColumns columns() { return null; }
              public DecoratedKey partitionKey() { return null; }
              public Row staticRow() { return Rows.EMPTY_STATIC_ROW; }
              public boolean hasNext()
              {
                  boolean r = hasNext;
                  hasNext = false;
                  return r;
              }
              public Unfiltered next()
              {
                  return BTreeRow.create(Clustering.EMPTY,
                                         LivenessInfo.EMPTY,
                                         Row.Deletion.LIVE,
                                         BTree.singleton(new BufferCell(r, 1, Cell.NO_TTL, Cell.NO_DELETION_TIME, one, null)));
              }
              public void close()
              {
                  closed.set(true);
              }
          }), 1);
          assertFalse(iter.hasNext());
          assertTrue(closed.get());
      }
  
      @Test
      public void testMutableIntersections()
      {
          TableMetadata metadata = TableMetadata.builder("testks", "testcf")
                                                .addPartitionKeyColumn("pk", Int32Type.instance)
                                                .addRegularColumn("r", Int32Type.instance)
                                                .addRegularColumn("t", UTF8Type.instance)
                                                .offline()
                                                .build();
  
          RowFilter filter = RowFilter.none().withNewExpressions(new ArrayList<>());
          assertFalse(filter.isMutableIntersection());
          
          ColumnMetadata r = metadata.getColumn(new ColumnIdentifier("r", true));
          RowFilter.Expression gt = new RowFilter.SimpleExpression(r, Operator.GT, ByteBufferUtil.EMPTY_BYTE_BUFFER);
          filter = filter.withNewExpressions(Collections.singletonList(gt));
          assertFalse(filter.isMutableIntersection());
  
          RowFilter.Expression lt = new RowFilter.SimpleExpression(r, Operator.LT, ByteBufferUtil.EMPTY_BYTE_BUFFER);
          filter = filter.withNewExpressions(ImmutableList.of(gt, lt));
          assertFalse(filter.isMutableIntersection());
  
          ColumnMetadata t = metadata.getColumn(new ColumnIdentifier("t", true));
          RowFilter.Expression eq = new RowFilter.SimpleExpression(t, Operator.EQ, ByteBufferUtil.EMPTY_BYTE_BUFFER);
          filter = filter.withNewExpressions(ImmutableList.of(gt, lt, eq));
          assertTrue(filter.isMutableIntersection());
      }
  }
  