spring integration jdbc inbound poller is failing on update query with invalid column type -
we using following config polling db table pick rows , rows picked want update status else not picked again in next poll. here config failing on update query error message
caused by: java.sql.sqlexception: invalid column type
<int-jdbc:inbound-channel-adapter auto-startup="true" channel="pollingchannel" query="$select id,status test_table status='ready'" data-source="datasource" id="pollingchanneladapter" row-mapper="testrowmapper" update="update test_table set status='picked' id in (:id)" update-per-row="true" > <int:poller default="false" id="poller" max-messages-per-poll="1" fixed-rate="1000"/> </int-jdbc:inbound-channel-adapter>
found fix. have use proper property defined in value object parsing select query response using row mapper value object did not had property named "id". once changed correct one, started working fine.
Comments
Post a Comment