Module com.iamsoft.util.ui

Package com.iamsoft.util.ui.javafx.table

Class JpaLazyLoadingSupport<E>

java.lang.Object

com.iamsoft.util.ui.javafx.table.JpaLazyLoadingSupport<E>

public class JpaLazyLoadingSupport<E>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JpaLazyLoadingSupport.State

Constructor Summary

Constructors

Constructor	Description
JpaLazyLoadingSupport(jakarta.persistence.EntityManagerFactory pEntityMgrFactory, Class<E> pEntityClass)
JpaLazyLoadingSupport(jakarta.persistence.EntityManagerFactory pEntityMgrFactory, Class<E> pEntityClass, int pMaxEntitiesPerTransaction)

Method Summary

Modifier and Type	Method	Description
void	abort(Consumer<jakarta.persistence.EntityManagerFactory> pCleanupOp)	Use this method to abort current and pending DB write operations, if any.
void	close()
void	configureAutoRefresh(long pRefreshRateMillis, Runnable pRefreshItemCountOp, Runnable pRefreshViewOp)
Consumer<jakarta.persistence.EntityManagerFactory>	createRemoveAllTask()
Consumer<jakarta.persistence.EntityManagerFactory>	createRemoveTask(String pWhereClause, javafx.util.Pair<String,Object>... pParamPairs)
JpaLazyLoadingSupport.State	getState()
boolean	isAborting()
boolean	isIdle()
void	persist(Supplier<Stream<E>> pEntityStreamSupplier)	Sometimes it is easier to implement thread-safe stream supplier instead of directly providing thread-safe stream.
void	persist(Stream<E> pEntityStream)	Note that specified stream should be thread-safe.
void	remove(String pWhereClause, javafx.util.Pair<String,Object>... pParamPairs)
void	removeAll()
javafx.beans.property.ReadOnlyObjectProperty<JpaLazyLoadingSupport.State>	stateProperty()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JpaLazyLoadingSupport

public JpaLazyLoadingSupport(jakarta.persistence.EntityManagerFactory pEntityMgrFactory,
                             Class<E> pEntityClass)

JpaLazyLoadingSupport

public JpaLazyLoadingSupport(jakarta.persistence.EntityManagerFactory pEntityMgrFactory,
                             Class<E> pEntityClass,
                             int pMaxEntitiesPerTransaction)

Method Detail

stateProperty

public final javafx.beans.property.ReadOnlyObjectProperty<JpaLazyLoadingSupport.State> stateProperty()

getState

public final JpaLazyLoadingSupport.State getState()

configureAutoRefresh

public void configureAutoRefresh(long pRefreshRateMillis,
                                 Runnable pRefreshItemCountOp,
                                 Runnable pRefreshViewOp)

abort

public void abort(Consumer<jakarta.persistence.EntityManagerFactory> pCleanupOp)

Use this method to abort current and pending DB write operations, if any.

isAborting

public boolean isAborting()

isIdle

public boolean isIdle()

persist

public void persist(Stream<E> pEntityStream)

Note that specified stream should be thread-safe.

persist

public void persist(Supplier<Stream<E>> pEntityStreamSupplier)

Sometimes it is easier to implement thread-safe stream supplier instead of directly providing thread-safe stream.

removeAll

public void removeAll()

createRemoveAllTask

public Consumer<jakarta.persistence.EntityManagerFactory> createRemoveAllTask()

remove

public void remove(String pWhereClause,
                   javafx.util.Pair<String,Object>... pParamPairs)

createRemoveTask

public Consumer<jakarta.persistence.EntityManagerFactory> createRemoveTask(String pWhereClause,
                                                                           javafx.util.Pair<String,Object>... pParamPairs)

close

public void close()