Defines a MessageStore (and MessageGroupStore)
backed by a database.
Reference to a data source to use to access
the database. Either this or the jdbc-operations
must be
specified (but not both).
Reference to a JdbcOperations. Either
this or
the data-source must be
specified (but not both).
Unique string to use as a partition for the
data in this store, so that
multiple instances can
share the same
database tables. The default
is "DEFAULT".
Prefix for the table names in the database
(e.g. so that a schema can be specified, or to avoid
a clash
with
other tables). The default is "INT_".
Defines an inbound Channel Adapter for polling a
database.
An update query to execute when a message is
polled. If the poll is in a transaction then the
update will
roll back if the transaction does.
An update query to execute when a message is
polled. If the poll is in a transaction then the
update will
roll back if the transaction does. The update can also be specified as a nested element.
Flag to indicate whether the update query
should be executed per message, or per row (in the
case that a
message contains multiple rows).
Limits the number of rows extracted per query (otherwise all rows
are extracted into the
outgoing message).
Channel to which polled messages will be
sent.
Flag to indicate that the poller should start automatically on startup (default true).
Reference to a SqlParameterSourceFactory. The input is the result of the
query. The
default factory creates a parameter source that treats a List in a special
way: the parameter name is used as an expression and projected onto the list,
so for instance "update foos set status=1 where id in (:id)" will generate
an in clause from the properties "id" of the input list elements.
Reference to a static SqlParameterSource for the SELECT query used for polling. If
that query has
placeholders (e.g. "SELECT * from FOO where KEY=:key") they
will be bound from this source by name.
Defines an outbound Channel Adapter for updating a
database.
Reference to a SqlParameterSourceFactory. The input is the whole
outgoing message. The
default factory creates a bean
property parameter source so the query can specify named
parameters like :payload and :headers[foo].
Channel from which messages will be output.
When a message is sent to this channel it will
cause the query
to be executed.
Flag to indicate whether primary keys are generated by the query.
Flag to indicate that the poller should start automatically on startup (default true).
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
Defines an outbound Channel Gateway for updating a
database in response to a message on the request
channel and getting a response
on the reply channel. The response can be created from a query
supplied here, or (if keys-generated="true") can be the
primary keys generated from an auto-increment, or else just a
count of the number of rows affected by the update. The response
is in general a case insensitive Map (or list of maps if multi-valued), unless
a select query and a row-mapper is provided. If the update count is
returned then the map key is "UPDATE".
An update query to execute when a message is
received. If this is in a transaction then the
update will
roll back when the transaction does.
An update query to execute when a message is
received. If this is in a transaction then the
update will
roll back when the transaction does. The update can also be specified as a nested element.
Reference to a SqlParameterSourceFactory. The input is the whole
outgoing message. The
default factory creates a bean
property parameter source so the query can specify named
parameters like :payload and :headers[foo].
Reference to a SqlParameterSourceFactory. The input is the whole
outgoing message. The
default factory creates a bean
property parameter source so the query can specify named
parameters like :payload and :headers[foo].
Flag to indicate whether primary keys are generated by the query. If they are then
they can be used as a reply payload instead of providing a select query. A single
valued result is extracted before returning (the usual case), so the payload of the reply message
can be a Map (column name to value) or a list of maps.
Flag to indicate that the poller should start automatically on startup (default true).
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
Reference to a data source to use to access
the
database. Either this or the
simple-jdbc-operations
must be
specified
(but not both).
Reference to a JdbcOperations. Either
this or
the
data-source must be
specified (but not both).
A select query to execute when a message is
polled. In general
the query can return multiple
rows, because
the result will be a List (of type determined by the
row
mapper).
A select query to execute when a message is
polled. In general the query can return multiple
rows, because
the result will be a List (of type determined by the row
mapper). The query can also be specified as
a nested element.
Reference to a row mapper to use to convert
JDBC result set rows to message payloads.
Optional
with default
that maps
result set row to a map (column name to column value).
Other simple
use cases can
be handled
with out-of-the box
implementations from Spring JDBC. Others require a custom row
mapper.