Package app.ductape.sdk.database

Class DatabaseService

java.lang.Object

app.ductape.sdk.database.DatabaseService

public class DatabaseService
extends Object

Constructor Summary

Constructors

Constructor	Description
DatabaseService(EnvType env, RequestContext auth)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	addConstraint(Map<String,Object> options)
Map<String,Object>	addField(Map<String,Object> options)
Map<String,Object>	aggregate(AggregationTypes.AggregateOptions options)	TS DatabaseService.aggregate — uses AggregationBuilder.buildAggregation(app.ductape.sdk.database.types.AggregationTypes.AggregateOptions) then BaseAdapter.aggregate(java.util.Map<java.lang.String, java.lang.Object>).
Map<String,Object>	aggregate(Map<String,Object> options)	TS aggregate(IAggregateOptions) when options contains operations.
void	alterTable(Map<String,Object> options)
Number	avg(Map<String,Object> options)
TransactionTypes.Transaction	beginTransaction(TransactionTypes.TransactionOptions options)	TS beginTransaction(ITransactionOptions).
TransactionTypes.Transaction	beginTransaction(Map<String,Object> options)	Map-based overload for parity with existing Java map API style.
void	closeAll()
DatabaseConnection	connect(ConnectionTypes.ConnectionConfig config)	TS-style connection object facade (DatabaseConnection).
Map<String,Object>	connect(Map<String,Object> config)
DatabaseConnection	connectScoped(Map<String,Object> config)	Map-based variant returning scoped facade while preserving existing connect(Map) behavior.
Number	count(Map<String,Object> options)
void	create(Map<String,Object> config)	TS DatabaseService.create: persist database component with cloud-linked env materialization.
void	createAction(Map<String,Object> options)
Map<String,Object>	createCollection(Map<String,Object> options)
void	createIndex(Map<String,Object> options)
void	createMigration(String productId, Map<String,Object> data)	TS createMigration.
void	createMigration(String productId, Map<String,Object> data, boolean throwErrorIfExists)
void	createTable(Map<String,Object> options)
void	createTrigger(String productId, Map<String,Object> data)	TS DatabaseService.createTrigger → product API (component: database_trigger, action: create).
void	createTrigger(String productId, Map<String,Object> data, boolean throwErrorIfExists)
Map<String,Object>	delete(WriteTypes.DeleteOptions options)
Map<String,Object>	delete(Map<String,Object> options)
void	deleteAction(String tag)
void	deleteMigration(String productId, String compositeTag)	TS deleteMigration.
void	deleteTrigger(String productId, String compositeTag)	TS DatabaseService.deleteTrigger.
void	disconnect()
Map<String,Object>	dispatch(Map<String,Object> data)
Map<String,Object>	dispatchAction(Map<String,Object> data)	TS parity for database.action.dispatch: schedule database action events.
Map<String,Object>	dropCollection(Map<String,Object> options)
Map<String,Object>	dropConstraint(Map<String,Object> options)
Map<String,Object>	dropField(Map<String,Object> options)
void	dropIndex(Map<String,Object> options)
void	dropTable(Map<String,Object> options)
Map<String,Object>	executeAction(Map<String,Object> options)
List<TriggerTypes.TriggerResult>	executeTriggers(TriggerTypes.TriggerEvent event, TriggerTypes.TriggerContext context)	TS DatabaseConnection.triggers.execute with a fully built context.
List<TriggerTypes.TriggerResult>	executeTriggers(TriggerTypes.TriggerEvent event, Map<String,Object> connectionOptions, Map<String,Object> partialContext)	TS DatabaseConnection.triggers.execute — supplies database and env (and product) from connection-scoped options, like connection._database / connection._env in TypeScript.
Map<String,Object>	fetch(String product, String database)
Map<String,Object>	fetchAction(String tag)
List<Map<String,Object>>	fetchActions(String tag)
List<Map<String,Object>>	fetchAll(String product)
List<Map<String,Object>>	fetchAllDatabases(String productTag)
Map<String,Object>	fetchConfig(String productTag, String databaseTag)
List<Map<String,Object>>	fetchConfigs(String productTag)
Map<String,Object>	fetchDashboard(Map<String,Object> options)
Map<String,Object>	fetchDatabase(String productTag, String databaseTag)
Map<String,Object>	fetchMigration(String productId, String compositeTag)	TS fetchMigration; composite tag format: database_tag:migration_tag.
List<Map<String,Object>>	fetchMigrations(String productId, String databaseTag)	TS fetchMigrations.
protected Map<String,Object>	fetchPersistedActionForExecute(String product, String database, String action)
Map<String,Object>	fetchTrigger(String productId, String compositeTag)	TS DatabaseService.fetchTrigger; tag is database_tag:trigger_tag.
List<Map<String,Object>>	fetchTriggers(String productId, String databaseTag)	TS DatabaseService.fetchTriggers.
BaseAdapter	getAdapterByContextKey(String contextKey)	TS getAdapterByContextKey used by DatabaseConnection.getAdapter().
Map<String,Object>	getCollectionInfo(Map<String,Object> options)
Map<String,Object>	getCurrentContext()
String	getEnvType()
List<Map<String,Object>>	getIndexStatistics(Map<String,Object> options)
List<Map<String,Object>>	getMigrationHistory()
Map<String,Object>	getMigrationStatus(Map<String,Object> options)
Map<String,Object>	getSchemaSnapshot(String productTag, String env, String databaseTag)
Map<String,Object>	getSchemaSnapshot(Map<String,Object> options)
Map<String,Object>	getTableSchema(Map<String,Object> options)
String	getToken()
TriggerProcessor	getTriggerProcessor()	Session + persisted trigger registry (TriggerTypes.TriggerManager).
List<TriggerTypes.TriggerDefinition>	getTriggersForEvent(String table, TriggerTypes.TriggerEvent event)	TS DatabaseConnection.triggers.getTriggersForEvent.
String	getUserId()
String	getWorkspaceId()
List<Map<String,Object>>	groupBy(AggregationTypes.GroupByOptions options)	TS DatabaseService.groupBy.
List<Map<String,Object>>	groupBy(Map<String,Object> options)	TS groupBy(IGroupByOptions).
Map<String,Object>	insert(WriteTypes.InsertOptions options)
Map<String,Object>	insert(Map<String,Object> options)
void	installDatabaseTriggerActionRunner()	TS TriggerProcessor.setDuctapeInstance equivalent: route database.* trigger actions to this service’s insert(app.ductape.sdk.database.types.WriteTypes.InsertOptions), update(app.ductape.sdk.database.types.WriteTypes.UpdateOptions), delete(app.ductape.sdk.database.types.WriteTypes.DeleteOptions), query(app.ductape.sdk.database.types.QueryTypes.QueryOptions) using product/database/env from the trigger TriggerTypes.TriggerContext.
List<Map<String,Object>>	listIndexes(Map<String,Object> options)
List<String>	listTables(Map<String,Object> options)
List<Map<String,Object>>	listTablesWithInfo(Map<String,Object> options)
void	loadTriggersFromBackend(String productId, String databaseTag)	TS DatabaseConnection.triggers.load: pull triggers from the product payload and register them on getTriggerProcessor().
Object	max(Map<String,Object> options)
Object	min(Map<String,Object> options)
Map<String,Object>	modifyField(Map<String,Object> options)
Map<String,Object>	query(QueryTypes.QueryOptions options)
Map<String,Object>	query(Map<String,Object> options)
Map<String,Object>	queryStats(Map<String,Object> options)	Local multi-metric helper; TS exposes count/sum/… separately — not one combined call.
Map<String,Object>	raw(QueryTypes.RawQueryOptions options)	TS raw(IRawQueryOptions).
Map<String,Object>	raw(Map<String,Object> options)	TS raw(IRawQueryOptions) map variant.
void	registerDatabase(String productTag, Map<String,Object> data)
void	registerTrigger(String table, TriggerTypes.TriggerDefinition definition)	TS DatabaseConnection.triggers.register: in-memory session trigger for this service.
void	registerTriggers(List<TriggerProcessor.TableTrigger> rows)	TS DatabaseConnection.triggers.registerAll.
Map<String,Object>	renameCollection(Map<String,Object> options)
Map<String,Object>	renameField(Map<String,Object> options)
Map<String,Object>	rollbackMigration(Map<String,Object> options)
Map<String,Object>	runMigration(Map<String,Object> options)
void	setCloudApiService(CloudApiService cloudApiService)	TS parity: setting a CloudApiService enables runtime credential resolution (ResolveCloudLinkedEnvConfig-equivalent) for cloud_connection-authMode databases right before the adapter connects — refreshes ephemeral credentials and detects VPC connector tunnel mode (mirrors TS databases.service.ts).
void	setLogApiService(LogApiService logApiService)	TS parity: setting a LogApiService enables structured connect-log emission (Database connect - initiated/success/failed) with the CONNECT_LOG_DEBOUNCE_MS (15s) suppression window.
void	setRuntimeDefaults(RuntimeDefaults runtimeDefaults)
Number	sum(Map<String,Object> options)
boolean	tableExists(Map<String,Object> options)
Map<String,Object>	testConnection(Map<String,Object> config)
<T> T	transaction(TransactionTypes.TransactionOptions options, TransactionTypes.TransactionCallback<T> callback)	TS transaction(options, callback) callback flow with auto-commit/rollback.
<T> T	transaction(Map<String,Object> options, TransactionTypes.TransactionCallback<T> callback)
boolean	unregisterTrigger(String table, String triggerName)	TS DatabaseConnection.triggers.unregister.
Map<String,Object>	update(WriteTypes.UpdateOptions options)
Map<String,Object>	update(Map<String,Object> options)
void	updateAction(Map<String,Object> options)
void	updateConfig(Map<String,Object> config)
void	updateDatabase(String productTag, String databaseTag, Map<String,Object> data)
void	updateLocalConfig(String tag, Map<String,Object> updates)
void	updateMigration(String productId, Map<String,Object> data)	TS updateMigration.
void	updateTrigger(String productId, Map<String,Object> data)	TS DatabaseService.updateTrigger.
Map<String,Object>	upsert(WriteTypes.UpsertOptions options)
Map<String,Object>	upsert(Map<String,Object> options)

Methods inherited from class java.lang.Object

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

Constructor Details

DatabaseService

public DatabaseService(EnvType env,
 RequestContext auth)

Method Details

setLogApiService

public void setLogApiService(LogApiService logApiService)

TS parity: setting a LogApiService enables structured connect-log emission (Database connect - initiated/success/failed) with the CONNECT_LOG_DEBOUNCE_MS (15s) suppression window.

setCloudApiService

public void setCloudApiService(CloudApiService cloudApiService)

TS parity: setting a CloudApiService enables runtime credential resolution (ResolveCloudLinkedEnvConfig-equivalent) for cloud_connection-authMode databases right before the adapter connects — refreshes ephemeral credentials and detects VPC connector tunnel mode (mirrors TS databases.service.ts).

setRuntimeDefaults

public void setRuntimeDefaults(RuntimeDefaults runtimeDefaults)

updateConfig

public void updateConfig(Map<String,Object> config)

getWorkspaceId

public String getWorkspaceId()

getUserId

public String getUserId()

getToken

public String getToken()

getEnvType

public String getEnvType()

create

public void create(Map<String,Object> config)

TS DatabaseService.create: persist database component with cloud-linked env materialization.

registerDatabase

public void registerDatabase(String productTag,
 Map<String,Object> data)

fetchConfigs

public List<Map<String,Object>> fetchConfigs(String productTag)

fetchConfig

public Map<String,Object> fetchConfig(String productTag,
 String databaseTag)

fetchAllDatabases

public List<Map<String,Object>> fetchAllDatabases(String productTag)

fetchDatabase

public Map<String,Object> fetchDatabase(String productTag,
 String databaseTag)

updateDatabase

public void updateDatabase(String productTag,
 String databaseTag,
 Map<String,Object> data)

connect

public Map<String,Object> connect(Map<String,Object> config)

connect

public DatabaseConnection connect(ConnectionTypes.ConnectionConfig config)

TS-style connection object facade (DatabaseConnection).

connectScoped

public DatabaseConnection connectScoped(Map<String,Object> config)

Map-based variant returning scoped facade while preserving existing connect(Map) behavior.

testConnection

public Map<String,Object> testConnection(Map<String,Object> config)

disconnect

public void disconnect()

closeAll

public void closeAll()

fetchAll

public List<Map<String,Object>> fetchAll(String product)

fetch

public Map<String,Object> fetch(String product,
 String database)

updateLocalConfig

public void updateLocalConfig(String tag,
 Map<String,Object> updates)

query

public Map<String,Object> query(QueryTypes.QueryOptions options)

query

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

raw

public Map<String,Object> raw(QueryTypes.RawQueryOptions options)

TS raw(IRawQueryOptions).

raw

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

TS raw(IRawQueryOptions) map variant.

insert

public Map<String,Object> insert(WriteTypes.InsertOptions options)

insert

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

update

public Map<String,Object> update(WriteTypes.UpdateOptions options)

update

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

delete

public Map<String,Object> delete(WriteTypes.DeleteOptions options)

delete

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

upsert

public Map<String,Object> upsert(WriteTypes.UpsertOptions options)

upsert

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

count

public Number count(Map<String,Object> options)

sum

public Number sum(Map<String,Object> options)

avg

public Number avg(Map<String,Object> options)

min

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

max

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

aggregate

public Map<String,Object> aggregate(AggregationTypes.AggregateOptions options)

TS DatabaseService.aggregate — uses AggregationBuilder.buildAggregation(app.ductape.sdk.database.types.AggregationTypes.AggregateOptions) then BaseAdapter.aggregate(java.util.Map<java.lang.String, java.lang.Object>).

aggregate

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

TS aggregate(IAggregateOptions) when options contains operations. If operations is absent, delegates to queryStats(Map) (local convenience, not a single TS method).

queryStats

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

Local multi-metric helper; TS exposes count/sum/… separately — not one combined call.

groupBy

public List<Map<String,Object>> groupBy(AggregationTypes.GroupByOptions options)

TS DatabaseService.groupBy.

groupBy

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

TS groupBy(IGroupByOptions).

beginTransaction

public TransactionTypes.Transaction beginTransaction(TransactionTypes.TransactionOptions options)

TS beginTransaction(ITransactionOptions).

beginTransaction

public TransactionTypes.Transaction beginTransaction(Map<String,Object> options)

Map-based overload for parity with existing Java map API style.

transaction

public <T> T transaction(TransactionTypes.TransactionOptions options,
 TransactionTypes.TransactionCallback<T> callback)
                  throws Exception

TS transaction(options, callback) callback flow with auto-commit/rollback.

Throws:

Exception

transaction

public <T> T transaction(Map<String,Object> options,
 TransactionTypes.TransactionCallback<T> callback)
                  throws Exception

Throws:

Exception

createTable

public void createTable(Map<String,Object> options)

alterTable

public void alterTable(Map<String,Object> options)

dropTable

public void dropTable(Map<String,Object> options)

listTables

public List<String> listTables(Map<String,Object> options)

listTablesWithInfo

public List<Map<String,Object>> listTablesWithInfo(Map<String,Object> options)

tableExists

public boolean tableExists(Map<String,Object> options)

getTableSchema

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

getCollectionInfo

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

createCollection

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

dropCollection

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

renameCollection

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

addField

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

dropField

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

renameField

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

modifyField

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

addConstraint

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

dropConstraint

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

createIndex

public void createIndex(Map<String,Object> options)

dropIndex

public void dropIndex(Map<String,Object> options)

listIndexes

public List<Map<String,Object>> listIndexes(Map<String,Object> options)

getIndexStatistics

public List<Map<String,Object>> getIndexStatistics(Map<String,Object> options)

getSchemaSnapshot

public Map<String,Object> getSchemaSnapshot(String productTag,
 String env,
 String databaseTag)

getSchemaSnapshot

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

runMigration

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

rollbackMigration

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

getMigrationHistory

public List<Map<String,Object>> getMigrationHistory()

getMigrationStatus

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

dispatch

public Map<String,Object> dispatch(Map<String,Object> data)

dispatchAction

public Map<String,Object> dispatchAction(Map<String,Object> data)

TS parity for database.action.dispatch: schedule database action events.

createAction

public void createAction(Map<String,Object> options)

updateAction

public void updateAction(Map<String,Object> options)

fetchAction

public Map<String,Object> fetchAction(String tag)

fetchActions

public List<Map<String,Object>> fetchActions(String tag)

deleteAction

public void deleteAction(String tag)

executeAction

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

getCurrentContext

public Map<String,Object> getCurrentContext()

fetchDashboard

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

getTriggerProcessor

public TriggerProcessor getTriggerProcessor()

Session + persisted trigger registry (TriggerTypes.TriggerManager). Call TriggerProcessor.setDefaultContext(java.lang.String, java.lang.String) when product/database are known.

getAdapterByContextKey

public BaseAdapter getAdapterByContextKey(String contextKey)

TS getAdapterByContextKey used by DatabaseConnection.getAdapter().

registerTrigger

public void registerTrigger(String table,
 TriggerTypes.TriggerDefinition definition)

TS DatabaseConnection.triggers.register: in-memory session trigger for this service.

registerTriggers

public void registerTriggers(List<TriggerProcessor.TableTrigger> rows)

TS DatabaseConnection.triggers.registerAll.

unregisterTrigger

public boolean unregisterTrigger(String table,
 String triggerName)

TS DatabaseConnection.triggers.unregister.

getTriggersForEvent

public List<TriggerTypes.TriggerDefinition> getTriggersForEvent(String table,
 TriggerTypes.TriggerEvent event)

TS DatabaseConnection.triggers.getTriggersForEvent.

executeTriggers

public List<TriggerTypes.TriggerResult> executeTriggers(TriggerTypes.TriggerEvent event,
 TriggerTypes.TriggerContext context)

TS DatabaseConnection.triggers.execute with a fully built context.

executeTriggers

public List<TriggerTypes.TriggerResult> executeTriggers(TriggerTypes.TriggerEvent event,
 Map<String,Object> connectionOptions,
 Map<String,Object> partialContext)

TS DatabaseConnection.triggers.execute — supplies database and env (and product) from connection-scoped options, like connection._database / connection._env in TypeScript.

partialContext should include at least table, record, and operation (e.g. insert).

installDatabaseTriggerActionRunner

public void installDatabaseTriggerActionRunner()

TS TriggerProcessor.setDuctapeInstance equivalent: route database.* trigger actions to this service’s insert(app.ductape.sdk.database.types.WriteTypes.InsertOptions), update(app.ductape.sdk.database.types.WriteTypes.UpdateOptions), delete(app.ductape.sdk.database.types.WriteTypes.DeleteOptions), query(app.ductape.sdk.database.types.QueryTypes.QueryOptions) using product/database/env from the trigger TriggerTypes.TriggerContext.

createTrigger

public void createTrigger(String productId,
 Map<String,Object> data)

TS DatabaseService.createTrigger → product API (component: database_trigger, action: create).

createTrigger

public void createTrigger(String productId,
 Map<String,Object> data,
 boolean throwErrorIfExists)

updateTrigger

public void updateTrigger(String productId,
 Map<String,Object> data)

TS DatabaseService.updateTrigger.

fetchTrigger

public Map<String,Object> fetchTrigger(String productId,
 String compositeTag)

TS DatabaseService.fetchTrigger; tag is database_tag:trigger_tag.

fetchTriggers

public List<Map<String,Object>> fetchTriggers(String productId,
 String databaseTag)

TS DatabaseService.fetchTriggers.

deleteTrigger

public void deleteTrigger(String productId,
 String compositeTag)

TS DatabaseService.deleteTrigger.

createMigration

public void createMigration(String productId,
 Map<String,Object> data)

TS createMigration.

createMigration

public void createMigration(String productId,
 Map<String,Object> data,
 boolean throwErrorIfExists)

updateMigration

public void updateMigration(String productId,
 Map<String,Object> data)

TS updateMigration.

fetchMigration

public Map<String,Object> fetchMigration(String productId,
 String compositeTag)

TS fetchMigration; composite tag format: database_tag:migration_tag.

fetchMigrations

public List<Map<String,Object>> fetchMigrations(String productId,
 String databaseTag)

TS fetchMigrations.

deleteMigration

public void deleteMigration(String productId,
 String compositeTag)

TS deleteMigration.

loadTriggersFromBackend

public void loadTriggersFromBackend(String productId,
 String databaseTag)

TS DatabaseConnection.triggers.load: pull triggers from the product payload and register them on getTriggerProcessor().

fetchPersistedActionForExecute

protected Map<String,Object> fetchPersistedActionForExecute(String product,
 String database,
 String action)