DataWorks:DB2

Versões compatíveis

O DB2 Reader e o DB2 Writer usam o IBM Data Server Driver for JDBC and SQLJ 4.11.77. Para verificar o mapeamento de versões entre o driver do DB2 e o serviço de banco de dados, consulte a documentação oficial.

Capacidades compatíveis

Tipos de campo compatíveis

O DB2 Reader e o DB2 Writer aceitam os seguintes tipos de dados do DB2 para operações de leitura e gravação offline. Verifique os tipos de dados antes de configurar uma tarefa de sincronização.

Limitações

• Grupos de recursos: O DB2 Reader e o DB2 Writer são compatíveis com grupos de recursos serverless e grupos de recursos exclusivos para Data Integration. Grupos de recursos públicos e grupos de recursos personalizados não são compatíveis.

• Comportamento de gravação: O DB2 Writer insere dados por meio de instruções insert into. Se houver conflito de chave primária ou índice único, as linhas conflitantes não serão gravadas. Para otimizar o desempenho, o DB2 Writer usa PreparedStatement + Batch com rewriteBatchedStatements=true, armazena dados em um buffer de contexto de thread e envia uma solicitação de gravação quando o buffer atinge o limiar configurado.

  A tarefa de sincronização exige, no mínimo, a permissão insert into . Permissões adicionais podem ser necessárias dependendo das instruções SQL configuradas nos parâmetros preSql e postSql .

• Criptografia: O algoritmo de criptografia AES do DB2 não é compatível.

Adicionar uma fonte de dados

Adicione a fonte de dados DB2 ao DataWorks antes de desenvolver uma tarefa de sincronização. Siga as instruções em Gerenciamento de fontes de dados. As descrições dos parâmetros estão disponíveis no console do DataWorks durante a adição da fonte de dados.

Desenvolver uma tarefa de sincronização de dados

Perguntas frequentes

Por que o banco de dados standby pode apresentar dados ausentes durante a sincronização active/standby?

Em um cenário de recuperação de desastres active/standby, o banco de dados standby aplica continuamente as alterações do banco de dados primário via binlogs. Esse processo tem um atraso inerente, agravado pela latência de rede. Consequentemente, o banco de dados standby pode não refletir o primário em tempo real, e discrepâncias significativas de dados entre ambos são possíveis.

O DB2 Reader garante consistência de dados durante a extração concorrente?

O DB2 é um sistema de gerenciamento de banco de dados relacional (RDBMS) com interfaces de consulta de forte consistência. No modo single-threaded, o DB2 Reader lê um snapshot consistente. Se outra fonte gravar dados enquanto a tarefa estiver em execução, o DB2 Reader não recuperará essas atualizações.

Ao configurar a extração concorrente com o parâmetro splitPk, o DB2 Reader inicia múltiplas tarefas fora da mesma transação de leitura e executadas em momentos diferentes. Nesse caso, os snapshots lidos pelas tarefas concorrentes podem estar incompletos ou inconsistentes. Existem duas soluções alternativas:

• Use sincronização single-threaded (sem particionamento de dados). Isso preserva a consistência dos dados, mas reduz a velocidade da sincronização.

• Desative as gravações na origem durante a sincronização, por exemplo, bloqueando tabelas ou pausando a replicação para o banco de dados standby. Essa abordagem mantém os dados da origem estáticos, mas pode afetar os serviços online.

É necessário configurar a codificação para o DB2 Reader?

Não. O DB2 Reader usa Java Database Connectivity (JDBC) para extrair dados. O JDBC gerencia a conversão de codificação na camada subjacente, portanto, o DB2 Reader detecta e transcodifica automaticamente a codificação.

Como configurar a sincronização incremental de dados?

O DB2 Reader extrai dados usando instruções JDBC SELECT, o que permite usar SELECT...WHERE... para extração incremental de duas formas:

• Se a aplicação de origem preencher um campo de timestamp (como uma coluna modify) quando os dados forem alterados, configure uma cláusula where com o timestamp da última execução de sincronização. Isso captura linhas novas, atualizadas e logicamente excluídas.

• Para dados apenas de acréscimo (append-only), configure uma cláusula where com o ID auto-incremental máximo da execução de sincronização anterior.

Se nenhum campo distinguir dados novos dos existentes, apenas a sincronização completa será possível.

**O parâmetro querySql é seguro contra injeção de SQL?**

O DB2 Reader não realiza verificações de segurança na instrução querySql. Revise e valide qualquer SQL personalizado antes de configurar esse parâmetro.

Apêndice: Demonstração de script e descrição de parâmetros

Use os scripts e referências de parâmetros a seguir ao configurar uma tarefa de sincronização em lote no editor de código. Para o procedimento geral, consulte Configure uma tarefa no editor de código.

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "db2",
            "parameter": {
                "datasource": "",
                "jdbcUrl": "",
                "username": "",
                "password": "",
                "table": "",
                "column": [
                    "id"
                ],
                "where": "",
                "splitPk": ""
            },
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "stream",
            "parameter": {},
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "throttle": true,
            "concurrent": 1,
            "mbps": "12"
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}

{
    "type": "job",
    "version": "2.0",
    "steps": [
        {
            "stepType": "stream",
            "parameter": {},
            "name": "Reader",
            "category": "reader"
        },
        {
            "stepType": "db2",
            "parameter": {
                "jdbcUrl": "jdbc:db2://ip:port/database",
                "username": "",
                "password": "",
                "table": "",
                "column": [
                    "id"
                ],
                "preSql": [],
                "postSql": [],
                "batchSize": 1024
            },
            "name": "Writer",
            "category": "writer"
        }
    ],
    "setting": {
        "errorLimit": {
            "record": "0"
        },
        "speed": {
            "throttle": true,
            "concurrent": 1,
            "mbps": "12"
        }
    },
    "order": {
        "hops": [
            {
                "from": "Reader",
                "to": "Writer"
            }
        ]
    }
}