Tablestore：主鍵列自增

注意事項

寫入資料到帶有自增主鍵列的表時，請務必返回並記錄自增列的值，用於後續資料更新或者資料讀取。

前提條件

已初始化Client。具體操作，請參見初始化OTSClient。

使用方法

1. 建立表時，將非分區鍵的主鍵列設定為自增列。

   只有整型的主鍵列才能設定為自增列，系統自動產生的自增列值為64位的有符號長整型。

2. 寫入資料時，無需為自增列設定具體值，只需將自增列的值設定為預留位置。

   如果需要擷取寫入資料後系統自動產生的自增列的值，將ReturnType設定為RT_PK，可以在資料寫入成功後返回自增列的值。

   讀取資料時，需要完整的主索引值。通過設定PutRow、UpdateRow或者BatchWriteRow中的ReturnType為RT_PK可以擷取完整的主索引值。

   讀取資料時，如果已記錄完整主鍵，您可以使用讀取單行資料或者批量讀取資料方式讀取資料；如果未記錄自增主鍵列的值，您可以使用範圍讀取資料方式按照第一個主鍵列確定範圍讀取資料。

   說明

   要更新已存在的行資料時，如果未記錄自增主鍵列的值，請先通過GetRange介面擷取要更新的行主鍵資訊，然後再進行資料更新。

樣本

以下樣本用於建立資料表時配置主鍵自增列。該表的主鍵為Pk1（String類型）、Pk2_AutoIncrement（Integer類型），其中Pk1主鍵列為分區鍵，Pk2_AutoIncrement主鍵列為自增列。

using System;
using System.Collections.Generic;
using Aliyun.OTS.DataModel;
using Aliyun.OTS.Request;
using Aliyun.OTS.Response;

namespace Aliyun.OTS.Samples.Samples
{
    /// <summary>
    /// 主鍵列自增樣本。
    /// </summary>
    public class AutoIncrementSample
    {
        private static readonly string TableName = "AutoIncrementSample";

        private static readonly string Pk1 = "Pk1";
        private static readonly string Pk2 = "Pk2_AutoIncrement";


        static void Main(string[] args)
        {
            Console.WriteLine("AutoIncrementSample");

            //建立一個帶自增列的表。
            CreateTableWithAutoIncrementPk();

            //寫入10行資料。
            for (int i = 0; i < 10; i++)
            {  
                PutRow(i.ToString());
            }

            Console.ReadLine();

        }

        /// <summary>
        /// 建立一個帶自增列的表。
        /// </summary>
        private static void CreateTableWithAutoIncrementPk()
        {

            OTSClient otsClient = Config.GetClient();

            IList<string> tables = otsClient.ListTable(new ListTableRequest()).TableNames;
            if (tables.Contains(TableName))
            {
                return;
            }

            PrimaryKeySchema primaryKeySchema = new PrimaryKeySchema
            {
                { Pk1, ColumnValueType.String },
                //指定Pk2為自增主鍵。
                { Pk2, ColumnValueType.Integer, PrimaryKeyOption.AUTO_INCREMENT}
            };
            TableMeta tableMeta = new TableMeta(TableName, primaryKeySchema);

            CapacityUnit reservedThroughput = new CapacityUnit(0, 0);
            CreateTableRequest request = new CreateTableRequest(tableMeta, reservedThroughput);
            otsClient.CreateTable(request);

        }

        public static void PutRow(string pk1Value)
        {
            Console.WriteLine("Start put row...");
            OTSClient otsClient = Config.GetClient();

            //定義行的主鍵，必須與建立表時的TableMeta中定義的一致。
            PrimaryKey primaryKey = new PrimaryKey
            {
                { Pk1, new ColumnValue(pk1Value) },
                { Pk2,  ColumnValue.AUTO_INCREMENT }
            };

            //定義要寫入該行的屬性列。
            AttributeColumns attribute = new AttributeColumns
            {
                { "Col1", new ColumnValue(0) }
            };
            PutRowRequest request = new PutRowRequest(TableName, new Condition(RowExistenceExpectation.IGNORE), primaryKey, attribute);
            request.RowPutChange.ReturnType = ReturnType.RT_PK;

            var response =  otsClient.PutRow(request);
            Console.WriteLine("Put row succeed，autoIncrement Pk value:"+ response.Row.GetPrimaryKey()[Pk2].IntegerValue);
        }

    }
}