spring - How to get value from StepExecutionContext -

-

i have spring batch jdbccursoritemreader. defined @jobscope. see method signature below. 

@bean @jobscope public jdbccursoritemreader<masterlist> querystagingdbreader(         @value("#{jobparameters['" + jobparamconstants.param_from_date + "']}") date jobfromdate,         @value("#{jobparameters['" + jobparamconstants.param_to_date + "']}") date jobtodate) {

this jdbccursoritemreader part of step 2 in job.

in step 1 of job have tasklet. inside tasklet building list of dates jdbccursoritemreader in step 2 know about.

my initial thought add list of dates stepexecutioncontext in tasklet so.

@bean @jobscope public tasklet createjobdatestasklet(         @value("#{jobparameters['" + jobparamconstants.param_from_date + "']}") date jobfromdate,         @value("#{jobparameters['" + jobparamconstants.param_to_date + "']}") date jobtodate) {      return new tasklet() {          @override         public repeatstatus execute(stepcontribution contribution, chunkcontext chunkcontext) throws exception {             localdate start = jobfromdate.toinstant().atzone(zoneid.systemdefault()).tolocaldate();             localdate end = jobtodate.toinstant().atzone(zoneid.systemdefault()).tolocaldate();              list<localdate> jobdates = new arraylist<>();             while (!start.isafter(end)) {                 jobdates.add(start);                 start = start.plusdays(1);             }             //adding context here             chunkcontext.getstepcontext().getstepexecution().getexecutioncontext().put("jobdates", jobdates);             return repeatstatus.finished;         }     }; }

and grab list of dates jdbccursoritemreader. when try grab step execution context inside jdbccursoritemreader tells me cannot wire in. , think because bean @jobscope.

what can grab list of dates stepexecutioncontext or alternatively can else make work me?

thanks in advance

you cannot write step context, rather write job context, steps of job have access data below.

 stepcontext stepcontext         = chunkcontext.getstepcontext();  stepexecution stepexecution     = stepcontext.getstepexecution();  jobexecution jobexecution         = stepexecution.getjobexecution();  executioncontext jobcontext     = jobexecution.getexecutioncontext();  jobcontext.put("jobdates", jobdates);

the below blog speaks it

http://techie-mixture.blogspot.com/2016/07/passing-values-between-spring-batch.html


Comments

Post a Comment

Popular posts from this blog

Spring Boot + JPA + Hibernate: Unable to locate persister -

-
i trying work entity inside request method of spring boot application. entity in project , pom.xml has dependencies it. why error message?: org.hibernate.unknownentitytypeexception: unable locate persister: com.ric.bill.model.bs.par package com.ric.web; import java.util.concurrent.atomic.atomiclong; import javax.persistence.entitymanager; import javax.persistence.persistencecontext; import net.sf.ehcache.cachemanager; import net.sf.ehcache.management.cache; import net.sf.ehcache.management.cachestatistics; import org.hibernate.stat.statistics; import org.springframework.beans.factory.annotation.autowired; import org.springframework.boot.autoconfigure.domain.entityscan; import org.springframework.cache.annotation.enablecaching; import org.springframework.transaction.annotation.enabletransactionmanagement; import org.springframework.transaction.annotation.propagation; import org.springframework.transaction.annotation.transactional; import org.springframework.web.bind.annotati
Read more

go - Golang: panic: runtime error: invalid memory address or nil pointer dereference using bufio.Scanner -

-
i implementing go program uses bufio.scanner , bufio.writer have packaged code follows package main import ( "fmt" "player/command" "strings" ) func main() { //enter code here. read input stdin. print output stdout commands.scanner.scan() { //scan new line , send comand variable check command exist or not input := strings.split(strings.trim(commands.scanner.text(), " "), " ") command := input[0] if command == "" { fmt.printf("$ %s:", commands.pwd) continue } if !commands.commands[command] { commands.throwerror("cannot recognize input.") } else { commands.execute(command, input[1:], nil) } fmt.printf("$ %s:", commands.pwd) } } i using init.go file in main package follows package main import ( "flag" "player/sourc
Read more

c - double free or corruption (fasttop) -

-
this code reads null terminated string file (file containing null terminated strings & should provide index wanted string). error: *** error in `./main': double free or corruption (fasttop): 0x090a4a80 *** aborted code: char *tmp_realloc=null; char *sstring=null; int i=1; /*set file pointer point string*/ fseek(fh,index,seek_set); sstring=(char*)malloc(sizeof(char)); if(sstring == null) return null; tmp_realloc=sstring; while( (*(sstring+i-1)=(char)fgetc((file*)fh)) != 0x0 ) { /*reallocate more memory*/ tmp_realloc=(char*)realloc((char*)sstring,++i); /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strcpy((char*)tmp_realloc,(char*)sstring); free(sstring); sstring=tmp_realloc; } } could tell me pointer causing issue (& reason) ? remove part /*if not same address copy old new & set old point new*/ if(tmp_realloc != sstring){ strc
Read more