没有任何

没有任何

事务在 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
    )

此方法采用以下参数：

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

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

下表显示了可能的值以及说明：

此方法用于执行事务。

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

该execute()方法采用此处列出的三个参数：

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

如果还有任何尚未执行的给定类型的 blob 部分操作， 此方法将执行 ExecType 等于的事务。NoCommit

int executePendingBlobOps
  (
    Uint8 flags = 0xFF
  )

flags参数是按位的结果 ，OR等于，其中 是 。默认对应于 . 1 << optypeoptypeNdbOperation::TypeNdbOperation::Type::PrimaryKeyAccess

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

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

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

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

该方法无法判断带有该GCI的全局检查点是否已经保存在磁盘上。

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

execute() 在使用调用 之前，GCI 不可 用ExecType::Commit。

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() 方法。 NdbOperationgetNdbErrorOperation()

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)NdbOperationNdbOperation myOp

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

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()采用以下参数：

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

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 此连接所拥有的。这是通过从连接中获取同名的模式对象并将它们与传递给事务的模式对象进行比较来完成的。如果它们不匹配，则返回错误。

从 NDB 7.3.9 开始，此方法可用于调试目的。（错误号 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
    )

此方法采用以下参数：

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