Esse padrão é usado para recuperar dados de um banco de dados que usa o OpenJPA.
Propriedade | Valor |
---|---|
PATTERN_IMPL_CLASS | Classe que implementa a interface JPAReader |
openjpa.ConnectionDriverName | O driver JDBC. Por exemplo, org.apache.derby.jdbc.EmbeddedDriver |
openjpa.ConnectionURL | A URL de JDBC. Por exemplo, jdbc:derby:C:\\mysample CREDITREPORT |
openjpa.jdbc.SynchronizeMappings | Propriedade específica ao JPA. Por exemplo, buildSchema |
openjpa.ConnectionUserName | O ID do usuário do banco de dados. Por exemplo, Myid |
openjpa.ConnectionPassword | Senha de usuário. Por exemplo, mypwd. |
PERSISTENT_UNIT | O nome da unidade persistente OpenJPA. |
Nome da Propriedade | Valor | Descrição |
---|---|---|
debug |
verdadeiro ou falso (o valor padrão é falso) |
Ativa o rastreio detalhado neste fluxo de dados em lote. |
openjpa.Log |
DefaultLevel=WARN,SQL=TRACE |
Configurações de log JPA |
Ativar Medida de Desempenho |
verdadeiro ou falso (o valor padrão é falso) |
Calcula o tempo total gasto nos fluxos de dados em lote e no método processRecord, se você estiver usando o GenericXDBatchStep. |
Ativar Medida de Desempenho Detalhada |
verdadeiro ou falso (o valor padrão é falso) |
Fornece uma lista expandida detalhada do tempo gasto em cada método dos fluxos de dados em lote. |
public interface JPAReaderPattern { /** * Esse método é invocado durante a fase de configuração da tarefa. * * @param Propriedades props fornecidas no xJCL */ public void initialize(Properties props); /** * Esse método deve recuperar valores para as várias colunas da linha atual do objeto Iterator fornecido. * Tipicamente, esses dados seriam usados para preencher um objeto intermediário que seria retornado * @param listIt * @return */ public Object fetchRecord(Iterator listIt); /** * Esse método deve retornar uma consulta JPQL que será usada durante a configuração do fluxo para recuperar todos os * dados relevantes que serão processados como parte das etapas da tarefa * @return objeto a ser usado durante a etapa do processo. */ public String getInitialLookupQuery(); /** * Esse método é chamado durante o Reinício da Tarefa. O token de reinício deve ser usado para criar uma consulta JPQL que * recuperará registros não processados anteriormente. * Tipicamente o token de reinício será a chave primária na tabela e a consulta obterá todas as linhas com * valor da chave primária > restarttoken * @param restartToken * @return A consulta de reinício */ public String getRestartQuery(String restartToken); /** * Esse método é chamado exatamente antes de um ponto de verificação ser utilizado. * @return O método deve retornar um valor de cadeia que identifica o último registro lido pelo fluxo. */ public String getRestartTokens(); }
<batch-data-streams> <bds> <logical-name>inputStream</logical-name> <props> <prop name="openjpa.ConnectionDriverName" value="org.apache.derby.jdbc.EmbeddedDriver"/> <prop name="openjpa.ConnectionURL" value="jdbc:derby:/opt/tmp/hellojpadb;create=true"/> <prop name="openjpa.ConnectionUserName" value="" /> <prop name="openjpa.ConnectionPassword" value="" /> <prop name="openjpa.jdbc.SynchronizeMappings" value="buildSchema"/> <prop name="openjpa.Log" value="DefaultLevel=WARN,SQL=TRACE"/> <prop name="PERSISTENT_UNIT" value="hellojpa"/> <prop name="debug" value="true"/> <prop name="PATTERN_IMPL_CLASS" value="com.ibm.websphere.samples.JPAOutputStream"/> </props> <impl-class>com.ibm.websphere.batch.devframework.datastreams.patterns.LocalJDBCReader</impl-class> </bds> </batch-data-streams>