DataWorks：Sumber data GBase 8a

Batasan

• GBase 8a Reader dan GBase 8a Writer hanya mendukung kelompok sumber daya eksklusif untuk Data Integration.

• INSERT INTO: Jika terjadi konflik kunci utama atau indeks unik, data tidak dapat ditulis ke baris yang bertentangan.

• Data hanya dapat ditulis ke tabel yang disimpan di database utama.

  Catatan

  Tugas sinkronisasi yang menggunakan GBase 8a Writer harus memiliki setidaknya izin untuk menjalankan INSERT INTO. Kebutuhan izin tambahan bergantung pada pernyataan SQL yang ditentukan dalam parameter preSql dan postSql saat Anda mengonfigurasi tugas tersebut.

• GBase 8a Writer tidak mendukung parameter writeMode.

Mengembangkan tugas sinkronisasi data

Untuk informasi tentang titik masuk dan prosedur mengonfigurasi tugas sinkronisasi data, lihat bagian berikut. Untuk detail pengaturan parameter, lihat tip info setiap parameter pada tab konfigurasi tugas.

Menambahkan sumber data

Mengonfigurasi tugas sinkronisasi batch untuk menyinkronkan data tabel tunggal

• Untuk informasi lebih lanjut tentang prosedur konfigurasi, lihat Mengonfigurasi Tugas Sinkronisasi Batch Menggunakan Antarmuka Tanpa Kode dan Mengonfigurasi Tugas Sinkronisasi Batch Menggunakan Editor Kode.

• Untuk informasi tentang semua parameter yang dikonfigurasi dan kode yang dijalankan saat menggunakan editor kode untuk mengonfigurasi tugas sinkronisasi batch, lihat Lampiran: Kode dan Parameter.

Lampiran: Kode dan parameter

Lampiran: Mengonfigurasi tugas sinkronisasi batch menggunakan editor kode

Kode untuk GBase 8a Reader

{
    "type": "job",
    "steps": [
        {
            "stepType": "gbase8a", // Nama plugin. 
            "parameter": {
                "datasource": "", // Nama sumber data. 
                "username": "",
                "password": "",
                "where": "",
                "column": [ // Nama kolom. 
                    "id",
                    "name"
                ],
                "splitPk": "id",
                "connection": [
                    {
                        "table": [ // Nama tabel. 
                            "table"
                        ],
                        "datasource":""
                    }
                ]
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "stream",
            "parameter": {
                "print": false,
                "fieldDelimiter": ","
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "version": "2.0",
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    },
    "setting": {
        "errorLimit": {
            "record": "0" // Jumlah maksimum catatan data kotor yang diizinkan. 
        },
        "speed": {
            "throttle": true, // Menentukan apakah akan mengaktifkan pembatasan kecepatan. Nilai false menunjukkan bahwa pembatasan dinonaktifkan, dan nilai true menunjukkan bahwa pembatasan diaktifkan. Parameter mbps hanya berlaku jika parameter throttle diatur ke true. 
            "concurrent": 1, // Jumlah maksimum thread paralel. 
            "mbps":"12"// Laju transmisi maksimum. Unit: MB/s. 
        }
    }
}

Parameter dalam kode untuk GBase 8a Reader

Kode untuk GBase 8a Writer

{
    "type":"job",
    "version":"2.0",// Nomor versi. 
    "steps":[
        {
            "stepType":"stream",
            "parameter":{},
            "name":"Reader",
            "category":"reader"
        },
        {
            "stepType":"gbase8a",// Nama plugin. 
            "parameter":{
                "datasource": "Nama sumber data",
                "username": "",
                "password": "",
                "column": [// Nama kolom. 
                    "id",
                    "name"
                ],
                "connection": [
                    {
                        "table": [// Nama tabel. 
                            "Gbase8a_table"
                        ],
                        "datasource":""
                    }
                ],
                "preSql": [ // Pernyataan SQL yang ingin Anda jalankan sebelum tugas sinkronisasi dijalankan. 
                    "delete from @table where db_id = -1"
                ],
                "postSql": [// Pernyataan SQL yang ingin Anda jalankan setelah tugas sinkronisasi dijalankan. 
                    "update @table set db_modify_time = now() where db_id = 1"
                ]
            },
            "name":"Writer",
            "category":"writer"
        }
    ],
    "setting":{
        "errorLimit":{
            "record":"0"// Jumlah maksimum catatan data kotor yang diizinkan. 
        },
        "speed":{
            "throttle":true,// Menentukan apakah akan mengaktifkan pembatasan kecepatan. Nilai false menunjukkan bahwa pembatasan dinonaktifkan, dan nilai true menunjukkan bahwa pembatasan diaktifkan. Parameter mbps hanya berlaku jika parameter throttle diatur ke true. 
            "concurrent":1, // Jumlah maksimum thread paralel. 
            "mbps":"12"// Laju transmisi maksimum. Unit: MB/s. 
        }
    },
    "order":{
        "hops":[
            {
                "from":"Reader",
                "to":"Writer"
            }
        ]
    }
}

Parameter dalam kode untuk GBase 8a Writer