2

こんにちは、SKU テーブル内のすべての SKU を処理し、在庫システムに要求を送信して在庫の詳細を取得する春のバッチに取り組んでいます。インベントリの詳細に送信するには、一度に 100 個の SKI ID を送信する必要があるため、pageSize を 100 に設定しました。

読者のログで：私たちは見る

SELECT * FROM (SELECT S_ID ,S_PRNT_PRD,SQ, ROWNUM as TMP_ROW_NUM FROM XXX_SKU WHERE SQ>=:min and SQ <=:max ORDER BY SQ ASC) WHERE ROWNUM <= 100]

しかし、WRITER では、特定の時間に 100 SKU が送信され、特定の要求では 1 つの SKU のみが送信されることがわかります。

public void write(List<? extends XXXPagingBean> pItems) throws XXXSkipItemException {
if (mLogger.isLoggingDebug()) {
mLogger.logDebug("XXXInventoryServiceWriter.write() method STARTING, ItemsList size:{0}" +pItems.size());
}
....
....
}
  • pageSize と commitInterval は 100 に設定されています (これらは同じであると考えられますか?)
  • sortKey (SEQ_ID) は、partitiner で使用する列と同じにする必要がありますか?

XML での Bean 構成:

<!-- InventoryService Writer configuration -->

<bean id="inventoryGridService" class="atg.nucleus.spring.NucleusResolverUtil" factory-method="resolveName">
<constructor-arg value="/com/XXX/gigaspaces/inventorygrid/service/InventoryGridService" />
</bean>

<bean id="inventoryWriter" class="com.XXX.batch.integrations.XXXXXX.XXXXInventoryServiceWriter" scope="step">
<property name="jdbcTemplate" ref="batchDsTemplate"></property>
<property name="inventoryGridService" ref="inventoryGridService" />
</bean>

<bean id="pagingReader" class="org.springframework.batch.item.database.JdbcPagingItemReader" xmlns="http://www.springframework.org/schema/beans" scope="step">
<property name="dataSource" ref="dataSource" />
<property name="queryProvider">
<bean id=" productQueryProvider" class="org.springframework.batch.item.database.support.SqlPagingQueryProviderFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="selectClause" value="select S_ID ,S_PRNT_PRD" />
<property name="fromClause" value="from XXX_SKU" />
<property name="sortKey" value="SEQ_ID" />
<property name="whereClause" value="SEQ_ID>=:min and SEQ_ID &lt;=:max"></property>
</bean>
</property>
<property name="parameterValues">
<map>
<entry key="min" value="#{stepExecutionContext[minValue]}"></entry>
<entry key="max" value="#{stepExecutionContext[maxValue]}"></entry>
</map>
</property>
<property name="pageSize" value="100" />
<property name="rowMapper">
<bean class="com.XXX.batch.integrations.endeca.XXXPagingRowMapper"></bean>
</property>
</bean>

提案してください。

4

1 に答える 1

0

Bean 定義から whereClause を削除し、それproductQueryProviderを取り除くparameterValuesと動作するはずです。が自動的にPagingQueryProviderページングを処理します。自分で手動で行う必要はありません。

于 2013-04-18T10:01:23.247 に答える