Package app.ductape.sdk.database.adapters

Class DynamoDbDriverLiveAdapter

java.lang.Object

app.ductape.sdk.database.adapters.BaseAdapter

app.ductape.sdk.database.adapters.DynamoDbDriverLiveAdapter

public class DynamoDbDriverLiveAdapter
extends BaseAdapter

Real DynamoDB adapter via the AWS SDK for Java v2 (Go DynamoLiveAdapter / .NET DynamoDbDriverLiveAdapter parity). Unlike the SQL/Mongo live adapters, there is no connection string to gate on — DynamoDB is reached via AWS access-key/region credentials, so shouldUse(java.util.Map<java.lang.String, java.lang.Object>) mirrors the Go/.NET credential-presence check instead.

Field Summary

Fields inherited from class app.ductape.sdk.database.adapters.BaseAdapter

connected, connectionOptions, connectionUrl, maxRetries

Constructor Summary

Constructors

Constructor	Description
DynamoDbDriverLiveAdapter()

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	connect(Map<String,Object> options)
void	createTable(String table, List<Map<String,Object>> columns)
protected DatabaseType	databaseType()
int	delete(String table, Map<String,Object> where)
void	disconnect()
void	dropTable(String table)
int	insert(String table, List<Map<String,Object>> rows)
List<String>	listTables()
List<Map<String,Object>>	query(String table, Map<String,Object> where, int limit, int offset)
Map<String,Object>	schema(String table)
static boolean	shouldUse(Map<String,Object> options)	TS/Go/.NET parity gate: opt-in via options.live == true (with resolvable AWS credentials) or the DUCTAPE_LIVE=true environment variable.
boolean	tableExists(String table)
Map<String,Object>	testConnection(Map<String,Object> options)
int	update(String table, Map<String,Object> where, Map<String,Object> setValues)

Methods inherited from class app.ductape.sdk.database.adapters.BaseAdapter

aggregate, attemptReconnect, beginTransaction, commitTransaction, createIndex, createSavepoint, dropIndex, executeWithRetry, executeWithRetry, getDatabaseType, getIndexStatistics, groupBy, isConnected, isConnectionError, listIndexes, rawQuery, releaseSavepoint, rollbackToSavepoint, rollbackTransaction, supportsDeferrableTransactions

Methods inherited from class java.lang.Object

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

Constructor Details

DynamoDbDriverLiveAdapter

public DynamoDbDriverLiveAdapter()

Method Details

databaseType

protected DatabaseType databaseType()

Specified by:

databaseType in class BaseAdapter

shouldUse

public static boolean shouldUse(Map<String,Object> options)

TS/Go/.NET parity gate: opt-in via options.live == true (with resolvable AWS credentials) or the DUCTAPE_LIVE=true environment variable.

connect

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

Specified by:

connect in class BaseAdapter

testConnection

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

Specified by:

testConnection in class BaseAdapter

disconnect

public void disconnect()

Specified by:

disconnect in class BaseAdapter

query

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

Specified by:

query in class BaseAdapter

insert

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

Specified by:

insert in class BaseAdapter

update

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

Specified by:

update in class BaseAdapter

delete

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

Specified by:

delete in class BaseAdapter

tableExists

public boolean tableExists(String table)

Specified by:

tableExists in class BaseAdapter

listTables

public List<String> listTables()

Specified by:

listTables in class BaseAdapter

schema

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

Specified by:

schema in class BaseAdapter

createTable

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

Specified by:

createTable in class BaseAdapter

dropTable

public void dropTable(String table)

Specified by:

dropTable in class BaseAdapter