DataWorks:DB2

Versões compatíveis

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

Recursos compatíveis

Tipos de campo compatíveis

O DB2 Reader e o DB2 Writer são compatíveis com os tipos de dados DB2 listados abaixo 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 Serverless resource groups e exclusive resource groups for Data Integration. Public resource groups e custom resource groups não são compatíveis.

• Comportamento de gravação: o DB2 Writer grava dados por meio de instruções insert into. Em caso de conflito de chave primária ou índice único, as linhas conflitantes não são gravadas. Para melhor desempenho, o DB2 Writer utiliza PreparedStatement + Batch com rewriteBatchedStatements=true, armazenando dados em um buffer de contexto de thread e enviando uma requisição de gravação quando o buffer atinge o limiar configurado.

  A tarefa de sincronização requer, 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 um data source

Adicione o data source do DB2 ao DataWorks antes de desenvolver uma tarefa de sincronização. Siga as instruções em Data source management. As descrições dos parâmetros estão disponíveis no console do DataWorks ao adicionar o data source.

Desenvolver uma tarefa de sincronização de dados

Perguntas frequentes

Por que o banco de dados em standby pode apresentar dados faltantes durante a sincronização ativo/standby?

Em uma configuração de recuperação de desastres ativo/standby, o banco de dados em standby aplica continuamente as alterações do banco de dados primário via binlogs. Esse processo tem uma latência inerente, que pode ser agravada pela latência de rede. Como resultado, o banco de dados em standby pode não refletir o banco de dados primário em tempo real, e discrepâncias significativas de dados entre os dois são possíveis.

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

O DB2 é um sistema de gerenciamento de banco de dados relacional (RDBMS) com interfaces de consulta de forte consistência. No modo de thread único, o DB2 Reader lê um snapshot consistente — se outra fonte gravar dados enquanto a tarefa estiver em execução, o DB2 Reader não recupera essas atualizações.

Ao configurar a extração simultânea com o parâmetro splitPk, o DB2 Reader inicia múltiplas tarefas que não fazem parte da mesma transação de leitura e são executadas em momentos diferentes. Nesse caso, os snapshots lidos pelas tarefas simultâneas podem ser incompletos ou inconsistentes. Duas alternativas estão disponíveis:

• Use sincronização com thread único (sem particionamento de dados). Essa abordagem preserva a consistência dos dados, mas reduz a velocidade de sincronização.

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

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

Não. O DB2 Reader extrai dados via Java Database Connectivity (JDBC). O JDBC gerencia a conversão de codificação na camada subjacente, de modo que o DB2 Reader detecta e transcodifica a codificação automaticamente.

Como configurar a sincronização incremental de dados?

O DB2 Reader extrai dados por meio de instruções JDBC SELECT, portanto é possível utilizar SELECT...WHERE... para extração incremental de duas formas:

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

• Para dados somente de acréscimo, configure uma cláusula where usando o maior ID de auto-incremento da execução de sincronização anterior.

Se nenhum campo distinguir dados novos dos existentes, somente a sincronização completa é possível.

O parâmetro querySql está protegido 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 este parâmetro.

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

Utilize 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 a task in the code editor.

{
    "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"
            }
        ]
    }
}