全部產品
Search
文件中心

Tablestore:主鍵列自增

更新時間:Jun 30, 2024

設定非分區鍵的主鍵列為自增列後,在寫入資料時,無需為自增列設定具體值,Tablestore會自動產生自增列的值。該值在分區鍵層級唯一且嚴格遞增。

前提條件

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

使用方法

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

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

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

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

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

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

    說明

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

樣本

主鍵自增列功能主要涉及建立表(CreateTable)和寫資料(PutRow、UpdateRow和BatchWriteRow)兩類介面。

  1. 建立表

    建立表時,只需將自增的主鍵屬性設定為PK_AUTO_INCR。

    以下樣本用於建立資料表時配置主鍵自增列。該表的主鍵為gid(Integer類型)和uid(Integer類型),其中gid主鍵列為分區鍵,uid主鍵列為自增列。

    table_name = '<TABLE_NAME>'
    def create_table(client):
        # 建立表,表中包括兩個主鍵:gid,INTEGER類型;uid,INTEGER類型,為自增列。
        schema_of_primary_key = [('gid', 'INTEGER'), ('uid', 'INTEGER', PK_AUTO_INCR)]
        table_meta = TableMeta(table_name, schema_of_primary_key)
        table_options = TableOptions()
        reserved_throughput = ReservedThroughput(CapacityUnit(0, 0))
        client.create_table(table_meta, table_options, reserved_throughput)
        print ('Table has been created.')
  2. 寫資料

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

    以下樣本用於向資料表中寫入一行資料,並返回完整主索引值和消耗的預留讀寫輸送量。

    table_name = '<TABLE_NAME>'
    def put_row(client):
        # 設定主鍵資訊:gid為1,uid為自增列。uid列必須設定,否則報錯。
        primary_key = [('gid',1), ('uid', PK_AUTO_INCR)]
        # 設定屬性列。
        attribute_columns = [('name','John'), ('mobile',1390000****), ('address','China'), ('age',20)]
        row = Row(primary_key, attribute_columns)
    
        # 寫入資料,返回消耗的CU但是不返回主鍵資訊。
        #consumed, return_row = client.put_row(table_name, row)
        #print ('Write succeed, consume %s write cu.' % consumed.write)
        
        # 寫入資料,返回消耗的CU和主鍵資訊。
        consumed, return_row = client.put_row(table_name, row, return_type = ReturnType.RT_PK)
        print ('Write succeed, consume %s write cu.' % consumed.write)
        print ('Primary key:%s' % return_row.primary_key)