Method SingleRowTransactionTest

src/observer/test/observer_test.cc:306–385

  }

  void SingleRowTransactionTest() {
    tera::ErrorCode err;
    tera::Client* client = tera::Client::NewClient(FLAGS_flagfile, &err);
    // for ut test
    EXPECT_EQ(tera::ErrorCode::kOK, err.GetType());
    // for no core
    if (tera::ErrorCode::kOK != err.GetType()) {
      LOG(ERROR) << "new client failed";
      return;
    }

    // create table
    tera::TableDescriptor table_desc("observer_table_gtx");
    table_desc.EnableTxn();

    table_desc.AddLocalityGroup("lg1");
    tera::ColumnFamilyDescriptor* cf1 = table_desc.AddColumnFamily("cf", "lg1");
    cf1->EnableNotify();
    ExtendNotifyLgToDescriptor(&table_desc);

    client->CreateTable(table_desc, &err);
    if (err.GetType() != tera::ErrorCode::kOK) {
      LOG(ERROR) << "Create table fail";
      return;
    }

    std::unique_ptr<Table> table(client->OpenTable("observer_table_gtx", &err));
    EXPECT_EQ(tera::ErrorCode::kOK, err.GetType());
    if (tera::ErrorCode::kOK != err.GetType()) {
      LOG(ERROR) << "open table failed";
      return;
    }

    std::unique_ptr<tera::Transaction> t(table->StartRowTransaction("www.baidu.com"));

    assert(t != NULL);
    std::unique_ptr<tera::RowMutation> mu0(table->NewRowMutation("www.baidu.com"));
    mu0->Put("_N_", "cf:Page", "I am not important");
    mu0->Put("cf", "Page", "hello world", -1);
    t->ApplyMutation(mu0.get());
    t->Commit();

    if (t->GetError().GetType() != tera::ErrorCode::kOK) {
      std::cout << t->GetError().ToString() << std::endl;
    } else {
      std::cout << "commit success" << std::endl;
    }

    Observer* observer = new TestWorkerGTX();

    Scanner* scanner = new ScannerImpl();
    bool ret = scanner->Init();

    EXPECT_EQ(true, ret);
    if (!ret) {
      LOG(ERROR) << "fail to init scanner_impl";
      return;
    }