hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

bugfix : obkv bugfix patch master

Browse Source
This commit is contained in:
obdev
2023-12-15 07:17:23 +00:00
committed by ant-ob-hengtang
parent 93ba53389e
commit 88c1579fb8
9 changed files with 59 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/libtable/test/ob_batch_execute_test.cpp
View File

@ -3500,7 +3500,7 @@ TEST_F(TestBatchExecute, update_table_with_index_by_lowercase_rowkey)
ASSERT_EQ(OB_SUCCESS, update_entity->add_rowkey_value(rk_obj));
ASSERT_EQ(OB_SUCCESS, update_entity->set_property(T, v_obj));
ObTableOperation table_operation = ObTableOperation::insert_or_update(*update_entity);
ASSERT_EQ(OB_SUCCESS, the_table->execute(table_operation, r));
ASSERT_EQ(OB_ERR_UPDATE_ROWKEY_COLUMN, the_table->execute(table_operation, r));
ASSERT_EQ(OB_SUCCESS, r.get_errno());
}
{
@ -3522,7 +3522,7 @@ TEST_F(TestBatchExecute, update_table_with_index_by_lowercase_rowkey)
ASSERT_EQ(1, result_entity->get_properties_count());
ASSERT_EQ(OB_SUCCESS, result_entity->get_property(K, obj1));
ASSERT_EQ(OB_SUCCESS, obj1.get_varchar(str));
ASSERT_TRUE(str == ObString::make_string("test"));
ASSERT_TRUE(str == ObString::make_string("TEST"));
}
ASSERT_EQ(OB_ITER_END, iter->get_next_entity(result_entity));
}
@ -4692,9 +4692,9 @@ TEST_F(TestBatchExecute, single_insert_up)
value.set_double(c2_value);
ASSERT_EQ(OB_SUCCESS, entity->set_property(C2, value));
ObTableOperation table_operation = ObTableOperation::insert_or_update(*entity);
ASSERT_EQ(OB_SUCCESS, the_table->execute(table_operation, r));
ASSERT_EQ(OB_ERR_UPDATE_ROWKEY_COLUMN, the_table->execute(table_operation, r));
ASSERT_EQ(OB_SUCCESS, r.get_errno());
ASSERT_EQ(1, r.get_affected_rows());
ASSERT_EQ(0, r.get_affected_rows());
ASSERT_EQ(ObTableOperationType::INSERT_OR_UPDATE, r.type());
ASSERT_EQ(OB_SUCCESS, r.get_entity(result_entity));
ASSERT_TRUE(result_entity->is_empty());
@ -4737,9 +4737,9 @@ TEST_F(TestBatchExecute, single_insert_up)
ASSERT_EQ(OB_SUCCESS, entity->set_property(C2, value));
ObTableOperation table_operation = ObTableOperation::insert_or_update(*entity);
// TODO:@linjing 和sql行为不一致
ASSERT_EQ(OB_SUCCESS, the_table->execute(table_operation, r));
ASSERT_EQ(OB_ERR_UPDATE_ROWKEY_COLUMN, the_table->execute(table_operation, r));
ASSERT_EQ(OB_SUCCESS, r.get_errno());
ASSERT_EQ(1, r.get_affected_rows());
ASSERT_EQ(0, r.get_affected_rows());
ASSERT_EQ(ObTableOperationType::INSERT_OR_UPDATE, r.type());
ASSERT_EQ(OB_SUCCESS, r.get_entity(result_entity));
ASSERT_TRUE(result_entity->is_empty());