public class MessageBodyStore extends JdbcAbstractStore
JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<R>, JdbcAbstractStore.StatementValues<T>datasource, logger| Constructor and Description |
|---|
MessageBodyStore(javax.sql.DataSource pool) |
| Modifier and Type | Method and Description |
|---|---|
void |
delete(java.lang.String guid) |
void |
deleteAll() |
java.util.List<java.lang.String> |
deleteOrphanBodies() |
java.util.List<java.lang.String> |
deletePurgedBodies(java.time.Instant removedBefore) |
java.util.List<java.lang.String> |
existing(java.util.List<java.lang.String> toCheck) |
boolean |
exists(java.lang.String uid) |
MessageBody |
get(java.lang.String guid) |
java.util.List<MessageBody> |
multiple(java.util.List<java.lang.String> guids) |
java.util.List<MessageBody> |
multiple(java.lang.String... guids) |
void |
store(MessageBody value) |
batchInsert, batchInsert, delete, delete, delete, doOrContinue, doOrFail, getConnection, insert, insert, insert, insert, insertAndReturn, insertWithSerial, lastInsertId, select, select, select, unique, unique, unique, unique, unique, update, update, update, update, updatepublic void store(MessageBody value) throws java.sql.SQLException
java.sql.SQLExceptionpublic void delete(java.lang.String guid)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void deleteAll()
throws java.sql.SQLException
java.sql.SQLExceptionpublic MessageBody get(java.lang.String guid) throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<MessageBody> multiple(java.lang.String... guids) throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<MessageBody> multiple(java.util.List<java.lang.String> guids) throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean exists(java.lang.String uid)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> existing(java.util.List<java.lang.String> toCheck)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> deleteOrphanBodies()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.util.List<java.lang.String> deletePurgedBodies(java.time.Instant removedBefore)
throws java.sql.SQLException
java.sql.SQLExceptionCopyright © 2022. All Rights Reserved.