Tablestore:Gunakan indeks sekunder untuk membaca data

Prasyarat

Sebelum memulai, pastikan Anda telah:

• Memiliki instans OTSClient yang telah diinisialisasi. Untuk informasi selengkapnya, lihat Initialize a Tablestore client.

• Membuat indeks sekunder. Untuk informasi selengkapnya, lihat Create a secondary index.

Catatan penggunaan

• Tabel indeks hanya dapat digunakan untuk membaca data.

• Kolom kunci primer pertama pada tabel indeks sekunder lokal harus sama dengan kolom kunci primer pertama pada tabel data.

• Jika kolom atribut yang akan dikembalikan tidak termasuk dalam tabel indeks, Anda harus mengkueri tabel data untuk mengambil data tersebut.

Parameter

Saat memanggil GetRow pada tabel indeks, atur parameter berikut:

Contoh

Contoh berikut membaca satu baris dari tabel indeks dengan menentukan kunci primernya secara lengkap. Kunci primer terdiri dari kolom indeks definedcol1 diikuti oleh kolom kunci primer tabel data pk1 dan pk2.

func GetRowFromIndex(client *tablestore.TableStoreClient, indexName string) {
    getRowRequest := new(tablestore.GetRowRequest)
    criteria := new(tablestore.SingleRowQueryCriteria)
    // Construct the primary key.
    // For an LSI, the first primary key column must match the first primary key column of the data table.
    putPk := new(tablestore.PrimaryKey)
    putPk.AddPrimaryKeyColumn("definedcol1", "value1")
    putPk.AddPrimaryKeyColumn("pk1", int64(2))
    putPk.AddPrimaryKeyColumn("pk2", []byte("pk2"))
    criteria.PrimaryKey = putPk

    getRowRequest.SingleRowQueryCriteria = criteria
    getRowRequest.SingleRowQueryCriteria.TableName = indexName
    getRowRequest.SingleRowQueryCriteria.MaxVersion = 1
    getResp, err := client.GetRow(getRowRequest)
    if err != nil {
        fmt.Println("getrow failed with error:", err)
    } else {
        fmt.Println("get row", getResp.Columns[0].ColumnName, "result is", getResp.Columns[0].Value)
    }
}

TableName diatur ke nama tabel indeks. Kunci primer mengikuti urutan kolom tabel indeks: kolom indeks terlebih dahulu (definedcol1), lalu kolom kunci primer tabel data (pk1, pk2). MaxVersion = 1 hanya mengembalikan versi terbaru dari setiap kolom atribut.

Baca data dalam rentang kunci primer

Gunakan operasi GetRange untuk membaca baris-baris yang nilai kunci primernya berada dalam rentang tertentu. Untuk detail parameter, lihat Read a range of data.

func GetRangeFromGlobalIndex(client *tablestore.TableStoreClient, indexName string) {
    getRangeRequest := &tablestore.GetRangeRequest{}
    rangeRowQueryCriteria := &tablestore.RangeRowQueryCriteria{}
    rangeRowQueryCriteria.TableName = indexName

    // Construct the start primary key. The range is a left-closed, right-open interval.
    startPK := new(tablestore.PrimaryKey)
    // GSI primary key order: index column first, then data table primary key columns.
    startPK.AddPrimaryKeyColumn("definedcol1", "value1")
    startPK.AddPrimaryKeyColumnWithMinValue("pk1")
    startPK.AddPrimaryKeyColumnWithMinValue("pk2")

    endPK := new(tablestore.PrimaryKey)
    endPK.AddPrimaryKeyColumn("definedcol1", "value1")
    endPK.AddPrimaryKeyColumnWithMaxValue("pk1")
    endPK.AddPrimaryKeyColumnWithMaxValue("pk2")
    rangeRowQueryCriteria.StartPrimaryKey = startPK
    rangeRowQueryCriteria.EndPrimaryKey = endPK
    rangeRowQueryCriteria.Direction = tablestore.FORWARD
    rangeRowQueryCriteria.MaxVersion = 1
    rangeRowQueryCriteria.Limit = 10
    getRangeRequest.RangeRowQueryCriteria = rangeRowQueryCriteria

    getRangeResp, err := client.GetRange(getRangeRequest)

    fmt.Println("get range result is ", getRangeResp)

    for {
        if err != nil {
            fmt.Println("get range failed with error:", err)
        }
        if len(getRangeResp.Rows) > 0 {
            for _, row := range getRangeResp.Rows {
                fmt.Println("range get row with key", row.PrimaryKey.PrimaryKeys[0].Value, row.PrimaryKey.PrimaryKeys[1].Value, row.PrimaryKey.PrimaryKeys[2].Value)
            }
            if getRangeResp.NextStartPrimaryKey == nil {
                break
            } else {
                fmt.Println("next pk is :", getRangeResp.NextStartPrimaryKey.PrimaryKeys[0].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[1].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[2].Value)
                getRangeRequest.RangeRowQueryCriteria.StartPrimaryKey = getRangeResp.NextStartPrimaryKey
                getRangeResp, err = client.GetRange(getRangeRequest)
            }
        } else {
            break
        }

        fmt.Println("continue to query rows")
    }
    fmt.Println("getrow finished")
}

func GetRangeFromLocalIndex(client *tablestore.TableStoreClient, indexName string) {
    getRangeRequest := &tablestore.GetRangeRequest{}
    rangeRowQueryCriteria := &tablestore.RangeRowQueryCriteria{}
    rangeRowQueryCriteria.TableName = indexName

    // Construct the start primary key. The range is a left-closed, right-open interval.
    startPK := new(tablestore.PrimaryKey)
    // LSI primary key order: data table's first PK column, then index column, then remaining PK columns.
    startPK.AddPrimaryKeyColumnWithMinValue("pk1")
    startPK.AddPrimaryKeyColumnWithMinValue("definedcol1")
    startPK.AddPrimaryKeyColumnWithMinValue("pk2")

    // Construct the end primary key.
    endPK := new(tablestore.PrimaryKey)
    endPK.AddPrimaryKeyColumnWithMaxValue("pk1")
    endPK.AddPrimaryKeyColumnWithMaxValue("definedcol1")
    endPK.AddPrimaryKeyColumnWithMaxValue("pk2")
    rangeRowQueryCriteria.StartPrimaryKey = startPK
    rangeRowQueryCriteria.EndPrimaryKey = endPK
    rangeRowQueryCriteria.Direction = tablestore.FORWARD
    rangeRowQueryCriteria.MaxVersion = 1
    rangeRowQueryCriteria.Limit = 10
    getRangeRequest.RangeRowQueryCriteria = rangeRowQueryCriteria

    getRangeResp, err := client.GetRange(getRangeRequest)

    fmt.Println("get range result is ", getRangeResp)

    for {
        if err != nil {
            fmt.Println("get range failed with error:", err)
        }
        if len(getRangeResp.Rows) > 0 {
            for _, row := range getRangeResp.Rows {
                fmt.Println("range get row with key", row.PrimaryKey.PrimaryKeys[0].Value, row.PrimaryKey.PrimaryKeys[1].Value, row.PrimaryKey.PrimaryKeys[2].Value)
                // To return attribute columns stored in the index table, uncomment the following line.
                //fmt.Println("get row", row.Columns[0].ColumnName, "result is ", row.Columns[0].Value)
            }
            if getRangeResp.NextStartPrimaryKey == nil {
                break
            } else {
                fmt.Println("next pk is :", getRangeResp.NextStartPrimaryKey.PrimaryKeys[0].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[1].Value, getRangeResp.NextStartPrimaryKey.PrimaryKeys[2].Value)
                getRangeRequest.RangeRowQueryCriteria.StartPrimaryKey = getRangeResp.NextStartPrimaryKey
                getRangeResp, err = client.GetRange(getRangeRequest)
            }
        } else {
            break
        }

        fmt.Println("continue to query rows")
    }
    fmt.Println("getrow finished")
}

FAQ

• Apa yang harus saya lakukan jika muncul pesan error "OTSErrorMsg: Disallow read index table in building base state" saat saya membaca data dari search Index?

• Apa yang harus saya lakukan jika pesan error "Validate PK size fail" dikembalikan saat saya menggunakan Tablestore SDK?

• Apa yang harus saya lakukan jika pesan error "Validate PK name fail" dikembalikan saat saya menggunakan Tablestore SDK?