数据节点进程有一些简单的构造，用于访问 NDB 集群中的数据。我们创建了一个非常简单的基准测试来检查每个构造的性能。

有四种访问方法

使用 NdbTransaction::getNdbOperation() 或 NdbTransaction::getNdbIndexOperation() 创建操作后，它将在以下三个步骤中定义

以下两个简短示例说明了此过程。为了简洁起见，我们省略了错误处理。

第一个示例使用 NdbOperation

// 1. Retrieve table object
myTable= myDict->getTable("MYTABLENAME");

// 2. Create an NdbOperation on this table
myOperation= myTransaction->getNdbOperation(myTable);

// 3. Define the operation's type and lock mode
myOperation->readTuple(NdbOperation::LM_Read);

// 4. Specify search conditions
myOperation->equal("ATTR1", i);

// 5. Perform attribute retrieval
myRecAttr= myOperation->getValue("ATTR2", NULL);

有关此类示例的更多信息，请参阅 第 2.5.2 节，“使用同步事务的 NDB API 示例”。

第二个示例使用 NdbIndexOperation

// 1. Retrieve index object
myIndex= myDict->getIndex("MYINDEX", "MYTABLENAME");

// 2. Create
myOperation= myTransaction->getNdbIndexOperation(myIndex);

// 3. Define type of operation and lock mode
myOperation->readTuple(NdbOperation::LM_Read);

// 4. Specify Search Conditions
myOperation->equal("ATTR1", i);

// 5. Attribute Actions
myRecAttr = myOperation->getValue("ATTR2", NULL);

另一个此类示例可在 第 2.5.6 节，“NDB API 示例：在扫描中使用辅助索引” 中找到。

我们现在将更详细地讨论创建和使用同步事务所涉及的每个步骤。

扫描大致相当于 SQL 游标，提供了一种执行高速行处理的方法。可以在表上（使用 NdbScanOperation）或有序索引上（通过 NdbIndexScanOperation）执行扫描。

扫描操作具有以下特点

使用 NdbTransaction::getNdbScanOperation() 或 NdbTransaction::getNdbIndexScanOperation() 创建操作后，它将按照以下步骤执行

以下两个简短的示例说明了此过程。为了保持简洁，我们省略了任何错误处理。

第一个示例使用NdbScanOperation执行表扫描。

// 1. Retrieve a table object
myTable= myDict->getTable("MYTABLENAME");

// 2. Create a scan operation (NdbScanOperation) on this table
myOperation= myTransaction->getNdbScanOperation(myTable);

// 3. Define the operation's type and lock mode
myOperation->readTuples(NdbOperation::LM_Read);

// 4. Specify search conditions
NdbScanFilter sf(myOperation);
sf.begin(NdbScanFilter::OR);
sf.eq(0, i);   // Return rows with column 0 equal to i or
sf.eq(1, i+1); // column 1 equal to (i+1)
sf.end();

// 5. Retrieve attributes
myRecAttr= myOperation->getValue("ATTR2", NULL);

第二个示例使用NdbIndexScanOperation执行索引扫描。

// 1. Retrieve index object
myIndex= myDict->getIndex("MYORDEREDINDEX", "MYTABLENAME");

// 2. Create an operation (NdbIndexScanOperation object)
myOperation= myTransaction->getNdbIndexScanOperation(myIndex);

// 3. Define type of operation and lock mode
myOperation->readTuples(NdbOperation::LM_Read);

// 4. Specify search conditions
// All rows with ATTR1 between i and (i+1)
myOperation->setBound("ATTR1", NdbIndexScanOperation::BoundGE, i);
myOperation->setBound("ATTR1", NdbIndexScanOperation::BoundLE, i+1);

// 5. Retrieve attributes
myRecAttr = MyOperation->getValue("ATTR2", NULL);

以下对执行扫描所需的每个步骤进行了一些额外的讨论。

扫描也可用于更新或删除行。这按如下方式执行。

索引扫描的特定功能。执行索引扫描时，可以使用NdbIndexScanOperation::setBound()只扫描表的子集。此外，可以使用NdbIndexScanOperation::readTuples()按升序或降序对结果集进行排序。请注意，除非sorted设置为true，否则默认情况下会返回无序的行。

同样重要的是要注意，当使用NdbIndexScanOperation::BoundEQ（请参见NdbIndexScanOperation::BoundType）和分区键时，实际上只会扫描包含行的片段。最后，执行排序扫描时，作为NdbIndexScanOperation::readTuples()方法的parallel参数传递的任何值都将被忽略，而改为使用最大并行度。换句话说，在这种情况下，将同时并行扫描所有可以扫描的片段。

对表或索引执行扫描可能会返回很多记录；但是，Ndb 每次在一个片段中只锁定预先确定的行数。每个片段中锁定的行数由传递给NdbScanOperation::readTuples()的批次参数控制。

为了使应用程序能够处理锁的释放方式，NdbScanOperation::nextResult()有一个布尔参数fetchAllowed。如果NdbScanOperation::nextResult()被调用，并且fetchAllowed等于false，则函数调用不会释放任何锁。否则，当前批次的锁可能会被释放。

以下示例展示了以有效方式处理锁的扫描删除。为了简洁起见，我们省略了错误处理。

int check;

// Outer loop for each batch of rows
while((check = MyScanOperation->nextResult(true)) == 0)
{
  do
  {
    // Inner loop for each row within the batch
    MyScanOperation->deleteCurrentTuple();
  }
  while((check = MyScanOperation->nextResult(false)) == 0);

  // When there are no more rows in the batch, execute all defined deletes
  MyTransaction->execute(NoCommit);
}

有关扫描的更完整示例，请参见第 2.5.5 节，“NDB API 基本扫描示例”。

错误可能发生在定义组成事务的操作时，也可能发生在实际执行事务时。捕获和处理任何类型的错误都需要测试由NdbTransaction::execute()返回的值，然后，如果指示错误（即，如果此值等于-1），则使用以下两种方法来识别错误的类型和位置。

此简短示例说明了如何检测错误以及如何使用这两种方法来识别错误。

theTransaction = theNdb->startTransaction();
theOperation = theTransaction->getNdbOperation("TEST_TABLE");
if(theOperation == NULL)
  goto error;

theOperation->readTuple(NdbOperation::LM_Read);
theOperation->setValue("ATTR_1", at1);
theOperation->setValue("ATTR_2", at1);  //  Error occurs here
theOperation->setValue("ATTR_3", at1);
theOperation->setValue("ATTR_4", at1);

if(theTransaction->execute(Commit) == -1)
{
  errorLine = theTransaction->getNdbErrorLine();
  errorOperation = theTransaction->getNdbErrorOperation();
}

在这里，errorLine是3，因为错误发生在NdbOperation对象（在本例中为theOperation）上调用的第三个方法中。如果NdbTransaction::getNdbErrorLine()的结果是0，则错误发生在执行操作时。在此示例中，errorOperation是指向对象theOperation的指针。NdbTransaction::getNdbError()方法返回一个NdbError对象，提供有关错误的信息。

处理事务失败（即，当报告错误时）的一种推荐方法如下所示。

当事务包含多个同时执行的操作时，可能会发生多个错误。在这种情况下，应用程序必须遍历所有操作并查询每个操作的NdbError对象，以找出真正发生的情况。