src/test/test_binlog_event.cpp - dev - envoy.istio/oblogproxy

src/test/test_binlog_event.cpp
142 строки3 KB
wangxiantong.wxt
fix gtid subtract
04 дек 2023, 15:51
04 дек 2023, 15:518cc9942
/**
 * Copyright (c) 2021 OceanBase
 * OceanBase Migration Service LogProxy is licensed under Mulan PubL v2.
 * You can use this software according to the terms and conditions of the Mulan PubL v2.
 * You may obtain a copy of Mulan PubL v2 at:
 *          http://license.coscl.org.cn/MulanPubL-2.0
 * THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
 * EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
 * MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
 * See the Mulan PubL v2 for more details.
 */

#include <bitset>
#include "gtest/gtest.h"
#include "common.h"
#include "log.h"
#include "binlog/binlog_converter/binlog_convert.h"
#include "data_type.h"
#include "binlog/binlog_converter/binlog_converter.h"

using namespace oceanbase::logproxy;

TEST(WriteRowsEvent, deserialize)
{
  unsigned char event[] = {0x27,
      0x21,
      0x18,
      0x64,
      0x1e,
      0x44,
      0x0f,
      0x65,
      0x44,
      0x20,
      0x00,
      0x00,
      0x00,
      0x9f,
      0x01,
      0x00,
      0x00,
      0x01,
      0x00,
      0xe0,
      0x3d,
      0x09,
      0x0b,
      0xe7,
      0x63,
      0x01,
      0x00,
      0x02,
      0x00,
      0x01,
      0xff,
      0xff};
  WriteRowsEvent write_rows_event = WriteRowsEvent(0, 0);
  write_rows_event.set_checksum_flag(OFF);
  write_rows_event.deserialize(event);
  printf("%s", write_rows_event.print_event_info().c_str());
  ASSERT_EQ("table_id: 109843973750240 flags: STMT_END_F", write_rows_event.print_event_info());
}

TEST(PreviousGtidsLogEvent, deserialize)
{}
{
  unsigned char event[] = {0x41,
      0xc6,
      0x5a,
      0x65,
      0x23,
      0x01,
      0x00,
      0x00,
      0x00,
      0x47,
      0x00,
      0x00,
      0x00,
      0xc2,
      0x00,
      0x00,
      0x00,
      0x80,
      0x00,
      0x01,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x70,
      0x63,
      0x48,
      0xf0,
      0x07,
      0xfc,
      0x11,
      0xed,
      0xa7,
      0x17,
      0x02,
      0x42,
      0xac,
      0x11,
      0x00,
      0x02,
      0x01,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x01,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x0b,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0x00,
      0xa4,
      0x9a,
      0x91,
      0x03};
  auto pre_gtid_event = PreviousGtidsLogEvent();
  pre_gtid_event.deserialize(event);
  OMS_INFO(pre_gtid_event.print_event_info());
  ASSERT_EQ("706348f0-07fc-11ed-a717-0242ac110002:1-10", pre_gtid_event.print_event_info());
}