亚洲欧洲无码精品合集,欧美不卡精品中文字幕日韩,老少配老妇熟女中文高清

表格存儲提供了單行插入、單行更新和批量寫入的寫入方式用于寫入數據到數據表。當要寫入數據到數據表時，您需要指定完整主鍵以及要增刪改的屬性列。在高并發應用中寫入數據時，您可以配置行存在性條件或者列條件實現按照指定條件更新數據。

如果需要了解表格存儲各場景的應用案例，請參見快速玩轉Tablestore入門與實戰。

寫入方式

表格存儲提供的數據寫入接口包括PutRow、UpdateRow和BatchWriteRow。寫入數據時，請根據實際場景選擇相應寫入方式。

寫入方式	說明	適用場景
插入單行數據	調用PutRow接口新寫入一行數據。如果該行已存在，則表格存儲會先刪除原行數據（原行的所有列以及所有版本的數據），再寫入新行數據。	適用于要寫入數據較少的場景。
更新單行數據	調用UpdateRow接口更新一行數據，支持增加和刪除一行中的屬性列，刪除屬性列指定版本的數據，或者更新已存在的屬性列值。如果更新的行不存在，則新增一行數據。	適用于更新已寫入數據的場景，例如刪除屬性列、刪除某個數據版本、修改屬性列值等。
批量寫入數據	調用BatchWriteRow接口在一次請求中進行批量寫入操作或者一次對多張表進行寫入。 BatchWriteRow操作由多個PutRow、UpdateRow、DeleteRow子操作組成，構造子操作的過程與使用PutRow接口、UpdateRow接口和DeleteRow接口時相同。	適用于要寫入、刪除或者更新大量數據以及要同時進行增刪改數據的場景。

前提條件

已初始化Client，具體操作，請參見初始化OTSClient。
已創建數據表并寫入數據。具體操作，請參見創建數據表和寫入數據。

插入單行數據

調用PutRow接口新寫入一行數據。如果該行已存在，則先刪除原行數據（原行的所有列以及所有版本的數據），再寫入新行數據。

接口

/// <summary>
/// 指定數據表名稱、主鍵和屬性，寫入一行數據。返回本次操作消耗的CapacityUnit。
/// </summary>
/// <param name="request">插入數據的請求</param>
/// <returns>本次操作消耗的CapacityUnit</returns>
public PutRowResponse PutRow(PutRowRequest request);

/// <summary>
/// PutRow的異步形式。
/// </summary>
public Task<PutRowResponse> PutRowAsync(PutRowRequest request);

參數

參數	說明
tableName	數據表名稱。
primaryKey	行的主鍵。主鍵包括主鍵列名、主鍵類型和主鍵值。重要設置的主鍵個數和類型必須和數據表的主鍵個數和類型一致。當主鍵為自增列時，只需將自增列的值設置為占位符。更多信息，請參見主鍵列自增。
attribute	行的屬性列。每一項的順序是屬性名、屬性類型（可選）、屬性值、時間戳（可選）。屬性名即屬性列的名稱，屬性類型即屬性列的數據類型。更多信息，請參見命名規則和數據類型。屬性類型可以是INTEGER、STRING（UTF-8編碼字符串）、BINARY、BOOLEAN和DOUBLE五種。時間戳即數據的版本號，可以由系統自動生成或者自定義，如果不設置此參數，則默認由系統自動生成。更多信息，請參見數據版本和生命周期。當由系統自動生成數據的版本號時，系統默認將當前時間的毫秒單位時間戳（從`1970-01-01 00:00:00` UTC計算起的毫秒數）作為數據的版本號。當自定義數據的版本號時，版本號需要為64位的毫秒單位時間戳且在有效版本范圍內。
condition	使用條件更新，可以設置原行的存在性條件或者原行中某列的列值條件。更多信息，請參見條件更新。說明從.NET SDK 2.2.0版本開始Condition不僅支持行條件，也支持列條件。 `Condition.IGNORE`、`Condition.EXPECT_EXIST`和`Condition.EXPECT_NOT_EXIST`從.NET SDK 3.0.0版本開始被廢棄，請替換為`new Condition (RowExistenceExpectation.IGNORE)`、`new Condition (RowExistenceExpectation.EXPECT_EXIST)`和`new Condition (RowExistenceExpectation.EXPECT_NOT_EXIST)`。 `RowExistenceExpectation.IGNORE`表示無論此行是否存在均會插入新數據，如果之前行已存在，則寫入數據時會覆蓋原有數據。 `RowExistenceExpectation.EXPECT_EXIST`表示只有此行存在時才會插入新數據，寫入數據時會覆蓋原有數據。 `RowExistenceExpectation.EXPECT_NOT_EXIST`表示只有此行不存在時才會插入數據。

示例

插入一行數據

以下示例用于插入一行數據。

//定義行的主鍵，必須與創建表時的TableMeta中定義的一致。
var primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

//定義要寫入該行的屬性列。
var attribute = new AttributeColumns();
attribute.Add("col0", new ColumnValue(0));
attribute.Add("col1", new ColumnValue("a"));
attribute.Add("col2", new ColumnValue(true));

try
{
    //構造插入數據的請求對象，RowExistenceExpectation.IGNORE表示無論此行是否存在均會插入新數據。
    var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                            primaryKey, attribute);

    //調用PutRow接口插入數據。
    otsClient.PutRow(request);

    //如果沒有拋出異常，則說明執行成功。
    Console.WriteLine("Put row succeeded.");
}
catch (Exception ex)
{
    //如果拋出異常，則說明執行失敗，處理異常。
    Console.WriteLine("Put row failed, exception:{0}", ex.Message);
}

詳細代碼請參見PutRow@GitHub。

插入數據時使用列條件和行條件

以下示例用于當行存在且col0大于24時才執行插入操作。

//定義行的主鍵，必須與創建表時的TableMeta中定義的一致。
var primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

//定義要寫入該行的屬性列。
AttributeColumns attribute = new AttributeColumns();
attribute.Add("col0", new ColumnValue(0));
attribute.Add("col1", new ColumnValue("a"));
attribute.Add("col2", new ColumnValue(true));

//當col0列的值大于24時，允許再次插入行，覆蓋掉原值。
try
{
    var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.EXPECT_EXIST),
                            primaryKey, attribute);
    request.Condition.ColumnCondition = new RelationalCondition("col0",
                                        CompareOperator.GREATER_THAN,
                                        new ColumnValue(24));
    otsClient.PutRow(request);

    Console.WriteLine("Put row succeeded.");
}
catch (Exception ex)
{
    Console.WriteLine("Put row failed. error:{0}", ex.Message);
}

詳細代碼請參見ConditionPutRow@GitHub。

異步插入數據

以下示例用于異步插入多行數據。

重要

每一個異步調用都會啟動一個線程，如果連續啟動了很多異步調用，且每個都耗時比較大時，可能會出現超時。

try
{
    var putRowTaskList = new List<Task<PutRowResponse>>();
    for (int i = 0; i < 100; i++)
    {
        //定義行的主鍵，必須與創建表時的TableMeta中定義的一致。
        var primaryKey = new PrimaryKey();
        primaryKey.Add("pk0", new ColumnValue(i));
        primaryKey.Add("pk1", new ColumnValue("abc"));

        //定義要寫入該行的屬性列。
        var attribute = new AttributeColumns();
        attribute.Add("col0", new ColumnValue(i));
        attribute.Add("col1", new ColumnValue("a"));
        attribute.Add("col2", new ColumnValue(true));

        var request = new PutRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                                        primaryKey, attribute);

        putRowTaskList.Add(otsClient.PutRowAsync(request));
    }

    //等待每個異步調用返回，并打印出消耗的CU值。
    foreach (var task in putRowTaskList)
    {
        task.Wait();
        Console.WriteLine("consumed read:{0}, write:{1}", task.Result.ConsumedCapacityUnit.Read,
                            task.Result.ConsumedCapacityUnit.Write);
    }

    //如果沒有拋出異常，則說明執行成功。
    Console.WriteLine("Put row async succeeded.");
}
catch (Exception ex)
{
    //如果拋出異常，則說明執行失敗，處理異常。
    Console.WriteLine("Put row async failed. exception:{0}", ex.Message);
}

詳細代碼請參見PutRowAsync@GitHub。

更新單行數據

調用UpdateRow接口更新一行數據，可以增加和刪除一行中的屬性列，刪除屬性列指定版本的數據，或者更新已存在的屬性列的值。如果更新的行不存在，則新增一行數據。

說明

當UpdateRow請求中只包含刪除指定的列且該行不存在時，則該請求不會新增一行數據。

接口

/// <summary>
/// 更新指定行的數據，如果該行不存在，則新增一行；若該行存在，則根據請求的內容在該行中新增、修改或者刪除指定列的值。
/// </summary>
/// <param name="request">請求實例</param>
public UpdateRowResponse UpdateRow(UpdateRowRequest request);

/// <summary>
/// UpdateRow的異步形式。
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public Task<UpdateRowResponse> UpdateRowAsync(UpdateRowRequest request);

參數

參數	說明
tableName	數據表名稱。
primaryKey	行的主鍵。主鍵包括主鍵列名、主鍵類型和主鍵值。重要設置的主鍵個數和類型必須和數據表的主鍵個數和類型一致。
condition	使用條件更新，可以設置原行的存在性條件或者原行中某列的列值條件。更多信息，請參見條件更新。
attribute	更新的屬性列。增加或更新數據時，需要設置屬性名、屬性值、屬性類型（可選）、時間戳（可選）。屬性名即屬性列的名稱，屬性類型即屬性列的數據類型。更多信息，請參見命名規則和數據類型。時間戳即數據的版本號，可以由系統自動生成或者自定義，如果不設置此參數，則默認由系統自動生成。更多信息，請參見數據版本和生命周期。當由系統自動生成數據的版本號時，系統默認將當前時間的毫秒單位時間戳（從1970-01-01 00:00:00 UTC計算起的毫秒數）作為數據的版本號。當自定義數據的版本號時，版本號需要為64位的毫秒單位時間戳且在有效版本范圍內。刪除屬性列特定版本的數據時，只需要設置屬性名和時間戳。時間戳是64位整數，單位為毫秒，表示某個特定版本的數據。刪除屬性列時，只需要設置屬性名。說明刪除一行的全部屬性列不等同于刪除該行，如果需要刪除該行，請使用DeleteRow操作。

示例

以下示例用于更新一行數據。

//定義行的主鍵，必須與創建表時的TableMeta中定義的一致。
PrimaryKey primaryKey = new PrimaryKey();
primaryKey.Add("pk0", new ColumnValue(0));
primaryKey.Add("pk1", new ColumnValue("abc"));

//定義要寫入該行的屬性列。
UpdateOfAttribute attribute = new UpdateOfAttribute();
attribute.AddAttributeColumnToPut("col0", new ColumnValue(0));
attribute.AddAttributeColumnToPut("col1", new ColumnValue("b")); // 將原先的值'a'改為'b'
attribute.AddAttributeColumnToPut("col2", new ColumnValue(true));

try
{
    //構造更新行的請求對象，RowExistenceExpectation.IGNORE表示無論此行是否存在都執行更新。
    var request = new UpdateRowRequest("SampleTable", new Condition(RowExistenceExpectation.IGNORE),
                                primaryKey, attribute);
    //調用UpdateRow接口更新數據。
    otsClient.UpdateRow(request);

    //如果沒有拋出異常，則說明執行成功。
    Console.WriteLine("Update row succeeded.");
}
catch (Exception ex)
{
    //如果拋出異常，則說明執行失敗，處理異常。
    Console.WriteLine("Update row failed, exception:{0}", ex.Message);
}

詳細代碼請參見UpdateRow@GitHub。

批量寫入數據

調用BatchWriteRow接口在一次請求中進行批量寫入操作或者一次對多張表進行寫入。

BatchWriteRow操作由多個PutRow、UpdateRow、DeleteRow子操作組成，構造子操作的過程與使用PutRow接口、UpdateRow接口和DeleteRow接口時相同。

BatchWriteRow的各個子操作獨立執行，表格存儲會分別返回各個子操作的執行結果。

注意事項

由于批量寫入可能存在部分行失敗的情況，失敗行的Index及錯誤信息在返回的BatchWriteRowResponse中，但并不拋出異常。因此調用BatchWriteRow接口時，需要檢查返回值，可通過BatchWriteRowResponse的isAllSucceed方法判斷是否全部成功；如果不檢查返回值，則可能會忽略掉部分操作的失敗。
當服務端檢查到某些操作出現參數錯誤時，BatchWriteRow接口可能會拋出參數錯誤的異常，此時該請求中所有的操作都未執行。

接口

/// <summary>
/// <para>批量插入，修改或刪除一個或多個表中的若干行數據。</para>
/// <para>BatchWriteRow操作可視為多個PutRow、UpdateRow、DeleteRow操作的集合，各個操作獨立執行，獨立返回結果，獨立計算服務能力單元。</para>
/// <para>與執行大量的單行寫操作相比，使用BatchWriteRow操作可以有效減少請求的響應時間，提高數據的寫入速率。</para>
/// </summary>
/// <param name="request">請求實例</param>
/// <returns>響應實例</returns>
public BatchWriteRowResponse BatchWriteRow(BatchWriteRowRequest request);

/// <summary>
/// BatchWriteRow的異步形式。
/// </summary>
/// <param name="request"></param>
/// <returns></returns>
public Task<BatchWriteRowResponse> BatchWriteRowAsync(BatchWriteRowRequest request);

示例

以下示例用于批量寫入100行數據。

var TableName = "SampleTable";
//構造批量寫的請求對象，設置100行數據的主鍵。
var request = new BatchWriteRowRequest();
var rowChanges = new RowChanges(TableName);
for (int i = 0; i < 100; i++)
{
    PrimaryKey primaryKey = new PrimaryKey();
    primaryKey.Add("pk0", new ColumnValue(i));
    primaryKey.Add("pk1", new ColumnValue("abc"));

    //定義要寫入該行的屬性列。
    UpdateOfAttribute attribute = new UpdateOfAttribute();
    attribute.AddAttributeColumnToPut("col0", new ColumnValue(0));
    attribute.AddAttributeColumnToPut("col1", new ColumnValue("a"));
    attribute.AddAttributeColumnToPut("col2", new ColumnValue(true));

    rowChanges.AddUpdate(new Condition(RowExistenceExpectation.IGNORE), primaryKey, attribute);
}

request.Add(TableName, rowChanges);

try
{
    //調用BatchWriteRow接口寫入數據。
    var response = otsClient.BatchWriteRow(request);
    var tableRows = response.TableRespones;
    var rows = tableRows[TableName];

    //批量操作可能部分成功部分失敗，需要檢查每行的狀態是否成功，詳見示例代碼的GitHub鏈接。
}
catch (Exception ex)
{
    //如果拋出異常，則說明執行失敗，處理異常。
    Console.WriteLine("Batch put row failed, exception:{0}", ex.Message);
}

詳細代碼請參見BatchWriteRow@GitHub。

日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

寫入數據