类class io.agentscope.extensions.jdbc.dialect.vendor 2.x

MysqlDialect

public class MysqlDialect extends AbstractJdbcDialect

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:46–272

MySQL Dialect，在多次调用之间保存和恢复会话与记忆数据。位于 io.agentscope.extensions.jdbc.dialect.vendor 包，继承自 AbstractJdbcDialect。核心成员包括 storeCreateTableDdls、storeUpsert、sessionStateCreateTableDdls、sessionStateUpsert、sessionStateCheckTableExists、snapshotCreateTableDdls。

MySQL / MariaDB dialect.

Overrides DDL (LONGTEXT, ENGINE=InnoDB, utf8mb4), UPSERT syntax (ON DUPLICATE KEY UPDATE), table-existence check (DATABASE()), and lock acquisition (GET_LOCK / RELEASE_LOCK). All other business SQL inherits ANSI defaults.

方法摘要Method Summary

方法Method	说明Description
`public List<String> storeCreateTableDdls()`	返回 `storeCreateTableDdls` 结果。 Returns the store create table ddls.
`public` `BoundSql storeUpsert(String namespacePath, String key, String json, long timestamp)`	执行 `storeUpsert` 方法。 Performs the store upsert operation.
`public List<String> sessionStateCreateTableDdls()`	返回 `sessionStateCreateTableDdls` 结果。 Returns the session state create table ddls.
`public` `BoundSql sessionStateUpsert(String sessionId, String stateKey, int itemIndex, String stateData)`	执行 `sessionStateUpsert` 方法。 Performs the session state upsert operation.
`public` `BoundSql sessionStateCheckTableExists(String tableName)`	设置该参数。 Performs the session state check table exists operation.
`public List<String> snapshotCreateTableDdls()`	返回 `snapshotCreateTableDdls` 结果。 Returns the snapshot create table ddls.
`public` `BoundSql snapshotUpsert(String snapshotId, InputStream data)`	执行 `snapshotUpsert` 方法。 Performs the snapshot upsert operation.
`public` `SandboxLease tryEnter(String lockName, int timeoutSeconds) throws InterruptedException`	执行 `tryEnter` 方法。 Performs the try enter operation.
`public boolean supports(DatabaseMetaData metaData) throws SQLException`	设置支持。 Performs the supports operation.

方法详情Method Detail

storeCreateTableDdls

public List<String> storeCreateTableDdls()

返回 storeCreateTableDdls 结果。

Returns the store create table ddls.

返回Returns List<String>

返回列出。Returns list.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:65–81

storeUpsert

public BoundSql storeUpsert(String namespacePath, String key, String json, long timestamp)

执行 storeUpsert 方法。

Performs the store upsert operation.

参数Parameters

名称Name	类型Type	说明Description
`namespacePath`	String	命名空间路径（类型 `String`）。The namespace path.
`key`	String	键（类型 `String`）。The key.
`json`	String	JSON（类型 `String`）。The json.
`timestamp`	long	时间戳（类型 `long`）。The timestamp.

返回Returns BoundSql

返回BoundSql。Returns bound sql.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:83–98

sessionStateCreateTableDdls

public List<String> sessionStateCreateTableDdls()

返回 sessionStateCreateTableDdls 结果。

Returns the session state create table ddls.

返回Returns List<String>

返回列出。Returns list.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:104–121

sessionStateUpsert

public BoundSql sessionStateUpsert(String sessionId, String stateKey, int itemIndex, String stateData)

执行 sessionStateUpsert 方法。

Performs the session state upsert operation.

参数Parameters

名称Name	类型Type	说明Description
`sessionId`	String	会话标识（类型 `String`）。The session id.
`stateKey`	String	状态键（类型 `String`）。The state key.
`itemIndex`	int	条目索引（类型 `int`）。The item index.
`stateData`	String	状态数据（类型 `String`）。The state data.

返回Returns BoundSql

返回BoundSql。Returns bound sql.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:123–137

sessionStateCheckTableExists

public BoundSql sessionStateCheckTableExists(String tableName)

设置该参数。

Performs the session state check table exists operation.

参数Parameters

名称Name	类型Type	说明Description
`tableName`	String	table 名称（类型 `String`）。The table name.

返回Returns BoundSql

返回BoundSql。Returns bound sql.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:139–145

snapshotCreateTableDdls

public List<String> snapshotCreateTableDdls()

返回 snapshotCreateTableDdls 结果。

Returns the snapshot create table ddls.

返回Returns List<String>

返回列出。Returns list.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:151–161

snapshotUpsert

public BoundSql snapshotUpsert(String snapshotId, InputStream data)

执行 snapshotUpsert 方法。

Performs the snapshot upsert operation.

参数Parameters

名称Name	类型Type	说明Description
`snapshotId`	String	快照标识（类型 `String`）。The snapshot id.
`data`	InputStream	数据（类型 `InputStream`）。The data.

返回Returns BoundSql

返回BoundSql。Returns bound sql.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:163–174

tryEnter

public SandboxLease tryEnter(String lockName, int timeoutSeconds) throws InterruptedException

执行 tryEnter 方法。

Performs the try enter operation.

参数Parameters

名称Name	类型Type	说明Description
`lockName`	String	锁名称（类型 `String`）。The lock name.
`timeoutSeconds`	int	超时秒（类型 `int`）。The timeout seconds.

返回Returns SandboxLease

返回SandboxLease。Returns sandbox lease.

抛出Throws

InterruptedException 可能抛出 `InterruptedException`。Thrown when the operation cannot be completed.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:180–212

supports

public boolean supports(DatabaseMetaData metaData) throws SQLException

设置支持。

Performs the supports operation.

参数Parameters

名称Name	类型Type	说明Description
`metaData`	DatabaseMetaData	元数据（类型 `DatabaseMetaData`）。The meta data.

返回Returns boolean

返回布尔值，表示判断结果。Returns a boolean result.

抛出Throws

SQLException 可能抛出 `SQLException`。Thrown when the operation cannot be completed.

源码Source io/agentscope/extensions/jdbc/dialect/vendor/MysqlDialect.java:267–271

继承成员Inherited Members

继承自Methods inherited from AbstractJdbcDialect

storeTableName, sessionStateTableName, snapshotTableName, createTableDdls, bindDataSource, getDataSource, closeConnection, closeStatement, closeResultSet, getOrder, lockTableName, from

继承自Methods inherited from StoreDialect

storeInsert, storeCasUpdate, storeSelect, storeDelete, storeSearch, storeLikeEscapeChar

继承自Methods inherited from SessionStateDialect

sessionStateInsert, sessionStateInsertIfAbsent, sessionStateUpdateIfVersion, sessionStateSelect, sessionStateSelectVersioned, sessionStateSelectList, sessionStateDeleteByKey, sessionStateDeleteSession, sessionStateSelectMaxIndex, sessionStateExists, sessionStateListSessionIds, sessionStateLikeEscapeChar

继承自Methods inherited from SnapshotDialect

snapshotSelect, snapshotExists