Package app.ductape.sdk.database.adapters

Class BaseAdapter

java.lang.Object

app.ductape.sdk.database.adapters.BaseAdapter

Direct Known Subclasses:

CassandraAdapter, CassandraDriverLiveAdapter, DynamoDBAdapter, DynamoDbDriverLiveAdapter, MariaDBAdapter, MongoDBAdapter, MongoDbDriverLiveAdapter, MySQLAdapter, MySqlJdbcLiveAdapter, PostgresJdbcLiveAdapter, PostgreSQLAdapter

public abstract class BaseAdapter
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	connected
protected Map<String,Object>	connectionOptions
protected String	connectionUrl
protected int	maxRetries

Constructor Summary

Constructors

Constructor	Description
BaseAdapter()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	aggregate(Map<String,Object> builtAggregation)	TS adapter.aggregate(builtAggregation) — runs built SQL/pipeline against in-memory rows.
protected void	attemptReconnect()
Map<String,Object>	beginTransaction(String isolationLevel, Boolean readOnly, Long timeout)	TS adapter.beginTransaction(isolationLevel, readOnly, timeout).
void	commitTransaction(Map<String,Object> context)
abstract Map<String,Object>	connect(Map<String,Object> options)
void	createIndex(Map<String,Object> index, Boolean ifNotExists, Boolean concurrent)	TS adapter.createIndex(index, ifNotExists, concurrent).
Map<String,Object>	createSavepoint(Map<String,Object> context, String name)
abstract void	createTable(String table, List<Map<String,Object>> columns)
protected abstract DatabaseType	databaseType()
abstract int	delete(String table, Map<String,Object> where)
abstract void	disconnect()
void	dropIndex(String table, String indexName, Boolean ifExists, Boolean concurrent, Boolean cascade)	TS adapter.dropIndex(table, indexName, ifExists, concurrent, cascade).
abstract void	dropTable(String table)
protected <T> T	executeWithRetry(Supplier<T> operation)
protected <T> T	executeWithRetry(Supplier<T> operation, int retries)
DatabaseType	getDatabaseType()	TS BaseAdapter.getDatabaseType().
List<Map<String,Object>>	getIndexStatistics(String table, String indexName)	TS adapter.getIndexStatistics(table, indexName?).
List<Map<String,Object>>	groupBy(Map<String,Object> builtGroupBy)	TS adapter.groupBy(builtGroupBy) — returns rows shaped as { group, aggregates }.
abstract int	insert(String table, List<Map<String,Object>> rows)
boolean	isConnected()
protected boolean	isConnectionError(Throwable error)
List<Map<String,Object>>	listIndexes(String table, Boolean includeSystem)	TS adapter.listIndexes(table, includeSystem).
abstract List<String>	listTables()
abstract List<Map<String,Object>>	query(String table, Map<String,Object> where, int limit, int offset)
Map<String,Object>	rawQuery(Map<String,Object> options)	TS adapter.rawQuery(options).
void	releaseSavepoint(Map<String,Object> context, String savepointName)
void	rollbackToSavepoint(Map<String,Object> context, String savepointName)
void	rollbackTransaction(Map<String,Object> context)
abstract Map<String,Object>	schema(String table)
boolean	supportsDeferrableTransactions()	TS feature check used by TransactionManager for deferrable transactions.
abstract boolean	tableExists(String table)
abstract Map<String,Object>	testConnection(Map<String,Object> options)
abstract int	update(String table, Map<String,Object> where, Map<String,Object> setValues)

Methods inherited from class java.lang.Object

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

Field Details

connected

protected boolean connected

connectionUrl

protected String connectionUrl

connectionOptions

protected Map<String,Object> connectionOptions

maxRetries

protected int maxRetries

Constructor Details

BaseAdapter

public BaseAdapter()

Method Details

databaseType

protected abstract DatabaseType databaseType()

isConnected

public boolean isConnected()

connect

public abstract Map<String,Object> connect(Map<String,Object> options)

testConnection

public abstract Map<String,Object> testConnection(Map<String,Object> options)

disconnect

public abstract void disconnect()

query

public abstract List<Map<String,Object>> query(String table,
 Map<String,Object> where,
 int limit,
 int offset)

insert

public abstract int insert(String table,
 List<Map<String,Object>> rows)

update

public abstract int update(String table,
 Map<String,Object> where,
 Map<String,Object> setValues)

delete

public abstract int delete(String table,
 Map<String,Object> where)

tableExists

public abstract boolean tableExists(String table)

listTables

public abstract List<String> listTables()

schema

public abstract Map<String,Object> schema(String table)

createTable

public abstract void createTable(String table,
 List<Map<String,Object>> columns)

dropTable

public abstract void dropTable(String table)

executeWithRetry

protected <T> T executeWithRetry(Supplier<T> operation)

executeWithRetry

protected <T> T executeWithRetry(Supplier<T> operation,
 int retries)

isConnectionError

protected boolean isConnectionError(Throwable error)

attemptReconnect

protected void attemptReconnect()

createIndex

public void createIndex(Map<String,Object> index,
 Boolean ifNotExists,
 Boolean concurrent)

TS adapter.createIndex(index, ifNotExists, concurrent). Default implementation is a no-op for in-memory adapters.

dropIndex

public void dropIndex(String table,
 String indexName,
 Boolean ifExists,
 Boolean concurrent,
 Boolean cascade)

TS adapter.dropIndex(table, indexName, ifExists, concurrent, cascade). Default implementation is a no-op for in-memory adapters.

listIndexes

public List<Map<String,Object>> listIndexes(String table,
 Boolean includeSystem)

TS adapter.listIndexes(table, includeSystem).

getIndexStatistics

public List<Map<String,Object>> getIndexStatistics(String table,
 String indexName)

TS adapter.getIndexStatistics(table, indexName?).

getDatabaseType

public DatabaseType getDatabaseType()

TS BaseAdapter.getDatabaseType().

aggregate

public Map<String,Object> aggregate(Map<String,Object> builtAggregation)

TS adapter.aggregate(builtAggregation) — runs built SQL/pipeline against in-memory rows.

groupBy

public List<Map<String,Object>> groupBy(Map<String,Object> builtGroupBy)

TS adapter.groupBy(builtGroupBy) — returns rows shaped as { group, aggregates }.

rawQuery

public Map<String,Object> rawQuery(Map<String,Object> options)

TS adapter.rawQuery(options). Default in-memory behavior supports object queries by delegating to query(java.lang.String, java.util.Map<java.lang.String, java.lang.Object>, int, int).

beginTransaction

public Map<String,Object> beginTransaction(String isolationLevel,
 Boolean readOnly,
 Long timeout)

TS adapter.beginTransaction(isolationLevel, readOnly, timeout). Default implementation provides a no-op context for in-memory adapters.

commitTransaction

public void commitTransaction(Map<String,Object> context)

rollbackTransaction

public void rollbackTransaction(Map<String,Object> context)

createSavepoint

public Map<String,Object> createSavepoint(Map<String,Object> context,
 String name)

releaseSavepoint

public void releaseSavepoint(Map<String,Object> context,
 String savepointName)

rollbackToSavepoint

public void rollbackToSavepoint(Map<String,Object> context,
 String savepointName)

supportsDeferrableTransactions

public boolean supportsDeferrableTransactions()

TS feature check used by TransactionManager for deferrable transactions.