मैं MySQL 5.5 सर्वर पर SQL क्वेरी के बैच चलाने के लिए स्प्रिंग-आधारित समाधान बनाने की कोशिश कर रहा हूं। "क्वेरी" से मेरा मतलब है कि कोई भी SQL कथन जो संकलित करता है, इसलिए SQL बैच नौकरी में उदाहरण के लिए कई CREATE तालिका, हटाएं और फिर INSERT कथन शामिल हो सकते हैं।स्प्रिंग ट्रांजैक्शन मैनेजर - प्रतिबद्ध काम नहीं करता
मैं इस उद्देश्य के लिए Spring Batch का उपयोग कर रहा हूं।
मेरे पास transactionManager निम्नानुसार कॉन्फ़िगर किया गया है।
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager" />
और dataSource:
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="${batch.jdbc.driver}" />
<property name="url" value="${batch.jdbc.url}" />
<property name="username" value="${batch.jdbc.user}" />
<property name="password" value="${batch.jdbc.password}" />
<property name="maxIdle" value="10" />
<property name="maxActive" value="100" />
<property name="maxWait" value="10000" />
<property name="validationQuery" value="select 1" />
<property name="testOnBorrow" value="false" />
<property name="testWhileIdle" value="true" />
<property name="timeBetweenEvictionRunsMillis" value="1200000" />
<property name="minEvictableIdleTimeMillis" value="1800000" />
<property name="numTestsPerEvictionRun" value="5" />
<property name="defaultAutoCommit" value="true" />
</bean>
मेरे डीएओ वर्ग विधि एकल एसक्यूएल बयान के साथ विधि बुला SQL कथन का एक संग्रह से अधिक
@Transactional(propagation = Propagation.REQUIRES_NEW)
और मैं पाश के साथ विन्यस्त है एक वक़्त।
simpleJdbcTemplate.getJdbcOperations().execute(sql);
मैं उम्मीद है कि जब डीएओ विधि पूरा करता है, मैं डीबी में परिणाम देखेंगे: प्रसंस्करण विधि के अंदर के रूप में सरल रूप में है। हालांकि, ऐसा लगता है कि वसंत नौकरी निष्पादन पूरा होने पर परिणाम डीबी में उपलब्ध हो जाते हैं।
मैं करने की कोशिश की मेरी डीएओ विधि के अंदर प्रतिबद्ध:
@Transactional(propagation = Propagation.REQUIRES_NEW)
private void executeSingleQuery(String sql) {
PlatformTransactionManager transactionManager = (PlatformTransactionManager)context.getBean("transactionManager");
DefaultTransactionDefinition def = new DefaultTransactionDefinition();
def.setPropagationBehavior(Propagation.REQUIRED.ordinal());
TransactionStatus status = transactionManager.getTransaction(def);
try {
// execute your business logic here
log.info("about to execute SQL query[" + sql + "]");
simpleJdbcTemplate.getJdbcOperations().execute(sql);
} catch (Exception e) {
log.info("SQL query was not committed due to exception and was marked for rollback");
transactionManager.rollback(status);
}
transactionManager.commit(status);
if (transactionManager.getTransaction(null).isRollbackOnly()
&& transactionManager.getTransaction(null).isCompleted()) {
log.info("SQL query commited!");
} else {
log.info("SQL query was not committed due to: 1) the transaction has been marked for rollback " +
"2) the transaction has not completed for some reason");
}
log.info("the query has completed");
}
मैं वसंत कोड डिबग और देखा कि मैं अपने लिए प्रतिबद्ध डीएओ विधि से फोन (प्रवाह लाइन तक पहुँच जाता TransactionTemplate द्वारा निष्पादित किया जाता है this.transactionManager.commit(status); और अपवादों के बिना गुजरता है)
मैं किसी भी सलाह की सराहना करता हूं कि प्रत्येक कॉल पर डीएओ विधि को प्रतिबद्ध करने के लिए क्या किया जाना चाहिए (प्रत्येक SQL कथन के बाद प्रतिबद्ध करें)।
@ ट्रांसेक्शन एनोटेशन करने का ख्याल रखता है। आपके कोड में आपको लेनदेन प्रबंधक के संदर्भ की आवश्यकता नहीं है और मुझे लगता है कि बदलाव स्पष्ट रूप से करें। – ch4nd4n