spring-batch

0熱度

2回答

我有三個步驟的彈簧批量作業。第一步運行一次，第二步和第三步爲隊列中的每個項目運行。用於重複步驟 return jobBuilderFactory.get("job") .incrementer(new RunIdIncrementer()) .listener(jobListener()) .flow(step1()) .next(step2())

2熱度

1回答

如何跟蹤Spring批處理失敗的記錄？

我想跟蹤在閱讀作業的過程中失敗的記錄。我爲此使用了SkipListener。 public class SkipListener implements org.springframework.batch.core.SkipListener { public void onSkipInProcess(Object arg0, Throwable arg1) { }

0熱度

1回答

Spring Batch的：替代JpaPagingItemReader導致ORA-01555

我有兩個步驟步驟1批作業：轉到外部數據庫，調用存儲過程，編寫JPA實體並持續到內部數據庫的標誌NOT_PROCESSED。第2步：遍歷剛纔保存的實體標誌NOT_PROCESSED，對它們進行處理，並寫更新實體回（不更新標誌）一旦所有的人都被處理的標誌個個已更新爲已處理。即全部或全部更新。第1步是好的，工作很順利。第2步基本上是JpaPagingItemReader，其中pageSize

0熱度

1回答

Spring批處理作業處理多個文件，但一次處理一個文件

我有一個彈簧批處理作業，我需要從一個文件夾中讀取多個文本文件。需求是這樣的： - 我需要讀取一個文件，如果有超過300行的條目，那麼我需要將塊大小設置爲300，並將其寫入數據庫中。如果它小於300那麼我需要將塊大小設置爲代碼行數並寫入數據庫。然後我需要讀取下一個文件並寫入數據庫，直到文件夾中的所有文件都被佔用。

0熱度

1回答

未能調用HibernateCursorItemReader的close方法

我有一個HibernateCursorItemReader在關閉方法上失敗，因爲我的光標已經關閉，它被AbstractStep.close()和JobSynchronizationManager.release()兩次調用。 @Configuration @ConfigurationProperties("job.entity") public class EntityJobConfig

2熱度

1回答

如何在Spring批處理應用程序中處理二進制（Blob）數據

我的要求是從數據庫中讀取數據聚合並轉換爲字節，然後將數據流傳輸到Blob列中的另一個數據庫（Oracle）。 Oracle需要禁用JDBC自動提交以流式傳輸到Blob列並在完成時調用Connection＃Commit。我目前有3個步驟。（步驟）：它有兩個SQL查詢。一個用來初始化柱（UPDATE DATABASEUSER.TABLENAME SET payload = empty_blob(

0熱度

1回答

在SpringBoot + Spring批處理中讀取多個文件和進程

我使用Spring批處理和Spring啓動。我在處理多個文件時遇到問題。我的情景。我有不同頭，例如多個文件： Sourcefile1.txt： name, age, salary ajay, 22, 2000 vijay, 23, 3000 Sourcefile2.txt： name, address vijay, india ajay, uk 我想處理使用彈簧啓動，彈簧批處理這

0熱度

1回答

Spring批處理使用> =和<Where子句

嘗試使用Spring Batch讀取僅在昨天創建的數據。下面是我嘗試使用的bean，使用JdbcPagingItemReader & SqlPagingQueryProviderFactoryBean。但是，查詢沒有得到執行。感謝您的幫助！ <bean id="customersPagingItemReader" class="org.springframework.batch.ite

0熱度

1回答

Spring批處理FlatFileItemReader獲得iput線

如果我的平面文件的標記數不正確，我會得到下面的異常。 2017-05-25 11:58:31,337 ERROR org.springframework.batch.item.file.FlatFileItemReader (FlatFileItemReader.java:199)- Parsing error at line: 7 in resource=file [C:\flatfiles\t

0熱度

1回答

方法executeQuery不能用於更新。 ERRORCODE = -4476，SQLSTATE = null

我正在使用Spring批處理框架從db2讀取並出現錯誤。請注意，與Mysql一樣正常工作。當使用db2在meta表中創建條目時。 BatchConfig.java @Configuration @EnableBatchProcessing public class BatchConfiguration { @Autowired public JobBuilderFact