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,
                  long limit)  | 
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,
                                                           long limit)
                                                    throws java.sql.SQLException
java.sql.SQLExceptionCopyright © 2023. All Rights Reserved.