Tüm Ürünler
Search
Belge Merkezi

DataWorks:DM (Dameng)

Son Güncelleme:Oct 05, 2026

DataWorks Data Integration, DM (Dameng) veritabanlarını hem kaynak hem de hedef olarak destekleyerek çevrimdışı toplu iş senkronizasyonu gerçekleştirmenize olanak tanır. DM Reader ile DM veritabanlarından veri okuyabilir ve DM Writer ile bu veritabanlarına veri yükleyebilirsiniz.

Yetenekler


Yetenek


DM Reader


DM Writer


Çevrimdışı (toplu iş) senkronizasyon


Evet


Evet


Görünümlerden okuma


Evet


—


Sütun budama


Evet


—


Sütun yeniden sıralama


Evet


—


Paralel okuma (splitPk)


Evet (yalnızca tamsayı sütunlar)


—


Artımlı senkronizasyon (where)


Evet


—


Öncesi SQL çalıştırma


Evet


Evet


Sonrası SQL çalıştırma


—


Evet


Serverless kaynak grupları


Evet


Evet


Data Integration için özel kaynak grupları


Evet


Evet

Desteklenen alan türleri

DM Reader ve DM Writer, çoğu yaygın ilişkisel veritabanı veri türünü destekler. Aşağıdaki tabloda DM Reader'ın dönüştürebildiği DM veri türleri listelenmiştir. Desteklenmeyen türler okuma hatasına neden olur; bu nedenle bir senkronizasyon görevini yapılandırmadan önce şemanızı doğrulayın.


Kategori


DM veri türleri


Tamsayı


INT, TINYINT, SMALLINT, BIGINT


Kayan nokta


REAL, FLOAT, DOUBLE, NUMBER, DECIMAL


Dize


CHAR, VARCHAR, LONGVARCHAR, TEXT


Tarih ve saat


DATE, DATETIME, TIMESTAMP, TIME


Boole


BIT


İkili


BINARY, VARBINARY, BLOB

Senkronizasyon görevi yapılandırma

Tek tablo çevrimdışı senkronizasyon

Görevi kod içermeyen kullanıcı arayüzünü veya kod düzenleyiciyi kullanarak yapılandırabilirsiniz:

Tam komut dosyası referansı ve parametre açıklamaları için bkz. Komut dosyası referansı.

Tüm veritabanı çevrimdışı senkronizasyon

Bkz. Toplu veritabanı senkronizasyonu yapılandırması.

Komut dosyası referansı

Kod düzenleyicide bir toplu iş senkronizasyon görevi yapılandırırken birleşik komut dosyası biçimini kullanın. Aşağıdaki bölümlerde Reader ve Writer için DM'ye özgü parametreler açıklanmıştır.

Reader

Komut dosyası örneği

{
  "type": "job",
  "version": "2.0",
  "order": {
    "hops": [
      { "from": "Reader", "to": "Writer" }
    ]
  },
  "setting": {
    "errorLimit": { "record": "0" },
    "speed": {
      "throttle": true,
      "concurrent": 1,
      "mbps": "12"
    }
  },
  "steps": [
    {
      "category": "reader",
      "name": "Reader",
      "stepType": "dm",
      "parameter": {
        "datasource": "dm_datasource",
        "table": "table",
        "column": ["*"],
        "preSql": ["delete from XXX;"],
        "fetchSize": 2048
      }
    },
    {
      "category": "writer",
      "name": "Writer",
      "stepType": "stream",
      "parameter": {}
    }
  ]
}

Reader parametreleri


Parametre


Gerekli


Varsayılan


Açıklama


datasource


Evet


—


DM veri kaynağının adı. Bkz. DM veri kaynağı yapılandırma.


table


Evet


—


Verilerin okunacağı tablo.


column


Evet


—


JSON dizisi olarak senkronize edilecek sütunlar. Tüm sütunlar için ["*"] kullanın. Sütun budama, sütun yeniden sıralama ve sabit değerler (tamsayı, dize, null, işlev ifadesi, kayan nokta, Boole) desteklenir.


splitPk


Hayır


Boş


Paralel okumalar için verileri bölmek üzere kullanılan sütun. Eşit dağılım sağlamak ve veri yoğun noktalarını önlemek için bunu birincil anahtar olarak ayarlayın. Yalnızca tamsayı sütunlar desteklenir; kayan nokta, dize, tarih ve diğer türler hata verir. Ayarlanmazsa tablo tek kanal üzerinden okunur.


where


Hayır


—


Sorguya eklenen SQL filtre koşulu; örneğin artımlı senkronizasyon için gmt_create>$bizdate veya test amacıyla limit 10 gibi. Ayarlanmazsa tüm satırlar okunur.


querySql


Hayır


—


Özel SQL sorgusu; örneğin select a,b from table_a join table_b on table_a.id = table_b.id gibi. Ayarlandığında column, table ve where parametreleri yoksayılır.


fetchSize


Hayır


1.024


Her toplu işte alınan satır sayısı. Daha yüksek değerler ağ gidiş-dönüşlerini azaltır ve aktarım hızını artırır. 2.048'in üzerindeki değerler bellek yetersizliği (OOM) hatasına neden olabilir.


preSql


Hayır


—


Senkronizasyon görevi başlamadan önce çalıştırılan SQL deyimi. Yalnızca bir deyim desteklenir.

Writer

Komut dosyası örneği

{
  "type": "job",
  "version": "2.0",
  "order": {
    "hops": [
      { "from": "Reader", "to": "Writer" }
    ]
  },
  "setting": {
    "errorLimit": { "record": "" },
    "speed": {
      "throttle": true,
      "concurrent": 2,
      "mbps": "12"
    }
  },
  "steps": [
    {
      "category": "reader",
      "name": "Reader",
      "stepType": "oracle",
      "parameter": {
        "datasource": "aaa",
        "column": ["PROD_ID", "name"],
        "where": "",
        "splitPk": "",
        "encoding": "UTF-8",
        "table": "PENGXI.SALES"
      }
    },
    {
      "category": "writer",
      "name": "Writer",
      "stepType": "dm",
      "parameter": {
        "datasource": "dm_datasource",
        "table": "table",
        "column": ["id", "name"],
        "preSql": ["delete from XXX;"]
      }
    }
  ]
}

Writer parametreleri


Parametre


Gerekli


Varsayılan


Açıklama


datasource


Evet


—


DM veri kaynağının adı. Bkz. DM veri kaynağı yapılandırma.


table


Evet


—


Hedef tablo. Tablonun şeması veri kaynağı yapılandırmasındaki kullanıcı adından farklıysa schema.table biçimini kullanın.


column


Evet


—


Virgülle ayrılmış hedef sütunlar. Varsayılan sütun ayarlarını kullanmayın.


preSql


Hayır


—


Senkronizasyon görevi başlamadan önce çalıştırılan SQL deyimi; örneğin eski verileri temizlemek için. Yalnızca bir deyim desteklenir; birden fazla deyim işlem desteğini devre dışı bırakır.


postSql


Hayır


—


Senkronizasyon görevi tamamlandıktan sonra çalıştırılan SQL deyimi; örneğin zaman damgası eklemek için. Yalnızca bir deyim desteklenir; birden fazla deyim işlem desteğini devre dışı bırakır.


batchSize


Hayır


1.024


Her toplu işte yazılan satır sayısı. Daha yüksek değerler ağ etkileşimlerini azaltır ve aktarım hızını artırır. Çok büyük değerler OOM hatasına neden olabilir.

Sonraki adımlar