无

无

事务在 NDB API 中由一个 NdbTransaction 对象表示，该对象属于一个 Ndb 对象，并使用 Ndb::startTransaction() 创建。事务包含一个操作列表，由 NdbOperation 类或其子类之一表示——NdbScanOperation、NdbIndexOperation 或 NdbIndexScanOperation。每个操作访问恰好一个表。

下表列出了此类的公共方法以及每个方法的目的或用途

方法 readTuple()、insertTuple()、updateTuple()、writeTuple()、deleteTuple()、scanTable() 和 scanIndex() 需要使用 NdbRecord.

NdbTransaction 定义了 2 种公共类型，如下表所示

此方法关闭事务。它等效于调用 Ndb::closeTransaction().

如果事务尚未提交，则调用此方法时会中止该事务。请参见 Ndb::startTransaction().

void close
    (
      void
    )

无.

无.

此方法获取事务的提交状态。

CommitStatusType commitStatus
    (
      void
    )

无.

事务的提交状态，一个 CommitStatusType 类型的值。

此类型用于描述事务的提交状态。

以下表格列出了可能的值及其描述

使用 NdbRecord 删除元组。

const NdbOperation* deleteTuple
    (
      const NdbRecord* key_rec,
      const char* key_row,
      const NdbRecord* result_rec,
      char* result_row,
      const unsigned char* result_mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

此方法采用以下参数

指向表示此写入操作的 NdbOperation 的 const 指针。如果需要，可以检查操作是否有错误。

此类型设置事务的执行类型；也就是说，它应该执行、执行并提交，还是中止。它用作 execute() 方法的参数。（请参见 NdbTransaction::execute()。）

以下表格列出了可能的值及其描述

此方法用于执行事务。

int execute
    (
      ExecType execType,
      NdbOperation::AbortOption abortOption = NdbOperation::DefaultAbortOption,
      int force = 0
    )

execute() 方法采用以下三个参数

成功时返回 0，失败时返回 -1。事务没有中止并不一定意味着每个操作都成功；您必须分别检查每个操作是否有错误。

此方法使用 ExecType 等于 NoCommit 执行事务，如果仍然存在尚未执行的给定类型的 blob 部分操作。

int executePendingBlobOps
  (
    Uint8 flags = 0xFF
  )

flags 参数是按位 OR 的结果，等于 1 << optype，其中 optype 是一个 NdbOperation::Type。默认值对应于 NdbOperation::Type::PrimaryKeyAccess。

成功时返回 0，失败时返回 -1。事务没有中止并不一定意味着每个操作都成功；您必须分别检查每个操作是否有错误。

此方法检索事务的全局检查点 ID (GCI)。

每个已提交的事务都属于一个 GCI。当发生全局检查点时，已提交事务的日志会保存在磁盘上。

通过将事务的 GCI 与在重新启动的 NDB 集群中恢复的最新 GCI 的值进行比较，您可以确定事务是否已恢复。

此方法无法确定具有此 GCI 的全局检查点是否已保存在磁盘上。

扫描事务的 GCI 未定义，因为扫描事务不会执行任何更新。

在使用 ExecType::Commit 调用 execute() 之前，无法获得 GCI。

int getGCI
    (
      void
    )

无.

事务的 GCI，如果不可用，则为 -1。

获取 blob 读取操作的当前批次大小（以字节为单位）。当给定事务中要读取的 blob 数据量超过此数量时，将执行该事务的所有挂起的 blob 读取操作。

Uint32 getMaxPendingBlobReadBytes
    (
      void
    ) const

无.

当前 blob 读取批次大小（以字节为单位）。有关更多信息，请参见 NdbTransaction::setMaxPendingBlobReadBytes().

获取 blob 写入操作的当前批次大小（以字节为单位）。当给定事务中要写入的 blob 数据量超过此数量时，将执行该事务的所有挂起的 blob 写入操作。

Uint32 getMaxPendingBlobWriteBytes
    (
      void
    ) const

无.

当前 blob 写入批次大小（以字节为单位）。有关更多信息，请参见 NdbTransaction::setMaxPendingBlobWriteBytes().

此方法用于获取最新的错误 (NdbError)。

const NdbError& getNdbError
    (
      void
    ) const

无.

指向 NdbError 对象的引用。

此方法返回发生最新错误的行号。

int getNdbErrorLine
    (
      void
    )

无.

最新错误的行号。

此方法检索导致错误的操作。

要获取有关实际错误的更多信息，请使用 NdbOperation::getNdbError() 方法（该方法由 getNdbErrorOperation() 返回的 NdbOperation 对象）。

NdbOperation* getNdbErrorOperation
    (
      void
    )

无.

指向 NdbOperation 的指针。

此方法用于创建与给定表格关联的 NdbIndexOperation。

同一事务中的所有索引操作都必须使用此方法初始化。必须在执行操作之前定义操作。

NdbIndexOperation* getNdbIndexOperation
    (
      const NdbDictionary::Index* index
    )

要执行操作的 Index 对象。

指向新 NdbIndexOperation 的指针。

此方法用于创建与给定表格关联的 NdbIndexScanOperation。

同一事务中的所有索引扫描操作都必须使用此方法初始化。必须在执行操作之前定义操作。

NdbIndexScanOperation* getNdbIndexScanOperation
    (
      const NdbDictionary::Index* index
    )

要执行操作的 Index 对象。

指向新 NdbIndexScanOperation 的指针。

此方法用于创建与给定表关联的 NdbOperation。

同一事务中的所有操作都必须使用此方法初始化。操作必须在执行之前定义。

NdbOperation* getNdbOperation
    (
      const NdbDictionary::Table* table
    )

将要执行操作的 Table 对象。

指向新的 NdbOperation 的指针。

此方法用于创建与给定表关联的 NdbScanOperation。

同一事务中的所有扫描操作都必须使用此方法初始化。操作必须在执行之前定义。

NdbScanOperation* getNdbScanOperation
    (
      const NdbDictionary::Table* table
    )

将要执行操作的 Table 对象。

指向新的 NdbScanOperation 的指针。

此方法用于检索事务的已完成操作。通常用于获取属于给定事务的所有操作以检查错误。

NdbTransaction::getNextCompletedOperation(NULL) 返回事务的第一个 NdbOperation 对象；NdbTransaction::getNextCompletedOperation(myOp) 返回在 NdbOperation myOp 之后定义的 NdbOperation 对象。

此方法只能在事务执行后但事务关闭之前使用。

const NdbOperation* getNextCompletedOperation
    (
      const NdbOperation* op
    ) const

此方法需要一个参数 op，它是一个操作（NdbOperation 对象），或者 NULL。

跟随 op 的操作，或如果 getNextCompletedOperation() 使用 NULL 调用，则为事务定义的第一个操作。

此方法用于获取事务 ID。

Uint64 getTransactionId
    (
      void
    )

无.

事务 ID，作为无符号 64 位整数。

使用 NdbRecord 插入元组。

const NdbOperation* insertTuple
    (
      const NdbRecord* key_rec,
      const char* key_row,
      const NdbRecord* attr_rec,
      const char* attr_row,
      const unsigned char* mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

const NdbOperation* insertTuple
    (
      const NdbRecord* combined_rec,
      const char* combined_row,
      const unsigned char* mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

insertTuple() 接受以下参数

指向表示此插入操作的 NdbOperation 的 const 指针。

此方法使用 NdbRecord 对象读取元组。

const NdbOperation* readTuple
    (
      const NdbRecord* key_rec,
      const char* key_row,
      const NdbRecord* result_rec,
      char* result_row,
      NdbOperation::LockMode lock_mode = NdbOperation::LM_Read,
      const unsigned char* result_mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

此方法采用以下参数

指向表示此读取操作的 NdbOperation 的指针（这可用于检查错误）。

此方法更新事务的超时计数器，从而避免因事务超时而中止。

不建议对记录进行锁定并长时间保持锁定，因为这会影响其他事务。

int refresh
    (
      void
    )

无.

成功返回 0，失败返回 -1。

此方法用于释放锁定句柄（请参阅 NdbOperation::getLockHandle），当不再需要该句柄时。对于 NdbRecord 主键读取操作，这不能在关联的读取操作执行之前调用。

当事务关闭时，与给定事务关联的所有锁定句柄都会被释放。

int releaseLockHandle
    (
      const NdbLockHandle* lockHandle
    )

要释放的 NdbLockHandle 对象。

成功返回 0。

执行表的索引范围扫描，并可选地进行排序。

NdbIndexScanOperation* scanIndex
    (
      const NdbRecord* key_record,
      const NdbRecord* result_record,
      NdbOperation::LockMode lock_mode = NdbOperation::LM_Read,
      const unsigned char* result_mask = 0,
      const NdbIndexScanOperation::IndexBound* bound = 0,
      const NdbScanOperation::ScanOptions* options = 0,
      Uint32 sizeOfOptions = 0
    )

当前的 NdbIndexScanOperation，可用于错误检查。

此方法执行表扫描，使用 NdbRecord 对象读取列数据。

NdbScanOperation* scanTable
    (
      const NdbRecord* result_record,
      NdbOperation::LockMode lock_mode = NdbOperation::LM_Read,
      const unsigned char* result_mask = 0,
      Uint32 scan_flags = 0,
      Uint32 parallel = 0,
      Uint32 batch = 0
    )

scanTable() 方法接受以下参数

指向表示此扫描的 NdbScanOperation 的指针。如果需要，可以检查操作是否有错误。

设置 blob 读取操作的字节批处理大小。当给定事务中要读取的 blob 数据量超过此大小时，将执行事务的所有挂起 blob 读取操作。

void setMaxPendingBlobReadBytes
    (
      Uint32 bytes
    )

批处理大小，以 bytes 计。使用 0 将导致禁用 blob 读取批处理，这是默认行为（为了向后兼容）。

无.

设置 blob 写入操作的字节批处理大小。当给定事务中要写入的 blob 数据量超过此大小时，将执行事务的所有挂起 blob 写入操作。

void setMaxPendingBlobWriteBytes
    (
      Uint32 bytes
    )

批处理大小，以 bytes 计。使用 0 将导致禁用 blob 写入批处理，这是默认行为（为了向后兼容）。

无.

当使用多个 Ndb_cluster_connection 对象时，启用或禁用架构对象所有权检查。当此检查启用时，将检查此事务使用的对象以确保它们属于此连接拥有的 NdbDictionary。这是通过从连接中获取相同名称的架构对象并将它们与传递给事务的架构对象进行比较来完成的。如果它们不匹配，则会返回错误。

此方法可用于调试目的。（Bug #19875977）请注意，启用此检查会带来性能损失，因此您应该避免在生产环境中这样做。

void setSchemaObjOwnerChecks
    (
      bool runChecks
    )

单个参数 runChecks。使用 true 启用所有权检查，使用 false 禁用它们。

无.

此方法在当前事务上创建一个解锁操作；执行后，解锁操作将删除由传递给方法的 NdbLockHandle（参见 NdbOperation::getLockHandle）引用的锁。

const NdbOperation* unlock
    (
      const NdbLockHandle* lockHandle,
      NdbOperation::AbortOption ao = NdbOperation::DefaultAbortOption
    )

指向锁句柄的指针；此外，还可以选择一个 AbortOption 值 ao。

如果解锁操作失败（例如，由于行已解锁），则 AbortOption 指定如何处理此问题，默认情况下，错误会导致事务中止。

指向 NdbOperation（创建的解锁操作）的指针。

使用 NdbRecord 对象更新元组。

const NdbOperation* updateTuple
    (
      const NdbRecord* key_rec,
      const char* key_row,
      const NdbRecord* attr_rec,
      const char* attr_row,
      const unsigned char* mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

updateTuple() 接受以下参数

表示此操作的 NdbOperation（可用于检查错误）。

此方法与 NdbRecord 一起使用来写入数据元组。

const NdbOperation* writeTuple
    (
      const NdbRecord* key_rec,
      const char* key_row,
      const NdbRecord* attr_rec,
      const char* attr_row,
      const unsigned char* mask = 0,
      const NdbOperation::OperationOptions* opts = 0,
      Uint32 sizeOfOptions = 0
    )

此方法采用以下参数

指向表示此写入操作的 NdbOperation 的 const 指针。如果需要，可以检查操作是否有错误。