UpdateDatabaseTable 2025.10.2.19¶
Pacote¶
org.apache.nifi | nifi-standard-nar
Descrição¶
Esse processador usa uma conexão JDBC e registros de entrada para gerar quaisquer alterações na tabela do banco de dados necessárias para oferecer suporte aos registros de entrada. Ele espera um layout de registro “nivelado”, o que significa que nenhum dos campos de registro de nível superior tem campos aninhados que se destinam a se tornar colunas.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Padrão de tradução de nome de coluna |
O nome da coluna será normalizado com esta expressão regular |
Estratégia de tradução de nome de coluna |
A estratégia usada para normalizar o nome da coluna de tabela. O nome da coluna será em letras maiúsculas para fazer a correspondência sem distinção entre maiúsculas e minúsculas, independentemente da estratégia |
Serviço de dialeto de banco de dados |
Serviço de dialeto de banco de dados para gerar instruções específicas para um determinado serviço ou fornecedor. |
db-type |
Database Type for generating statements specific to a particular service or vendor. The Generic Type supports most cases but selecting a specific type enables optimal processing or additional features. |
record-reader |
O serviço para leitura de FlowFiles de entrada. O leitor é usado apenas para determinar o esquema dos registros; os registros reais não serão processados. |
updatedatabasetable-catalog-name |
O nome do catálogo que a instrução deve atualizar. Isso pode não se aplicar ao banco de dados que você está atualizando. Nesse caso, deixe o campo vazio. Observe que, se a propriedade estiver definida e o banco de dados diferenciar maiúsculas de minúsculas, o nome do catálogo deverá corresponder exatamente ao nome do catálogo do banco de dados. |
updatedatabasetable-create-table |
Especifica como processar a tabela de destino quando ela não existir (criá-la, falhar, por exemplo). |
updatedatabasetable-dbcp-service |
O Controller Service usado para obter conexão(ões) com o banco de dados |
updatedatabasetable-primary-keys |
Uma lista de nomes de campos de registro separados por vírgulas que identifica exclusivamente uma linha no banco de dados. Essa propriedade só é usada se a tabela especificada precisar ser criada; nesse caso, os Campos de chave primária (Primary Key Fields) serão usados para especificar as chaves primárias da tabela recém-criada. Importante: os campos de chave primária devem corresponder exatamente aos nomes de campo do registro, a menos que a opção “Citar identificadores de coluna” seja falsa e o banco de dados permita nomes de coluna que não diferenciem maiúsculas de minúsculas. Na prática, é melhor especificar campos de chave primária que correspondam exatamente aos nomes de campos de registro, e esses se tornarão os nomes das colunas na tabela criada. |
updatedatabasetable-query-timeout |
Define o número de segundos que o driver aguardará a execução de uma consulta. Um valor de 0 significa que não há tempo limite. NOTE: valores diferentes de zero podem não ser compatíveis com o driver. |
updatedatabasetable-quoted-column-identifiers |
A ativação dessa opção fará com que todos os nomes de coluna sejam colocados entre aspas, permitindo que você use palavras reservadas como nomes de coluna em suas tabelas e/ou forçando os nomes de campo de registro a corresponder exatamente aos nomes de coluna. |
updatedatabasetable-quoted-table-identifiers |
A ativação dessa opção fará com que o nome da tabela seja citado para oferecer suporte ao uso de caracteres especiais no nome da tabela e/ou forçará o valor da propriedade Table Name a corresponder exatamente ao nome da tabela de destino. |
updatedatabasetable-record-writer |
Specifies the Controller Service to use for writing results to a FlowFile. The Record Writer should use Inherit Schema to emulate the inferred schema behavior, i.e. an explicit schema need not be defined in the writer, and will be supplied by the same logic used to infer the schema from the column types. If Create Table Strategy is set “Create If Not Exists”, the Record Writer “s output format must match the Record Reader’s format in order for the data to be placed in the created table location. Note that this property is only used if “Update Field Names” is set to true and the field names do not all match the column names exactly. If no update is needed for any field names (or “Update Field Names” is false), the Record Writer is not used and instead the input FlowFile is routed to success or failure without modification. |
updatedatabasetable-schema-name |
O nome do esquema do banco de dados ao qual a tabela pertence. Isso pode não se aplicar ao banco de dados que você está atualizando. Nesse caso, deixe o campo vazio. Observe que, se a propriedade for definida e o banco de dados diferenciar maiúsculas de minúsculas, o nome do esquema deverá corresponder exatamente ao nome do esquema do banco de dados. |
updatedatabasetable-table-name |
O nome da tabela do banco de dados a ser atualizada. Se a tabela não existir, ela será criada ou será lançado um erro, dependendo do valor da propriedade Criar tabela. |
updatedatabasetable-translate-field-names |
Se for verdadeiro, o processador tentará traduzir os nomes de campo para os nomes de coluna correspondentes da tabela especificada, com o objetivo de determinar se o nome do campo existe como uma coluna na tabela de destino. NOTE: Se a tabela de destino não existir e tiver que ser criada, essa propriedade será ignorada e os nomes dos campos serão usados no estado em que se encontram. Se falso, os nomes dos campos deverão corresponder exatamente aos nomes das colunas; caso contrário, a coluna poderá não ser encontrada e, em vez disso, será relatado um erro informando que a coluna já existe. |
updatedatabasetable-update-field-names |
This property indicates whether to update the output schema such that the field names are set to the exact column names from the specified table. This should be used if the incoming record field names may not match the table “s column names in terms of upper- and lower-case. For example, this property should be set to true if the output FlowFile is destined for Oracle e.g., which expects the field names to match the column names exactly. NOTE: The value of the’Translate Field Names” property is ignored when updating field names; instead they are updated to match the column name as returned by the database. |
Relações¶
Nome |
Descrição |
|---|---|
failure |
Um FlowFile contendo registros encaminhados para essa relação se o registro não puder ser transmitido ao banco de dados. |
success |
Um FlowFile contendo registros encaminhados para essa relação após o registro ter sido transmitido com sucesso ao banco de dados. |
Grava atributos¶
Nome |
Descrição |
|---|---|
output.table |
Esse atributo é gravado nos FlowFiles roteados para as relações “success” e “failure” e contém o nome da tabela de destino. |
output.path |
Esse atributo é gravado nos FlowFiles encaminhados para as relações “success” e “failure” e contém o caminho no sistema de arquivos para a tabela (ou o local da partição, se a tabela for particionada). |
mime.type |
Define o atributo mime.type como o tipo MIME especificado pelo Record Writer, somente se um Record Writer for especificado e Update Field Names (Atualizar nomes de campo) for “true”. |
record.count |
Define o número de registros no FlowFile, somente se um Record Writer for especificado e Update Field Names (Atualizar nomes de campo) for “true”. |