Synchronizes the shared or local databases with their opposite side. Local changes are pushed by EntriesEvent using Google's Guava EventBus.

Threading model:

The listen methods run on the thread posting the event - the UI thread while typing - and therefore never touch the database themselves. Every database access runs on syncExecutor, a single worker, so that writes and pulls happen in the order they were queued.
The local model is only mutated on the model thread (remoteUpdateExecutor, the UI thread in the GUI): a pull fetches on the database worker and applies the result on the model thread.
Multi-step apply sequences are serialized with pullLock, because in headless use (tests) the notification listener thread applies concurrently with the caller. EventBus-dispatched listen methods only tryLock and skip the work when the lock is contended - they may hold EventBus monitors that the lock holder needs for posting its own events.

Connection loss: once a write finds the connection dead, the synchronizer goes offline - every change is recorded in OfflineChanges (in memory and on disk) instead of being written, pulls are skipped, and a background loop reconnects with backoff. Back online, the recorded changes are written through the same optimistic lock as any other change, then everything is pulled.

Undo: a change pulled from the database is applied to the local model without going on the undo journal, and that is a decision rather than an omission - see ADR-0072. Undoing one locally would take back something the shared database still holds, leaving this copy out of step until the next push, and what happens then is a question about who owns a change. What the local user meets instead: their own recorded change refuses to apply once a pulled change has moved the value on, and says so, rather than overwriting the newer value (org.jabref.model.undo.BibChange#apply); and the pulled change marks the library as needing a save, because it arrives as org.jabref.model.entry.event.EntriesEventSource#SHARED.

Nested and Inner Type Summary

Modifier and Type	Class and Description
private static interface	DBMSSynchronizer.DatabaseWrite
private static record	DBMSSynchronizer.RemoteChanges What the shared database has that the local library has not.

Field Summary

Modifier and Type	Field and Description
private final BibDatabase	bibDatabase
private final BibDatabaseContext	bibDatabaseContext
private volatile boolean	closed
private final AtomicBoolean	connected
private Connection	currentConnection
private DatabaseConnection	dbmsConnection
private DBMSProcessor	dbmsProcessor
private String	dbName
private final AtomicReference<BibEntry>	entryWithPendingChanges
private final EventBus	eventBus
private final FieldPreferences	fieldPreferences
private final FileUpdateMonitor	fileMonitor
private final GlobalCitationKeyPatterns	globalCiteKeyPattern
private static final long	INITIAL_RECONNECT_DELAY_MILLIS
private final Character	keywordSeparator
private volatile Map<String, String>	lastSharedMetaData
private static final Logger	LOGGER
private static final long	MAX_RECONNECT_DELAY_MILLIS
private MetaData	metaData
private Notifier	notifier
private OfflineChanges	offlineChanges
private final Path	offlineChangesDirectory
private final @Nullable ExecutorService	ownedSyncExecutor
private final ReentrantLock	pullLock
private final Executor	remoteUpdateExecutor
private boolean	sharedDatabaseOpen
private final Set<Integer>	sharedIdsInConflict
private final Executor	syncExecutor
private final TaskExecutor	taskExecutor
private final String	userAndHost

Constructor Summary

Access	Constructor and Description
public	DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor)
public	DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor, Executor remoteUpdateExecutor)
pack-priv	DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor, Executor remoteUpdateExecutor, Executor syncExecutor, Path offlineChangesDirectory)

Method Summary

Modifier and Type	Method and Description
public void	applyMetaData() Applies the `MetaData` on all local and shared BibEntries.
private void	applyRemoteChanges(DBMSSynchronizer.RemoteChanges remoteChanges) Model thread
public void	applyRemoteFieldChange(FieldChange fieldChange) Applies a field change received from another client.
private void	applyRemoteMetaData(Map<String, String> sharedMetaData) Model thread
private boolean	applySaveActions(BibEntry bibEntry) Returns: whether a save action changed the entry
private void	applySaveActionsToBufferedEntry() Model thread: the save actions mutate the entry, which the database worker must not do.
private boolean	Returns: `true` if the connection is valid, else `false`. checkCurrentConnection() Checks whether the current SQL connection is valid; a dead one takes the synchronizer offline.
private static void	closeQuietly(Connection connection)
public void	closeSharedDatabase() Implements org.jabref.logic.shared.DatabaseSynchronizer.closeSharedDatabase.
private void	doApplyMetaData() Model thread: applies the save actions locally; the entries they changed are written afterwards.
private void	doApplyRemoteFieldChange(FieldChange fieldChange)
private DBMSSynchronizer.RemoteChanges	fetchRemoteChanges() Database worker.
public DatabaseConnectionProperties	getConnectionProperties() Implements org.jabref.logic.shared.DatabaseSynchronizer.getConnectionProperties.
public String	getDBName() Implements org.jabref.logic.shared.DatabaseSynchronizer.getDBName.
private void	goOffline() Takes the synchronizer offline: from now on changes are recorded instead of written, and a scheduled task tries to get a new connection.
public void	handleRemoteDatabaseChange() Schedules a full synchronization requested by another shared-database client.
public void	handleRemoteFieldChange(FieldChange fieldChange) Schedules a field update received from another shared-database client.
public void	handleRemoteMetaDataChange() Schedules a metadata update received from another shared-database client.
private void	handleWriteFailure(String message, SQLException exception, Runnable record) Database worker.
private boolean	Returns: whether the work ran ifNotPullingAlready(Runnable work) Runs the given work only when no other thread is applying a pull right now.
public void	initializeDatabases() Sets the table structure of shared database if needed and pulls all shared entries to the new local database.
private boolean	Returns: whether the entries reached the shared database insertSharedEntries(List<BibEntry> bibEntries) Database worker
private static boolean	isEventSourceAccepted(EntriesEvent event) Only local changes (and their undo) are written; changes applied from the shared side are not echoed back.
private boolean	isPresentLocalBibEntry(BibEntry bibEntry)
public void	listen(EntriesAddedEvent event) Listening method.
public void	listen(FieldChangedEvent event) Listening method.
public void	listen(EntriesRemovedEvent event) Listening method.
public void	listen(MetaDataChangedEvent event) Listening method.
private List<BibEntry>	Returns: the entries whose shared version still is the one the removal was recorded against onlyUnchangedSharedEntries(List<BibEntry> entriesToRemove) Database worker: the optimistic lock for a recorded removal, which `DBMSProcessor#removeEntries` cannot express.
public void	openSharedDatabase(DatabaseConnection connection) Implements org.jabref.logic.shared.DatabaseSynchronizer.openSharedDatabase.
private static void	overwriteLocalEntry(BibEntry localEntry, BibEntry sharedEntry) Writes a pulled entry over the local one.
public void	pullChanges() Implements org.jabref.logic.shared.DatabaseSynchronizer.pullChanges. Synchronizes the local BibEntries and applies the fetched MetaData on them.
private void	pullEntries() Brings the local entries up to date with the shared database: fetches on the database worker, applies on the model thread.
private void	pullMetaData()
private void	reconnect(long delayMillis)
public void	registerListener(Object listener) Implements org.jabref.logic.shared.DatabaseSynchronizer.registerListener.
private boolean	Returns: whether the removal reached the shared database removeSharedEntries(List<BibEntry> bibEntries) Database worker
private boolean	Returns: whether there was anything to replay replayOfflineChanges(boolean whether the local library was just loaded from the shared database and needs the recorded state restored - after a reconnect it holds the changes already, plus micro-edits made since the record afterRestart) Writes the changes recorded while offline through the same paths as live changes: applied to the local library (model thread) where a restart lost them, then written (database worker) - a shared entry that moved on meanwhile refuses the write and the user merges, like any other conflict.
private void	reviveEntriesDeletedMeanwhile(List<BibEntry> entriesToWrite, List<BibEntry> entriesToInsert) Database worker: a shared row deleted during the outage must not take the changes recorded against it with it.
private void	scheduleReconnect(long delayMillis) One attempt per scheduled task, so that waiting for the next one occupies no thread
public void	setDBName(String dbName) Implements org.jabref.logic.shared.DatabaseSynchronizer.setDBName.
public void	setMetaData(MetaData metaData)
public void	synchronizeLocalDatabase() Implements org.jabref.logic.shared.DatabaseSynchronizer.synchronizeLocalDatabase. Synchronizes the local database with shared one.
public void	synchronizeSharedEntry(BibEntry bibEntry) Implements org.jabref.logic.shared.DatabaseSynchronizer.synchronizeSharedEntry. Writes the merged entry of a resolved conflict.
private void	useConnection(DatabaseConnection newConnection) Database worker: replaces the dead connection, then synchronizes what happened meanwhile
private void	withPullLock(Runnable work)
private void	writeBufferedEntry() Database worker: writes the buffered micro-edited entry (if any) as a whole
private boolean	Returns: whether the write reached the shared database writeOrRecord(String failureMessage, DBMSSynchronizer.DatabaseWrite write, Runnable record) Database worker: runs the write and asks other clients to pull, or records the change when the connection is gone
private boolean	writeRecordedMetaData(Map<String, String> recordedMetaData, OfflineChanges.Recorded recorded) Database worker: recorded metadata is merged into what the shared side has now, so that metadata other clients changed during the outage (a group they added, say) survives
private boolean	Returns: whether the entry reached the shared database - a refused or failed (and thus rolled back) update must not be announced to other clients writeSharedEntry(BibEntry bibEntry) Database worker.
private boolean	writeSharedMetaData(Map<String, String> serializedMetaData) Database worker.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bibDatabase	back to summary
private final BibDatabase bibDatabase

bibDatabaseContext	back to summary
private final BibDatabaseContext bibDatabaseContext

closed	back to summary
private volatile boolean closed

connected	back to summary
private final AtomicBoolean connected

currentConnection	back to summary
private Connection currentConnection

dbmsConnection	back to summary
private DatabaseConnection dbmsConnection

dbmsProcessor	back to summary
private DBMSProcessor dbmsProcessor

dbName	back to summary
private String dbName

entryWithPendingChanges	back to summary
private final AtomicReference<BibEntry> entryWithPendingChanges

eventBus	back to summary
private final EventBus eventBus

fieldPreferences	back to summary
private final FieldPreferences fieldPreferences

fileMonitor	back to summary
private final FileUpdateMonitor fileMonitor

globalCiteKeyPattern	back to summary
private final GlobalCitationKeyPatterns globalCiteKeyPattern

INITIAL_RECONNECT_DELAY_MILLIS	back to summary
private static final long INITIAL_RECONNECT_DELAY_MILLIS

keywordSeparator	back to summary
private final Character keywordSeparator

lastSharedMetaData	back to summary
private volatile Map<String, String> lastSharedMetaData

LOGGER	back to summary
private static final Logger LOGGER

MAX_RECONNECT_DELAY_MILLIS	back to summary
private static final long MAX_RECONNECT_DELAY_MILLIS

metaData	back to summary
private MetaData metaData

notifier	back to summary
private Notifier notifier

offlineChanges	back to summary
private OfflineChanges offlineChanges

offlineChangesDirectory	back to summary
private final Path offlineChangesDirectory

ownedSyncExecutor	back to summary
private final @Nullable ExecutorService ownedSyncExecutor

pullLock	back to summary
private final ReentrantLock pullLock

remoteUpdateExecutor	back to summary
private final Executor remoteUpdateExecutor

sharedDatabaseOpen	back to summary
private boolean sharedDatabaseOpen

sharedIdsInConflict	back to summary
private final Set<Integer> sharedIdsInConflict

syncExecutor	back to summary
private final Executor syncExecutor

taskExecutor	back to summary
private final TaskExecutor taskExecutor

userAndHost	back to summary
private final String userAndHost

Constructor Detail

DBMSSynchronizer	back to summary
public DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor)

DBMSSynchronizer	back to summary
public DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor, Executor remoteUpdateExecutor)

DBMSSynchronizer	back to summary
pack-priv DBMSSynchronizer(@NonNull BibDatabaseContext bibDatabaseContext, Character keywordSeparator, FieldPreferences fieldPreferences, @NonNull GlobalCitationKeyPatterns globalCiteKeyPattern, FileUpdateMonitor fileMonitor, String userAndHost, TaskExecutor taskExecutor, Executor remoteUpdateExecutor, Executor syncExecutor, Path offlineChangesDirectory) Annotations @VisibleForTesting

Method Detail

applyMetaData	back to summary
public void applyMetaData() Applies the `MetaData` on all local and shared BibEntries.

applyRemoteChanges	back to summary
private void applyRemoteChanges(DBMSSynchronizer.RemoteChanges remoteChanges) Model thread

applyRemoteFieldChange	back to summary
public void applyRemoteFieldChange(FieldChange fieldChange) Applies a field change received from another client. Any state that does not exactly match the received change (content-less payload, unknown entry, diverged field value) falls back to pulling everything from the database.

applyRemoteMetaData	back to summary
private void applyRemoteMetaData(Map<String, String> sharedMetaData) Model thread

applySaveActions	back to summary
private boolean applySaveActions(BibEntry bibEntry) Returns:boolean whether a save action changed the entry

applySaveActionsToBufferedEntry	back to summary
private void applySaveActionsToBufferedEntry() Model thread: the save actions mutate the entry, which the database worker must not do. Only the flush queued from here includes them; a flush before a remote-triggered pull writes the entry as it is.

checkCurrentConnection back to summary

checkCurrentConnection	back to summary
private boolean checkCurrentConnection() Checks whether the current SQL connection is valid; a dead one takes the synchronizer offline. Returns:boolean `true` if the connection is valid, else `false`.

private boolean checkCurrentConnection()

Checks whether the current SQL connection is valid; a dead one takes the synchronizer offline.

Returns:boolean: true if the connection is valid, else false.

closeQuietly	back to summary
private static void closeQuietly(Connection connection)

closeSharedDatabase	back to summary
public void closeSharedDatabase() Implements org.jabref.logic.shared.DatabaseSynchronizer.closeSharedDatabase. Annotations @Override

closeSharedDatabase

back to summary

public void closeSharedDatabase()

Implements org.jabref.logic.shared.DatabaseSynchronizer.closeSharedDatabase.

Annotations

@Override

doApplyMetaData	back to summary
private void doApplyMetaData() Model thread: applies the save actions locally; the entries they changed are written afterwards.

doApplyRemoteFieldChange	back to summary
private void doApplyRemoteFieldChange(FieldChange fieldChange)

fetchRemoteChanges	back to summary
private DBMSSynchronizer.RemoteChanges fetchRemoteChanges() throws SQLException Database worker. Transfers only what differs: the id/version mapping plus the entries that are new or newer on the shared side.

getConnectionProperties	back to summary
public DatabaseConnectionProperties getConnectionProperties() Implements org.jabref.logic.shared.DatabaseSynchronizer.getConnectionProperties. Annotations @Override

getConnectionProperties

back to summary

public DatabaseConnectionProperties getConnectionProperties()

Implements org.jabref.logic.shared.DatabaseSynchronizer.getConnectionProperties.

Annotations

@Override

getDBName

back to summary

public String getDBName()

Implements org.jabref.logic.shared.DatabaseSynchronizer.getDBName.

Annotations

@Override

goOffline	back to summary
private void goOffline() Takes the synchronizer offline: from now on changes are recorded instead of written, and a scheduled task tries to get a new connection.

handleRemoteDatabaseChange	back to summary
public void handleRemoteDatabaseChange() Schedules a full synchronization requested by another shared-database client.

handleRemoteFieldChange	back to summary
public void handleRemoteFieldChange(FieldChange fieldChange) Schedules a field update received from another shared-database client.

handleRemoteMetaDataChange	back to summary
public void handleRemoteMetaDataChange() Schedules a metadata update received from another shared-database client.

handleWriteFailure	back to summary
private void handleWriteFailure(String message, SQLException exception, Runnable record) Database worker. A dead connection takes the synchronizer offline and the change is recorded for later; a failure on a live connection is transient and only reported (repeating that write would fail the same way).

ifNotPullingAlready

back to summary

private boolean ifNotPullingAlready(Runnable work)

Runs the given work only when no other thread is applying a pull right now.

Returns:boolean: whether the work ran

initializeDatabases back to summary

public void initializeDatabases() throws DatabaseNotSupportedException, SQLException

Sets the table structure of shared database if needed and pulls all shared entries to the new local database.

Exceptions

DatabaseNotSupportedException:: if the version of shared database does not match the version of current shared database support (DBMSProcessor).

insertSharedEntries

back to summary

private boolean insertSharedEntries(List<BibEntry> bibEntries)

Database worker

Returns:boolean: whether the entries reached the shared database

isEventSourceAccepted	back to summary
private static boolean isEventSourceAccepted(EntriesEvent event) Only local changes (and their undo) are written; changes applied from the shared side are not echoed back.

isPresentLocalBibEntry	back to summary
private boolean isPresentLocalBibEntry(BibEntry bibEntry)

listen back to summary

public void listen(EntriesAddedEvent event)

Listening method. Inserts a new BibEntry into shared database.

Annotations

@Subscribe

listen back to summary

public void listen(FieldChangedEvent event)

Listening method. Updates an existing shared BibEntry.

Annotations

@Subscribe

listen back to summary

public void listen(EntriesRemovedEvent event)

Listening method. Deletes the given list of BibEntry from shared database.

Annotations

@Subscribe

listen back to summary

public void listen(MetaDataChangedEvent event)

Listening method. Synchronizes the shared MetaData and applies them locally.

Annotations

@Subscribe

onlyUnchangedSharedEntries back to summary

private List<BibEntry> onlyUnchangedSharedEntries(List<BibEntry> entriesToRemove) throws SQLException

Database worker: the optimistic lock for a recorded removal, which DBMSProcessor#removeEntries cannot express. An entry another client changed during the outage is kept - the pull that ends the replay brings it back locally, rather than the collaborator losing their work.

Returns:List<BibEntry>: the entries whose shared version still is the one the removal was recorded against

openSharedDatabase

back to summary

public void openSharedDatabase(DatabaseConnection connection) throws DatabaseNotSupportedException, SQLException

Implements org.jabref.logic.shared.DatabaseSynchronizer.openSharedDatabase.

Annotations

@Override

overwriteLocalEntry	back to summary
private static void overwriteLocalEntry(BibEntry localEntry, BibEntry sharedEntry) Writes a pulled entry over the local one. Nothing is recorded: the change is not this user's to take back — see the class javadoc.

pullChanges

back to summary

public void pullChanges()

Implements org.jabref.logic.shared.DatabaseSynchronizer.pullChanges.

Synchronizes the local BibEntries and applies the fetched MetaData on them.

Annotations

@Override

pullEntries	back to summary
private void pullEntries() Brings the local entries up to date with the shared database: fetches on the database worker, applies on the model thread. A failed fetch leaves the local library as it is.

pullMetaData	back to summary
private void pullMetaData()

reconnect	back to summary
private void reconnect(long delayMillis)

registerListener

back to summary

public void registerListener(Object listener)

Implements org.jabref.logic.shared.DatabaseSynchronizer.registerListener.

Annotations

@Override

removeSharedEntries

back to summary

private boolean removeSharedEntries(List<BibEntry> bibEntries)

Database worker

Returns:boolean: whether the removal reached the shared database

replayOfflineChanges

back to summary

private boolean replayOfflineChanges(boolean afterRestart)

Writes the changes recorded while offline through the same paths as live changes: applied to the local library (model thread) where a restart lost them, then written (database worker) - a shared entry that moved on meanwhile refuses the write and the user merges, like any other conflict. Ends with a pull.

Every record is dropped only once it reached the shared database, so that closing, a crash or a refused write in between leaves it recorded for the next attempt.

Parameters

afterRestart:boolean: whether the local library was just loaded from the shared database and needs the recorded state restored - after a reconnect it holds the changes already, plus micro-edits made since the record

Returns:boolean

whether there was anything to replay

reviveEntriesDeletedMeanwhile back to summary

private void reviveEntriesDeletedMeanwhile(List<BibEntry> entriesToWrite, List<BibEntry> entriesToInsert)

Database worker: a shared row deleted during the outage must not take the changes recorded against it with it. Such an entry is re-inserted as a new shared entry instead of being updated - an update would fail with SharedEntryNotPresentException and pull the deletion, which removes the user's edited entry.

scheduleReconnect	back to summary
private void scheduleReconnect(long delayMillis) One attempt per scheduled task, so that waiting for the next one occupies no thread

setDBName

back to summary

public void setDBName(String dbName)

Implements org.jabref.logic.shared.DatabaseSynchronizer.setDBName.

Annotations

@Override

setMetaData	back to summary
public void setMetaData(MetaData metaData)

synchronizeLocalDatabase back to summary

public void synchronizeLocalDatabase()

Implements org.jabref.logic.shared.DatabaseSynchronizer.synchronizeLocalDatabase.

Synchronizes the local database with shared one. Possible update types are: removal, update, or insert of a BibEntry.

Annotations

@Override

synchronizeSharedEntry

back to summary

public void synchronizeSharedEntry(BibEntry bibEntry)

Implements org.jabref.logic.shared.DatabaseSynchronizer.synchronizeSharedEntry.

Writes the merged entry of a resolved conflict. The entry is a detached copy, so the save actions may run on the caller's thread.

Annotations

@Override

useConnection	back to summary
private void useConnection(DatabaseConnection newConnection) Database worker: replaces the dead connection, then synchronizes what happened meanwhile

withPullLock	back to summary
private void withPullLock(Runnable work)

writeBufferedEntry	back to summary
private void writeBufferedEntry() Database worker: writes the buffered micro-edited entry (if any) as a whole

writeOrRecord

back to summary

private boolean writeOrRecord(String failureMessage, DBMSSynchronizer.DatabaseWrite write, Runnable record)

Database worker: runs the write and asks other clients to pull, or records the change when the connection is gone

Returns:boolean: whether the write reached the shared database

writeRecordedMetaData	back to summary
private boolean writeRecordedMetaData(Map<String, String> recordedMetaData, OfflineChanges.Recorded recorded) Database worker: recorded metadata is merged into what the shared side has now, so that metadata other clients changed during the outage (a group they added, say) survives

writeSharedEntry

back to summary

private boolean writeSharedEntry(BibEntry bibEntry)

Database worker.

Returns:boolean: whether the entry reached the shared database - a refused or failed (and thus rolled back) update must not be announced to other clients

writeSharedMetaData	back to summary
private boolean writeSharedMetaData(Map<String, String> serializedMetaData) Database worker. Other clients are notified by the database function (see DBMSProcessor.setUp).

org.jabref.logic.shared back to summary

private Interface DBMSSynchronizer.DatabaseWrite

Annotations

@FunctionalInterface

Method Summary

Modifier and Type	Method and Description
public void	run()

Method Detail

run	back to summary
public void run() throws SQLException

org.jabref.logic.shared back to summary

private final Record DBMSSynchronizer.RemoteChanges

Class Inheritance

extends Record

java.lang.Object
java.lang.Record
org.jabref.logic.shared.DBMSSynchronizer.RemoteChanges

Record Components

removedIds:Set<Integer>
changedEntries:List<BibEntry>

What the shared database has that the local library has not. Determined on the database worker against the local ids as of the fetch, applied on the model thread.

Field Summary

Modifier and Type	Field and Description
private final List<BibEntry>	changedEntries Record Component accessed by changedEntries().
private final Set<Integer>	removedIds Record Component accessed by removedIds().

Constructor Summary

Access	Constructor and Description
private	RemoteChanges(Set<Integer> removedIds, List<BibEntry> changedEntries)

Method Summary

Modifier and Type	Method and Description
public List<BibEntry>	changedEntries() Record Component getter of changedEntries.
public final boolean	equals(Object o) Implements abstract java.lang.Record.equals. Indicates whether some other object is "equal to" this one.
public final int	hashCode() Implements abstract java.lang.Record.hashCode. Returns a hash code value for the record.
public Set<Integer>	removedIds() Record Component getter of removedIds.
public final String	toString() Implements abstract java.lang.Record.toString. Returns a string representation of the record.

Field Detail

changedEntries	back to summary
private final List<BibEntry> changedEntries Record Component accessed by changedEntries().

removedIds	back to summary
private final Set<Integer> removedIds Record Component accessed by removedIds().

Constructor Detail

RemoteChanges	back to summary
private RemoteChanges(Set<Integer> removedIds, List<BibEntry> changedEntries)

Method Detail

changedEntries	back to summary
public List<BibEntry> changedEntries() Record Component getter of changedEntries.

equals back to summary

public final boolean equals(Object o)

Implements abstract java.lang.Record.equals.

Doc from java.lang.Record.equals.

Indicates whether some other object is "equal to" this one. In addition to the general contract of Object.equals, record classes must further obey the invariant that when a record instance is "copied" by passing the result of the record component accessor methods to the canonical constructor, as follows:

    R copy = new R(r.c1(), r.c2(), ..., r.cn());

then it must be the case that r.equals(copy).

hashCode back to summary

public final int hashCode()

Implements abstract java.lang.Record.hashCode.

Doc from java.lang.Record.hashCode.

Returns a hash code value for the record. Obeys the general contract of Object.hashCode. For records, hashing behavior is constrained by the refined contract of Record.equals, so that any two records created from the same components must have the same hash code.

removedIds	back to summary
public Set<Integer> removedIds() Record Component getter of removedIds.

toString back to summary

public final String toString()

Implements abstract java.lang.Record.toString.

Doc from java.lang.Record.toString.

Returns a string representation of the record. In accordance with the general contract of Object#toString(), the toString method returns a string that "textually represents" this record. The result should be a concise but informative representation that is easy for a person to read.

In addition to this general contract, record classes must further participate in the invariant that any two records which are equal must produce equal strings. This invariant is necessarily relaxed in the rare case where corresponding equal component values might fail to produce equal strings for themselves.

public Class DBMSSynchronizer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Interface DBMSSynchronizer.DatabaseWrite

Method Summary

Method Detail

private final Record DBMSSynchronizer.RemoteChanges

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail