Skip to content

refactor constructing newkv in building batchOperation#212

Merged
maochongxin merged 2 commits into
oceanbase:masterfrom
Zhou-jw:adjust_construct_newkv_in_buildBatchOperation
May 8, 2025
Merged

refactor constructing newkv in building batchOperation#212
maochongxin merged 2 commits into
oceanbase:masterfrom
Zhou-jw:adjust_construct_newkv_in_buildBatchOperation

Conversation

@Zhou-jw

@Zhou-jw Zhou-jw commented Apr 30, 2025

Copy link
Copy Markdown
Contributor

Test case:

String groupName = getTableName(entry.getKey());
        System.out.println("groupName: " + groupName);
        OHTableClient hTable = ObHTableTestUtil.newOHTableClient(groupName);
        hTable.init();

//        byte[] Rowkey = generateRandomValue(1024);
        byte[] Column = generateRandomValue(256);
        byte[] Rowkey = "rowkey".getBytes();
//        byte[] Column = "col".getBytes();
        byte[] Value = generateRandomValue(1024);
        int cnt = 0;
        long timestamp = System.currentTimeMillis();
        Put put = new Put(Rowkey);
        Delete delete = new Delete(Rowkey);
        for (String tableName : entry.getValue()) {
            String family = getColumnFamilyName(tableName);
            // 输出 Column的大小
//            System.err.println("Column array size: " + Column.length);
            put.addColumn(family.getBytes(), Column, timestamp, Value);
//            delete.addColumns(family.getBytes(), Column);
            cnt += 1;
        }

        hTable.put(put);
        System.out.println("put finished");
        Thread.sleep(3000);

        Get get1 = new Get(Rowkey);
        get1.setMaxVersions();
        for (String tableName : entry.getValue()) {
            String family = getColumnFamilyName(tableName);
            get1.addColumn(toBytes(family), Column);
            delete.addColumns(toBytes(family), Column, timestamp);
            System.out.println(tableName + " delete " + family + "_col ");
        }
        Result result = hTable.get(get1);
        Assert(entry.getValue(), ()->Assert.assertEquals(3, result.size()));

        hTable.delete(delete);

        Get get0 = new Get(Rowkey);
        get0.setMaxVersions();
        for (String tableName : entry.getValue()) {
            String family = getColumnFamilyName(tableName);
            get0.addColumn(toBytes(family), Column);
        }
        Result result0 = hTable.get(get0);
        Assert(entry.getValue(), ()->Assert.assertEquals(0, result0.size()));
        hTable.close();
        System.out.println(groupName + " succeeds");

see also #210

@maochongxin

Copy link
Copy Markdown
Contributor

LGTM

@maochongxin maochongxin merged commit 0d83374 into oceanbase:master May 8, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants