Docs 菜单
Docs 主页
/
MongoDB 阿特拉斯
/
Atlas Device SDKs
/
.NET SDK
/
CRUD

写入事务 - .NET SDK

在此页面上

  • 概述
  • 发起事务
  • 检查事务状态

概述

除了读取对象外，您还可以在 Realm 中创建、更新和删除对象。 由于这些操作会修改域的状态，因此我们将其称为“写入”，并且对Realm的所有写入都必须在事务中进行。

事务是一系列读写操作，Realm 将其视为单个不可分割的操作。 事务是全有或全无操作：事务中的所有操作要么成功，要么事务中的所有操作都不生效。

Realm 一次只允许一个打开的事务。 Realm 会阻止其他线程上的其他写入，直到打开的事务完成。 这可确保在事务中从 Realm 读取值时不存在争用情况。

当事务中的所有操作完成后，Realm 要么提交事务，要么取消事务：

  • 当 Realm 提交事务时，Realm 会将所有更改写入磁盘。 对于同步 Realm，SDK 会将更改排队以便与 Atlas App Services 同步。

  • 当 Realm 取消写事务（write transaction）时（如事务中的操作导致错误时），所有更改都将被丢弃（或“回滚”）。

发起事务

.NET SDK 提供了一个简单的 API，可用于大多数写入操作。 Write()和WriteAsync()方法将所有命令包装到单个事务中，然后提交该事务。

Write()和WriteAsync()方法是使用BeginWrite()和Transaction.Commit()方法及其Async对应方法的简写。在大多数情况下，这两种写入方法都可以满足您的需求。如果需要更好地控制事务，请将BeginWrite()与以下Transaction方法之一结合使用：

以下代码展示了如何使用这两种方法：

// Instantiate a class, as normal.
var dog = new Dog { Id = 42, Name = "Max", Age = 5 };
// Open a thread-safe transaction.
realm.Write(() =>
{
    // Add the instance to the realm.
    realm.Add(dog);
});
// Open a thread-safe transaction.
using (var transaction = realm.BeginWrite())
{
    // At this point, the TransactionState is "Running":
    // transaction.State == TransactionState.Running
    try
    {
        // Perform a write op...
        realm.Add(myDog);
        // Do other work that needs to be included in
        // this transaction
        if (transaction.State == TransactionState.Running)
        {
            transaction.Commit();
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
        // Something went wrong; roll back the transaction
        if (transaction.State != TransactionState.RolledBack &&
            transaction.State != TransactionState.Committed)
        {
            transaction.Rollback();
        }
    }
}

注意

CancelationTokens

与大多数 C# 异步方法一样， WriteAsync 、 BeginWriteAsync 和 CommitAsync 方法可以采用 CancellationToken 作为参数，为您提供在进程完成之前取消操作的选项。

检查事务状态

SDK 提供了包含当前事务状态的TransactionState属性。可以使用TransactionState确保不会提交或回滚事务两次：

// Open a thread-safe transaction.
using (var transaction = realm.BeginWrite())
{
    // At this point, the TransactionState is "Running":
    // transaction.State == TransactionState.Running
    try
    {
        // Perform a write op...
        realm.Add(myDog);
        // Do other work that needs to be included in
        // this transaction
        if (transaction.State == TransactionState.Running)
        {
            transaction.Commit();
        }
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
        // Something went wrong; roll back the transaction
        if (transaction.State != TransactionState.RolledBack &&
            transaction.State != TransactionState.Committed)
        {
            transaction.Rollback();
        }
    }
}

后退

线程

来年

响应变更

在此页面上