Package org.gridgain.cache.store.jdbc

Class MariaDbCacheStoreFactory

java.lang.Object

org.gridgain.cache.store.jdbc.JdbcCacheStoreFactory

org.gridgain.cache.store.jdbc.MariaDbCacheStoreFactory

All Implemented Interfaces:

CacheStoreFactory

public class MariaDbCacheStoreFactory
extends JdbcCacheStoreFactory

Factory producing a MariaDbCacheStore preconfigured with MariaDbDialect. For dialect-agnostic configuration, JdbcCacheStoreFactory combined with setDialect(new MariaDbDialect()) is the standard alternative.

Field Summary

Fields inherited from class org.gridgain.cache.store.jdbc.JdbcCacheStoreFactory

DFLT_BATCH_SIZE, DFLT_PARALLEL_LOAD_CACHE_MINIMUM_THRESHOLD, DFLT_WRITE_ATTEMPTS

Constructor Summary

Constructors

Constructor	Description
MariaDbCacheStoreFactory()	Constructor.

Method Summary

Modifier and Type	Method	Description
protected <K, V> JdbcCacheStore<K,V>	createStore(Class<K> keyCls, Class<V> valCls)	Creates the store instance that JdbcCacheStoreFactory.create(Class, Class) then configures.
int	getFetchSize()	Gets the fetch size passed to JDBC Statement.setFetchSize for load cache queries.
MariaDbCacheStoreFactory	setBatchSize(int batchSize)	Set maximum batch size for write and delete operations.
MariaDbCacheStoreFactory	setDataSource(DataSource dataSrc)	Sets data source.
MariaDbCacheStoreFactory	setDialect(JdbcDialect dialect)	Set database dialect.
MariaDbCacheStoreFactory	setExecutor(ExecutorService executor)	Sets the executor for accessing the database.
MariaDbCacheStoreFactory	setFetchSize(int fetchSize)	Sets the fetch size passed to JDBC Statement.setFetchSize for load cache queries, replacing the installed dialect.
MariaDbCacheStoreFactory	setMaximumWriteAttempts(int maxWrtAttempts)	Sets maximum number of write attempts in case of database error.
MariaDbCacheStoreFactory	setParallelLoadCacheMinimumThreshold(int parallelLoadCacheMinThreshold)	Parallel load cache minimum row count threshold.
MariaDbCacheStoreFactory	setSqlEscapeAll(boolean sqlEscapeAll)	If true all the SQL table and field names will be escaped with double quotes like ("tableName"."fieldsName").
MariaDbCacheStoreFactory	setTransformer(JdbcTypesTransformer transformer)	Sets types transformer.
MariaDbCacheStoreFactory	setType(JdbcType type)	Sets store configurations.
String	toString()

Methods inherited from class org.gridgain.cache.store.jdbc.JdbcCacheStoreFactory

create, getBatchSize, getDataSource, getDialect, getExecutor, getMaximumWriteAttempts, getParallelLoadCacheMinimumThreshold, getTransformer, getType, isSqlEscapeAll

Methods inherited from class java.lang.Object

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

Constructor Details

MariaDbCacheStoreFactory

public MariaDbCacheStoreFactory()

Constructor.

Method Details

getFetchSize

public int getFetchSize()

Gets the fetch size passed to JDBC Statement.setFetchSize for load cache queries.

Returns:

Fetch size.

setFetchSize

public MariaDbCacheStoreFactory setFetchSize(int fetchSize)

Sets the fetch size passed to JDBC Statement.setFetchSize for load cache queries, replacing the installed dialect.

Parameters:

fetchSize - Fetch size.

Returns:

This for chaining.

setDataSource

public MariaDbCacheStoreFactory setDataSource(DataSource dataSrc)

Sets data source. Data source should be fully configured and ready-to-use.

Overrides:

setDataSource in class JdbcCacheStoreFactory

Parameters:

dataSrc - Data source.

Returns:

This for chaining.

createStore

protected <K,
V> JdbcCacheStore<K,V> createStore(Class<K> keyCls,
 Class<V> valCls)

Creates the store instance that JdbcCacheStoreFactory.create(Class, Class) then configures.

Overrides:

createStore in class JdbcCacheStoreFactory

Type Parameters:

K - Key type.

V - Value type.

Parameters:

keyCls - Key class.

valCls - Value class.

Returns:

Unconfigured store.

setExecutor

public MariaDbCacheStoreFactory setExecutor(ExecutorService executor)

Sets the executor for accessing the database. By default ForkJoinPool.commonPool() executor is used.

Thread safety note: it's possible to run into deadlock issue then using a connection pool if a number of user threads accessing cache store is larger than underlying pool size. To mitigate this issue make sure the executor's pool size is large enough, or use a single-threaded executor. This is the safest option.

Overrides:

setExecutor in class JdbcCacheStoreFactory

Parameters:

executor - The executor.

Returns:

This for chaining.

setBatchSize

public MariaDbCacheStoreFactory setBatchSize(int batchSize)

Set maximum batch size for write and delete operations.

Overrides:

setBatchSize in class JdbcCacheStoreFactory

Parameters:

batchSize - Maximum batch size.

Returns:

This for chaining.

setDialect

public MariaDbCacheStoreFactory setDialect(JdbcDialect dialect)

Set database dialect.

Overrides:

setDialect in class JdbcCacheStoreFactory

Parameters:

dialect - Database dialect.

Returns:

This for chaining.

setMaximumWriteAttempts

public MariaDbCacheStoreFactory setMaximumWriteAttempts(int maxWrtAttempts)

Sets maximum number of write attempts in case of database error.

Overrides:

setMaximumWriteAttempts in class JdbcCacheStoreFactory

Parameters:

maxWrtAttempts - Number of write attempts.

Returns:

This for chaining.

setParallelLoadCacheMinimumThreshold

public MariaDbCacheStoreFactory setParallelLoadCacheMinimumThreshold(int parallelLoadCacheMinThreshold)

Parallel load cache minimum row count threshold.

Overrides:

setParallelLoadCacheMinimumThreshold in class JdbcCacheStoreFactory

Parameters:

parallelLoadCacheMinThreshold - Minimum row count threshold. If 0 then load sequentially.

Returns:

This for chaining.

setType

public MariaDbCacheStoreFactory setType(JdbcType type)

Sets store configurations.

Overrides:

setType in class JdbcCacheStoreFactory

Parameters:

type - Store should process.

Returns:

This for chaining.

setTransformer

public MariaDbCacheStoreFactory setTransformer(JdbcTypesTransformer transformer)

Sets types transformer.

Overrides:

setTransformer in class JdbcCacheStoreFactory

Parameters:

transformer - Types transformer.

Returns:

This for chaining.

setSqlEscapeAll

public MariaDbCacheStoreFactory setSqlEscapeAll(boolean sqlEscapeAll)

If true all the SQL table and field names will be escaped with double quotes like ("tableName"."fieldsName"). This enforces case sensitivity for field names and also allows having special characters in table and field names.

Overrides:

setSqlEscapeAll in class JdbcCacheStoreFactory

Parameters:

sqlEscapeAll - Flag value.

Returns:

this for chaining.

toString

public String toString()

Overrides:

toString in class JdbcCacheStoreFactory