एक रिकॉर्ड/आइटम पढ़ें और वसंत बैच

Question

का उपयोग करके एकाधिक रिकॉर्ड/आइटम लिखें और मैंने कुछ खोज किया लेकिन कोई नमूना/उदाहरण नहीं मिला।

मुझे एक आवश्यकता है जहां एक तालिका (इनपुट) से भू समन्वय पढ़ा जाता है, पीओआई को समन्वय से जुड़े उत्पन्न करने के लिए संसाधित किया जाता है। तो एक भू समन्वय के परिणामस्वरूप एक या अधिक पीओआई की आवश्यकता होगी जिसे किसी अन्य तालिका (आउटपुट) में डालने की आवश्यकता है।

मैं वर्तमान में एक आइटम/रिकॉर्ड पढ़ने और एक आइटम/रिकॉर्ड लिखने के लिए एक जेडीबीसी कर्सोरइटम रीडर और जेडीबीसी बैचइटमम्राइटर का उपयोग कर रहा हूं। एक आइटमप्रोसेसर भी है जो पीओआई को भू-समन्वय देने के लिए उत्पन्न करता है।

क्या कोई कस्टम JdbcBatchItemWriter मुझे यह प्राप्त करने में मदद करता है?

कोई विचार? TIA।

Answer 1

अगर आप सिर्फ विभिन्न लेखकों (डुप्लिकेट उत्पादन पढ़ें) आप मौजूदा CompositeItemWriter

उपयोग कर सकते हैं, लेकिन मैं यकीन नहीं है अगर आपके प्रोसेसर विभिन्न प्रकार की वस्तुओं के उत्पादन करेगा या यदि आप प्रसार करने के लिए चाहते करने के लिए आइटम का प्रसार करना चाहते हैं कई लेखकों को एक जटिल आइटम प्रकार की सामग्री, उन मामलों के लिए आप एक से थोड़ा बदला गया वर्शन एक multiline-record-writer प्रश्न के लिए करीब उपयोग कर सकते हैं

public class MultiOutputItemWriter implements ItemWriter<Object> { 

private JdbcBatchItemWriter<ClassFoo> delegateFoo; 
private JdbcBatchItemWriter<ClassBar> delegateBar; 

public void write(List<? extends Object> items) throws Exception { 
     // if you have different types of items 
     // check Object Class 
     // add to new List<Classfoo> 
     // call delegate e.g. delegateFoo.write(List with ClassFoo); 
     // 
     // or if you have complex objects 
     // same procedure as above, but with 
     // add to new List<Classfoo> with item.getClassFoo 
} 
} 

अगर आप FlatFileItemWriter उपयोग करते हैं, register the delegates as ItemStreams को भूल नहीं है (ताकि वसंत बैच खुल जाएगा/उन्हें आपके लिए)

Answer 2

क्या तुम सच में करने के लिए एक Splitter पैटर्न कहा जाता है देख रहे हैं:

यहाँ है कि यह कैसे Spring Integration में परिभाषित किया गया है:

एक स्प्लिटर संदेश Endpoint जिसका जिम्मेदारी के लिए है का एक प्रकार है अपने इनपुट चैनल से एक संदेश स्वीकार करें, उस संदेश को कई संदेशों में विभाजित करें, और फिर उनमें से प्रत्येक को अपने आउटपुट चैनल में भेजें। यह आमतौर पर उप-विभाजित पेलोड वाले संदेशों के समूह में "समग्र" पेलोड ऑब्जेक्ट को विभाजित करने के लिए उपयोग किया जाता है।

विन्यास अत्यंत सरल है:

<channel id="inputChannel"/> 

<splitter id="splitter" 
    ref="splitterBean" 
    method="split" 
    input-channel="inputChannel" 
    output-channel="outputChannel" /> 

<channel id="outputChannel"/> 

<beans:bean id="splitterBean" class="sample.PojoSplitter"/> 

या आप व्याख्या का उपयोग कर सकते हैं:

@Splitter 
List<LineItem> extractItems(Order order) { 
    return order.getItems() 
} 

आप निश्चित रूप से लिख सकते हैं अपने खुद के JdbcBatchItemWriter अगर यह आसान लगता है। हालांकि वसंत एकीकरण पहले से ही आपके लिए यह करता है।

आप Spring Integration JDBC Support =>jdbc:inbound-channel-adapter/jdbc:outbound-channel-adapter और उपरोक्त स्प्लिटर का उपयोग कर सकते हैं जो आप चाहते हैं और प्राप्त करने के लिए .. सादगी।

Answer 3

मैंने राइटर क्लास (मेरे मामले में HibernateItemWriter) को विस्तारित करके ऐसा किया। मुझे लगता है कि एक जवाब वर्णन करता है कि 'स्प्लिटर' का उपयोग कैसे करें। अगर किसी के पास एक कामकाजी उदाहरण है कि वसंत-बूट स्टार्टर-पैरेंट का उपयोग करके पर्यावरण में कैसे काम कर सकता है, तो मुझे इसे देखना अच्छा लगेगा। मैं जो कर रहा हूं (एक रिकॉर्ड से एक सूची बनाना) यह बहुत आसान होगा अगर स्प्रिंग ने एक लिखित विधि प्रदान की जो लिस्ट की सूची प्रदान करती है।Spring-Batch Multi-line record Item Writer with variable number of lines per record