Package org.infinispan.persistence.jdbc.common

Interface TableOperations<K,V>

All Known Implementing Classes:

AbstractSchemaJdbcStore.SchemaTableOperations, org.infinispan.persistence.jdbc.common.sql.BaseTableOperations, QueriesJdbcStore.QueryTableOperations, TableJdbcStore.TableTableOperations

public interface TableOperations<K,V>

Author:

William Burns

Method Summary

Modifier and Type	Method	Description
void	batchUpdates(Connection connection, int writePublisherCount, org.reactivestreams.Publisher<Object> removePublisher, org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
void	deleteAllRows(Connection connection)
boolean	deleteEntry(Connection connection, int segment, Object key)
MarshallableEntry<K,V>	loadEntry(Connection connection, int segment, Object key)
io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>>	publishEntries(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter, boolean fetchValue)
default io.reactivex.rxjava3.core.Flowable<K>	publishKeys(Supplier<Connection> connectionSupplier, Consumer<Connection> connectionCloser, IntSet segments, Predicate<? super K> filter)
long	size(Connection connection)
void	upsertEntry(Connection connection, int segment, MarshallableEntry<? extends K,? extends V> entry)

Method Detail

loadEntry

MarshallableEntry<K,V> loadEntry(Connection connection,
                                       int segment,
                                       Object key)
                                throws SQLException

Throws:

SQLException

publishKeys

default io.reactivex.rxjava3.core.Flowable<K> publishKeys(Supplier<Connection> connectionSupplier,
                                                          Consumer<Connection> connectionCloser,
                                                          IntSet segments,
                                                          Predicate<? super K> filter)

publishEntries

io.reactivex.rxjava3.core.Flowable<MarshallableEntry<K,V>> publishEntries(Supplier<Connection> connectionSupplier,
                                                                                Consumer<Connection> connectionCloser,
                                                                                IntSet segments,
                                                                                Predicate<? super K> filter,
                                                                                boolean fetchValue)

deleteEntry

boolean deleteEntry(Connection connection,
                    int segment,
                    Object key)
             throws SQLException

Throws:

SQLException

deleteAllRows

void deleteAllRows(Connection connection)
            throws SQLException

Throws:

SQLException

upsertEntry

void upsertEntry(Connection connection,
                 int segment,
                 MarshallableEntry<? extends K,? extends V> entry)
          throws SQLException

Throws:

SQLException

size

long size(Connection connection)
   throws SQLException

Throws:

SQLException

batchUpdates

void batchUpdates(Connection connection,
                  int writePublisherCount,
                  org.reactivestreams.Publisher<Object> removePublisher,
                  org.reactivestreams.Publisher<NonBlockingStore.SegmentedPublisher<MarshallableEntry<K,V>>> writePublisher)
           throws SQLException

Throws:

SQLException