grails - 如何在 Grails Spring Batch 和 SQL 中使用日期作业参数？

Question

我想使用 2 个使用 Spring Batch 后期绑定(bind)的日期作业参数执行查询。

JobParametersBuilder builder = new JobParametersBuilder()
builder.addDate("until", until);
builder.addDate("start", start);
JobExecution exec = jobLauncher.run(myJob, builder.toJobParameters())

我的 bean /工作定义:

myReader(JdbcPagingItemReader) { bean ->
    bean.scope = 'step'
    bean.autowire = 'byName'
    dataSource = ref('dataSource')
    queryProvider = ref('sqlPagingQueryProviderFactoryBean')
    parameterValues = [
            start: "#{jobParameters['start']}",
            until: "#{jobParameters['until']}"
    ]
    pageSize = '10'
    rowMapper = ref('myRowMapper') // not shown here
}


sqlPagingQueryProviderFactoryBean(SqlPagingQueryProviderFactoryBean) { bean ->
    bean.autowire = 'byName'
    bean.scope = 'step'
    dataSource = ref('dataSource')
    selectClause = 'some_timestamp, column2'
    fromClause = 'some_table'
    whereClause = 'some_timestamp >= cast(:start as timestamp) AND some_timestamp < cast(:until as timestamp)'
    sortKey = 'some_timestamp'
}

我收到各种错误，具体取决于我如何转换时间戳等，例如(对于上面的代码):

step.AbstractStep Encountered an error executing step myStep in job myJob org.springframework.dao.DataIntegrityViolationException: PreparedStatementCallback; SQL [SELECT some_timestamp, column2 FROM some_table WHERE some_timestamp >= cast(? as timestamp) AND some_timestamp < cast(? as timestamp) ORDER BY some_timestamp ASC LIMIT 10]; ERROR: invalid input syntax for type timestamp: "#{jobParameters['start']}"; nested exception is org.postgresql.util.PSQLException: ERROR: invalid input syntax for type timestamp: "#{jobParameters['start']}"nested exception is org.postgresql.util.PSQLException: ERROR: invalid input syntax for type timestamp: "#{jobParameters['start']}"

请问如何访问我的查询的时间戳？

Answer 1

好的，所以我用了this SO question作为线索，并没有将参数传递给 SqlPagingQueryProviderFactoryBean并在这里简单地使用后期绑定(bind)。

// within myReader, no need for parameters
// parameterValues = [
//        start: "#{jobParameters['start']}",
//        until: "#{jobParameters['until']}"
// ]


// within sqlPagingQueryProviderFactoryBean
whereClause = "some_timestamp >= '#{jobParameters[\'start\']}'::timestamptz AND some_timestamp < '#{jobParameters[\'until\']}'::timestamptz"