Tablestore：Tipe data Array dan Nested

Format Array

Tabel berikut menjelaskan kombinasi tipe data Array dan tipe data primitif dalam indeks pencarian.

Catatan penggunaan

Jika tipe data suatu bidang dalam indeks pencarian merupakan kombinasi tipe data Array dan tipe data primitif (misalnya Long atau Double), maka bidang tersebut dalam tabel data tempat indeks pencarian dibuat harus bertipe String, sedangkan bidang dalam indeks pencarian harus bertipe primitif yang sesuai.

Misalnya, jika bidang price bertipe Double Array, maka bidang price dalam tabel data harus bertipe String. Dalam indeks pencarian, bidang yang sesuai harus bertipe Double, dan Anda harus menambahkan properti isArray=true.

Contoh

Asumsikan sebuah tabel data bernama array_search_table. Tabel berikut menunjukkan data sampel.

Tabel data mencakup kolom kunci primer pk dan dua kolom atribut: col_keyword_array dan col_long_array. Semua kolom bertipe String.

1. Buat indeks pencarian.

   Buat indeks pencarian bernama array_query_table_index yang mencakup dua kolom: col_keyword_array bertipe String Array dan col_long_array bertipe Long Array.

   

2. Gunakan indeks pencarian untuk mengkueri data bertipe Array.

   Kode Java berikut menunjukkan cara mengkueri data array. Kondisi kueri menentukan bahwa kolom col_keyword_array berisi elemen yang persis sesuai dengan "Cloud server" dan kolom col_long_array berisi elemen yang sama dengan 2024.

   Catatan

   Anda dapat mengeksekusi Pernyataan SQL untuk mengkueri data bertipe Array dalam indeks pencarian. Untuk informasi selengkapnya, lihat Eksekusi Pernyataan SQL untuk mengkueri data menggunakan indeks pencarian.

   private static void query(SyncClient client) {
       // Kondisi 1: Nilai kolom col_keyword_array berisi elemen yang persis sesuai dengan "Cloud server".
       TermQuery keywordTermQuery = new TermQuery(); // Atur tipe kueri menjadi TermQuery.
       keywordTermQuery.setFieldName("col_keyword_array"); // Tentukan nama kolom yang ingin dicocokkan.
       keywordTermQuery.setTerm(ColumnValue.fromString("Cloud server")); // Tentukan nilai yang digunakan untuk mencocokkan bidang.
       
       // Kondisi 2: Nilai kolom col_long_array berisi elemen yang sama dengan 2024.
       TermQuery longTermQuery = new TermQuery(); // Atur tipe kueri menjadi TermQuery.
       longTermQuery.setFieldName("col_long_array"); // Tentukan nama kolom yang ingin dicocokkan.
       longTermQuery.setTerm(ColumnValue.fromLong(2024l)); // Tentukan nilai yang digunakan untuk mencocokkan bidang.
       
       SearchQuery searchQuery = new SearchQuery();
       // Bangun kueri Boolean di mana hasil kueri memenuhi Kondisi 1 dan Kondisi 2 secara bersamaan.
       BoolQuery boolQuery = new BoolQuery();
       boolQuery.setMustQueries(Arrays.asList(keywordTermQuery, longTermQuery));
       searchQuery.setQuery(boolQuery);
       //searchQuery.setGetTotalCount(true); // Tentukan bahwa jumlah total baris yang cocok dikembalikan.
       
       SearchRequest searchRequest = new SearchRequest("<TABLE_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);
       // Anda dapat mengonfigurasi parameter columnsToGet untuk menentukan kolom yang ingin dikembalikan atau menentukan agar semua kolom dikembalikan. Jika Anda tidak mengonfigurasi parameter ini, hanya kolom kunci primer yang dikembalikan.
       //SearchRequest.ColumnsToGet columnsToGet = new SearchRequest.ColumnsToGet();
       //columnsToGet.setReturnAll(true); // Tentukan agar semua kolom dikembalikan.
       //columnsToGet.setColumns(Arrays.asList("ColName1","ColName2")); // Tentukan kolom yang ingin dikembalikan.
       //searchRequest.setColumnsToGet(columnsToGet);
       
       SearchResponse resp = client.search(searchRequest);
       //System.out.println("TotalCount: " + resp.getTotalCount()); // Tentukan bahwa jumlah total baris yang cocok (bukan jumlah baris yang dikembalikan) ditampilkan.
       System.out.println("Row: " + resp.getRows());
   }

Format Nested

Bidang nested diklasifikasikan menjadi bidang nested tingkat tunggal dan multi-level. Tabel berikut menjelaskan kedua tipe tersebut.

[
    {
        "tagName": "tag1",
        "score": 0.8
    },
    {
        "tagName": "tag2",
        "score": 0.2
    }
]

[
    {
        "name": "Zhang San",
        "age": 20,
        "phone": "1390000****",
        "address": [
            {
                "province": "Zhejiang Province",
                "city": "Hangzhou City",
                "street": "No. 1201, Xingfu Community, Sunshine Avenue"
            }
        ]
    }
]

Contoh

// Buat skema untuk bidang-bidang dalam baris anak.
List<FieldSchema> subFieldSchemas = new ArrayList<FieldSchema>();
subFieldSchemas.add(new FieldSchema("tagName", FieldType.KEYWORD)
    .setIndex(true).setEnableSortAndAgg(true));
subFieldSchemas.add(new FieldSchema("score", FieldType.DOUBLE)
    .setIndex(true).setEnableSortAndAgg(true));
subFieldSchemas.add(new FieldSchema("time", FieldType.DATE)
    .setDateFormats(Arrays.asList("epoch_millis")));

// Gunakan skema yang dibuat untuk baris anak sebagai nilai subfieldSchemas untuk bidang Nested.
FieldSchema nestedFieldSchema = new FieldSchema("tags", FieldType.NESTED)
    .setSubFieldSchemas(subFieldSchemas);

// Buat skema untuk tiga bidang dalam baris anak bidang Nested address. Jalur yang ditentukan oleh user.address dapat digunakan untuk mengkueri data bidang dalam baris anak.
List<FieldSchema> addressSubFiledSchemas = new ArrayList<>();
addressSubFiledSchemas.add(new FieldSchema("province",FieldType.KEYWORD));
addressSubFiledSchemas.add(new FieldSchema("city",FieldType.KEYWORD));
addressSubFiledSchemas.add(new FieldSchema("street",FieldType.KEYWORD));

// Buat skema untuk setiap baris anak bidang Nested user. Setiap baris anak berisi tiga bidang dengan tipe data primitif berbeda dan satu bidang Nested bernama address. Jalur yang ditentukan oleh bidang Nested user dapat digunakan untuk mengkueri data bidang dalam baris anak.
List<FieldSchema> subFieldSchemas = new ArrayList<>();
subFieldSchemas.add(new FieldSchema("name",FieldType.KEYWORD));
subFieldSchemas.add(new FieldSchema("age",FieldType.LONG));
subFieldSchemas.add(new FieldSchema("birth",FieldType.DATE).setDateFormats(Arrays.asList("yyyy-MM-dd HH:mm:ss.SSS")));
subFieldSchemas.add(new FieldSchema("phone",FieldType.KEYWORD));
subFieldSchemas.add(new FieldSchema("address",FieldType.NESTED).setSubFieldSchemas(addressSubFiledSchemas));

// Gunakan skema yang dibuat untuk baris anak bidang Nested user sebagai nilai subfieldSchemas untuk bidang Nested.
List<FieldSchema> fieldSchemas = new ArrayList<>();
fieldSchemas.add(new FieldSchema("user",FieldType.NESTED).setSubFieldSchemas(subFieldSchemas));