Package org.bsc.langgraph4j.checkpoint

Class AbstractMysqlServer

java.lang.Object

org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

org.bsc.langgraph4j.checkpoint.AbstractMysqlServer

All Implemented Interfaces:

BaseCheckpointSaver

Direct Known Subclasses:

MysqlSaver

public abstract class AbstractMysqlServer
extends AbstractCheckpointSaver

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractMysqlServer.AbstractBuilder<B extends AbstractMysqlServer.AbstractBuilder<B>>	A builder for MysqlSaver.

Nested classes/interfaces inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

BaseCheckpointSaver.Tag

Field Summary

Fields

Modifier and Type	Field	Description
protected final CreateOption	createOption
protected final DataSource	dataSource
protected final com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Fields inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

THREAD_ID_DEFAULT

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractMysqlServer(AbstractMysqlServer.AbstractBuilder<?> builder)	protected constructor used by the builder to create a new instance of MysqlSaver.

Method Summary

Modifier and Type	Method	Description
Collection<Checkpoint>	clearCheckpointsCache(String threadId)	Deprecated, for removal: This API element is subject to removal in a future version. this method do nothing because currently this saver don't use cache anymore
protected void	initTables()	Initializes the database according the create options.
protected void	insertedCheckpoint(RunnableConfig config, LinkedList<Checkpoint> checkpoints, Checkpoint checkpoint)	Inserts a checkpoint to the database
protected LinkedList<Checkpoint>	loadCheckpoints(RunnableConfig config)	If the list of checkpoints is empty, loads the checkpoints from the database.
protected BaseCheckpointSaver.Tag	releaseCheckpoints(RunnableConfig config, LinkedList<Checkpoint> checkpoints)	Marks the checkpoints as released
protected void	updatedCheckpoint(RunnableConfig config, LinkedList<Checkpoint> checkpoints, Checkpoint checkpoint)	If the checkpoint exists, updates the checkpoint, otherwise it inserts it.

Methods inherited from class org.bsc.langgraph4j.checkpoint.AbstractCheckpointSaver

get, list, put, release

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.bsc.langgraph4j.checkpoint.BaseCheckpointSaver

threadId

Field Details

dataSource

protected final DataSource dataSource

createOption

protected final CreateOption createOption

objectMapper

protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Details

AbstractMysqlServer

protected AbstractMysqlServer(AbstractMysqlServer.AbstractBuilder<?> builder)

protected constructor used by the builder to create a new instance of MysqlSaver.

Parameters:

builder - Builder instance

Method Details

loadCheckpoints

protected LinkedList<Checkpoint> loadCheckpoints(RunnableConfig config)
                                          throws Exception

If the list of checkpoints is empty, loads the checkpoints from the database.

Specified by:

loadCheckpoints in class AbstractCheckpointSaver

Parameters:

config - the configuration

Returns:

a list of checkpoints

Throws:

Exception - if an error occurs while the checkpoints are being loaded from the database.

insertedCheckpoint

protected void insertedCheckpoint(RunnableConfig config,
 LinkedList<Checkpoint> checkpoints,
 Checkpoint checkpoint)
                           throws Exception

Inserts a checkpoint to the database

Specified by:

insertedCheckpoint in class AbstractCheckpointSaver

Parameters:

config - the configuration

checkpoints - the list of checkpoints

checkpoint - the checkpoint to insert

Throws:

Exception - if an error occurs while inserting the checkpoint in the database.

releaseCheckpoints

protected BaseCheckpointSaver.Tag releaseCheckpoints(RunnableConfig config,
 LinkedList<Checkpoint> checkpoints)
                                              throws Exception

Marks the checkpoints as released

Specified by:

releaseCheckpoints in class AbstractCheckpointSaver

Parameters:

config - the configuration

checkpoints - the checkpoints

Throws:

Exception - if an error occurs while marking the checkpoints as released

updatedCheckpoint

protected void updatedCheckpoint(RunnableConfig config,
 LinkedList<Checkpoint> checkpoints,
 Checkpoint checkpoint)
                          throws Exception

If the checkpoint exists, updates the checkpoint, otherwise it inserts it.

Specified by:

updatedCheckpoint in class AbstractCheckpointSaver

Parameters:

config - the configuration

checkpoints - the list of checkpoints

checkpoint - the checkpoint

Throws:

Exception - if an error occurs while inserting or updating the checkpoint.

initTables

protected void initTables()

Initializes the database according the create options.

clearCheckpointsCache

@Deprecated(forRemoval=true)
public Collection<Checkpoint> clearCheckpointsCache(String threadId)

Deprecated, for removal: This API element is subject to removal in a future version.

this method do nothing because currently this saver don't use cache anymore

Removes the cached checkpoints associated with the given thread identifier from the in-memory cache.

Parameters:

threadId - the thread identifier whose cached checkpoints must be cleared

Returns:

the checkpoints removed from the cache, or an empty collection if no cached checkpoints exist