Skip to content

add reverse scan case #178

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 2 commits into
base: secondary_part
Choose a base branch
from
Open

add reverse scan case #178

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
abcf0aa
add reverse scan case
maochongxin Mar 21, 2025
fa42a82
fix reverse scan case
maochongxin Mar 31, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
83 changes: 79 additions & 4 deletions src/test/java/com/alipay/oceanbase/hbase/secondary/OHTableSecondaryPartScanTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@
import com.alipay.oceanbase.hbase.OHTableClient;
import com.alipay.oceanbase.hbase.util.ObHTableTestUtil;
import com.alipay.oceanbase.hbase.util.TableTemplateManager;
import com.alipay.oceanbase.rpc.exception.ObTableException;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.BinaryComparator;
Expand All @@ -31,6 +32,8 @@

import static com.alipay.oceanbase.hbase.util.ObHTableSecondaryPartUtil.*;
import static com.alipay.oceanbase.hbase.util.ObHTableTestUtil.FOR_EACH;
import static com.alipay.oceanbase.hbase.util.ObHTableTestUtil.secureCompare;
import static com.alipay.oceanbase.hbase.util.TableTemplateManager.TableType.SINGLE_PARTITIONED_REGULAR;
import static org.apache.hadoop.hbase.util.Bytes.toBytes;
import static org.junit.Assert.assertEquals;

Expand All @@ -41,10 +44,8 @@ public class OHTableSecondaryPartScanTest {
@BeforeClass
public static void before() throws Exception {
openDistributedExecute();
for (TableTemplateManager.TableType type : TableTemplateManager.TableType.values()) {
if (!type.name().contains("TIME")) {
createTables(type, tableNames, group2tableNames, true);
}
for (TableTemplateManager.TableType type : TableTemplateManager.NORMAL_TABLES) {
createTables(type, tableNames, group2tableNames, true);
}
}

Expand Down Expand Up @@ -486,14 +487,88 @@ public static void testMultiCFScanImpl(Map.Entry<String, List<String>> entry) th
}
}
}

public static void testReverseScanImpl(String tableName) throws Throwable {
OHTableClient hTable = ObHTableTestUtil.newOHTableClient(getTableName(tableName));
hTable.init();

String family = getColumnFamilyName(tableName);
String key = "putKey";
String column = "putColumn";
long timestamp = System.currentTimeMillis();
String value = "value";

for (int i = 0; i < 10; ++i) {
Put put = new Put(toBytes(key + i));
put.add(family.getBytes(), (column + 1).getBytes(), timestamp, toBytes(value + i));
put.add(family.getBytes(), (column + 2).getBytes(), timestamp, toBytes(value + i));
hTable.put(put);
}

{
Scan scan = new Scan("putKey8".getBytes(), "putKey".getBytes());
scan.addColumn(family.getBytes(), (column + "2").getBytes());
scan.setReversed(true);
try {
ResultScanner scanner = hTable.getScanner(scan);
} catch (Exception e) {
Assert.assertTrue(e.getCause().getMessage().contains("OB_NOT_SUPPORTED"));
}
}
}

public static void testReverseScanMultiCFImpl(Map.Entry<String, List<String>> entry) throws Throwable {
String groupName = getTableName(entry.getKey());
OHTableClient hTable = ObHTableTestUtil.newOHTableClient(groupName);
hTable.init();

String key = "putKey";
String column = "putColumn";
long timestamp = System.currentTimeMillis();
String value = "value";
// prepare data
for (int i = 0; i < 10; ++i) {
Put put = new Put(toBytes(key + i));
for (String tableName : entry.getValue()) {
String family = getColumnFamilyName(tableName);
put.add(family.getBytes(), (column + 1).getBytes(), timestamp, toBytes(family + value + i));
put.add(family.getBytes(), (column + 2).getBytes(), timestamp, toBytes(family + value + i));
}
hTable.put(put);
}

{
Scan scan = new Scan("putKey8".getBytes(), "putKey".getBytes());
for (String tableName : entry.getValue()) {
String family = getColumnFamilyName(tableName);
scan.addFamily(family.getBytes());
}
scan.setReversed(true);
try {
ResultScanner scanner = hTable.getScanner(scan);
} catch (Exception e) {
Assert.assertTrue(e.getCause().getMessage().contains("OB_NOT_SUPPORTED"));
}
}
}

@Test
public void testScan() throws Throwable {
FOR_EACH(tableNames, OHTableSecondaryPartScanTest::testScanImpl);
}

@Test
public void testReverseScan() throws Throwable {
FOR_EACH(tableNames, OHTableSecondaryPartScanTest::testReverseScanImpl);
}

@Test
public void testMultiCFScan() throws Throwable {
FOR_EACH(group2tableNames, OHTableSecondaryPartScanTest::testMultiCFScanImpl);
}

@Test
public void testMultiCFReverseScan() throws Throwable {
FOR_EACH(group2tableNames, OHTableSecondaryPartScanTest::testReverseScanMultiCFImpl);
}
}