Tablestore：Tipe JSON

Perbedaan utama

Kedua tipe JSON tersebut memiliki perbedaan signifikan dalam metode pemrosesan data, sintaks kueri, hubungan bidang, dan karakteristik performa:

• Metode pemrosesan data: Object type menyimpan data bersarang dalam struktur datar. Nested type menyimpan setiap objek bersarang sebagai dokumen terpisah.

• Metode kueri: Object type menggunakan kueri dasar. Nested type harus menggunakan NestedQuery.

• Hubungan bidang: Object type memungkinkan pencocokan silang antar bidang dari objek bersarang yang berbeda. Nested type memastikan bahwa bidang dicocokkan secara independen dalam setiap objek bersarang.

• Performa: Kueri tipe Object ringan, efisien, dan mengonsumsi sedikit resource. Kueri tipe Nested kuat tetapi mengonsumsi lebih banyak resource.

Prinsip pemilihan

Pilih Nested type jika kueri Anda harus secara ketat mempertahankan hubungan dan akurasi bidang dalam objek bersarang. Pilih Object type jika Anda memerlukan performa kueri tinggi dan tidak memiliki persyaratan ketat terhadap hubungan bidang.

Langkah 1: Pilih tipe JSON dan format data

Pilih tipe JSON dan format data yang paling sesuai berdasarkan kebutuhan kueri spesifik, persyaratan performa, dan struktur data Anda.

// Format array
[{ "country": "China", "city": "hangzhou" }, { "country": "usa", "city": "Seattle" }]

// Format non-array
{ "country": "China", "city": "hangzhou" }

private static void putRow(SyncClient client) {
    // Konstruksi primary key.
    PrimaryKeyBuilder primaryKeyBuilder = PrimaryKeyBuilder.createPrimaryKeyBuilder();
    primaryKeyBuilder.addPrimaryKeyColumn("id", PrimaryKeyValue.fromString("10001"));
    PrimaryKey primaryKey = primaryKeyBuilder.build();

    // Tetapkan nama tabel data.
    RowPutChange rowPutChange = new RowPutChange("<TABLE_NAME>", primaryKey);

    // Bangun data JSON mentah.
    List<Map<String, Object>> addresses = Arrays.asList(
    new HashMap<String, Object>() {{ put("country", "China"); put("city", "hangzhou"); }},
    new HashMap<String, Object>() {{ put("country", "usa");   put("city", "Seattle"); }}
    );
    String jsonString = JSON.toJSONString(addresses); 

    rowPutChange.addColumn(new Column("address", ColumnValue.fromString(jsonString)));

    client.putRow(new PutRowRequest(rowPutChange));
}

Langkah 2: Konfigurasi struktur bidang dan buat indeks

Contoh ini menunjukkan proses konfigurasi indeks lengkap untuk objek JSON tingkat tunggal dengan dua sub-bidang. Menentukan tipe bidang dan mengatur properti dengan benar memastikan integritas indeks dan mengoptimalkan performa kueri.

List<FieldSchema> subFieldSchemas = new ArrayList<FieldSchema>();
subFieldSchemas.add(new FieldSchema("country", FieldType.KEYWORD)
    .setIndex(true).setEnableSortAndAgg(true));
subFieldSchemas.add(new FieldSchema("city", FieldType.KEYWORD)
    .setIndex(true).setEnableSortAndAgg(true));

FieldSchema jsonFieldSchema = new FieldSchema("address", FieldType.Json)
    .setJsonType(JsonType.OBJECT) // Setel ke JsonType.OBJECT atau JsonType.NESTED
    .setSubFieldSchemas(subFieldSchemas);

Langkah 3: Kueri data

Anda dapat menguji kueri untuk memverifikasi konfigurasi indeks. Bandingkan perilaku dan hasil kueri untuk tipe JSON Object dan Nested menggunakan data dan kondisi kueri yang sama.

• Object type: Meratakan data bersarang. Untuk melakukan kueri, gunakan path yang menghubungkan nama bidang induk dan anak dengan titik (.). Struktur datar ini memungkinkan nilai bidang dari objek bersarang berbeda untuk dicocokkan silang.

• Nested type: Mempertahankan independensi dan integritas setiap objek bersarang. Anda harus membungkus kondisi kueri dalam NestedQuery. Ini memastikan bahwa bidang hanya dicocokkan dalam objek bersarang yang sama.

public static void nestedQuery(SyncClient client) {
    // Kondisi 1: Nilai bidang country dalam sub-baris address harus "China".
    TermQuery termQuery1 = new TermQuery();
    termQuery1.setFieldName("address.country");
    termQuery1.setTerm(ColumnValue.fromString("China"));

    // Kondisi 2: Nilai bidang city dalam sub-baris address harus "Seattle".
    TermQuery termQuery2 = new TermQuery();
    termQuery2.setFieldName("address.city");
    termQuery2.setTerm(ColumnValue.fromString("Seattle"));

    // Gunakan kondisi AND dari BoolQuery untuk mencari sub-baris yang memenuhi kedua kondisi.
    List<Query> mustQueries = new ArrayList<>();
    mustQueries.add(termQuery1);
    mustQueries.add(termQuery2);
    BoolQuery boolQuery = new BoolQuery();
    boolQuery.setMustQueries(mustQueries);

    // Tetapkan BoolQuery dalam NestedQuery agar sub-baris memenuhi beberapa kondisi kueri sekaligus.
    NestedQuery nestedQuery = new NestedQuery();    // Tetapkan tipe kueri ke NestedQuery.
    nestedQuery.setPath("address");   // Tetapkan path kolom tipe nested, yaitu path induk dari bidang yang akan dikueri.
    nestedQuery.setQuery(boolQuery);
    nestedQuery.setScoreMode(ScoreMode.None);

    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(nestedQuery);

    SearchRequest searchRequest = new SearchRequest("<TABLE_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);

    SearchResponse resp = client.search(searchRequest);
    System.out.println("Row: " + resp.getRows());
}

public static void boolQuery(SyncClient client) {
    // Kondisi 1: Nilai bidang country dalam sub-baris address harus "China".
    TermQuery termQuery1 = new TermQuery();
    termQuery1.setFieldName("address.country");
    termQuery1.setTerm(ColumnValue.fromString("China"));

    // Kondisi 2: Nilai bidang city dalam sub-baris address harus "Seattle".
    TermQuery termQuery2 = new TermQuery();
    termQuery2.setFieldName("address.city");
    termQuery2.setTerm(ColumnValue.fromString("Seattle"));

    // Gunakan kondisi AND dari BoolQuery untuk mencari sub-baris yang memenuhi kedua kondisi.
    List<Query> mustQueries = new ArrayList<>();
    mustQueries.add(termQuery1);
    mustQueries.add(termQuery2);
    BoolQuery boolQuery = new BoolQuery();
    boolQuery.setMustQueries(mustQueries);


    SearchQuery searchQuery = new SearchQuery();
    searchQuery.setQuery(boolQuery);

    SearchRequest searchRequest = new SearchRequest("<TABLE_NAME>", "<SEARCH_INDEX_NAME>", searchQuery);

    SearchResponse resp = client.search(searchRequest);
    System.out.println("Row: " + resp.getRows());
}

Contoh JSON tingkat tunggal

Contoh kode Java ini membuat bidang JSON tingkat tunggal bernama tags. Anda dapat menyetel tipe JSON sesuai kebutuhan. Bidang ini mencakup tiga sub-bidang berikut:

• tagName: Tipe Keyword (string) untuk pencocokan eksak dan agregasi nama tag.

• score: Tipe Double (bilangan titik mengambang) untuk perhitungan numerik dan pengurutan berdasarkan bobot tag.

• time: Tipe Date yang menggunakan format stempel waktu UNIX milidetik. Digunakan untuk kueri rentang waktu dan analisis deret waktu.

Data dapat ditulis dalam format array atau non-array. Pilih format yang sesuai dengan struktur data Anda:

// Format array
[{"tagName":"tag1", "score":0.8,"time": 1730690237000 }, {"tagName":"tag2", "score":0.2,"time": 1730691557000}]
// Format non-array
{"tagName":"tag1", "score":0.8,"time": 1730690237000 }

Kode konfigurasi skema lengkap adalah sebagai berikut:

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")));

FieldSchema nestedFieldSchema = new FieldSchema("tags", FieldType.Json)
    .setJsonType(JsonType.OBJECT) // Ganti dengan JsonType.NESTED sesuai kebutuhan
    .setSubFieldSchemas(subFieldSchemas);

Contoh JSON multi-level

Contoh kode Java ini membuat bidang JSON multi-level bernama user. Anda dapat menyetel `JsonType` sesuai kebutuhan. Bidang ini membangun struktur data lengkap yang berisi informasi pengguna dasar dan informasi alamat bersarang. Anda dapat menggunakan kombinasi tipe Nested dan Object dalam struktur JSON multi-level.

• Bidang dasar: `name` (tipe Keyword untuk kueri nama eksak), `age` (tipe Long untuk filter rentang usia), `birth` (tipe Date dalam format `yyyy-MM-dd HH:mm:ss.SSS` untuk kueri tanggal lahir), dan `phone` (tipe Keyword untuk pencocokan informasi kontak).

• Bidang bersarang: address (Anda dapat menyetel `JsonType` sesuai kebutuhan). Berisi tiga bidang tingkat alamat: province, city, dan street. Semuanya bertipe Keyword yang mendukung kueri hierarkis untuk lokasi geografis.

Berikut adalah contoh khas penulisan data pengguna:

{
  "name": "Zhang San",
  "age": 20,
  "birth": "2014-10-10 12:00:00.000",
  "phone": "1390000****",
  "address": {
    "province": "Zhejiang Province",
    "city": "Hangzhou City",
    "street": "No. 1201, Xingfu Community, Yangguang Avenue"
  }
}

Konfigurasi skema lengkap untuk JSON multi-level adalah sebagai berikut:

// Skema untuk sub-bidang address (path: user.address)
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));

// Skema untuk sub-bidang user (path: user)
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.JSON)
    .setJsonType(JsonType.NESTED) // Ganti dengan JsonType.OBJECT sesuai kebutuhan
    .setSubFieldSchemas(addressSubFiledSchemas));

// Buat bidang induk user
List<FieldSchema> fieldSchemas = new ArrayList<>();
fieldSchemas.add(new FieldSchema("user",FieldType.JSON)
    .setJsonType(JsonType.OBJECT) // Ganti dengan JsonType.NESTED sesuai kebutuhan
    .setSubFieldSchemas(subFieldSchemas));