Package app.ductape.sdk.database.adapters

Class MySqlJdbcLiveAdapter

java.lang.Object

app.ductape.sdk.database.adapters.BaseAdapter

app.ductape.sdk.database.adapters.MySqlJdbcLiveAdapter

Direct Known Subclasses:

MariaDbJdbcLiveAdapter

public class MySqlJdbcLiveAdapter
extends BaseAdapter

Real MySQL adapter via the MariaDB Connector/J driver (Go MySQLLiveAdapter / .NET MySqlConnectorLiveAdapter parity). The MariaDB driver is wire-protocol-compatible with MySQL and is used here instead of mysql-connector-j to avoid pulling a GPL-licensed dependency into the SDK. Plain JDBC Connection, no connection pool — the VPC connector tunnel local proxy only accepts a single TCP connection per connect() call, so pooling beyond 1 connection would be unusable anyway.

Field Summary

Fields

Modifier and Type	Field	Description
protected Connection	connection

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

connected, connectionOptions, connectionUrl, maxRetries

Constructor Summary

Constructors

Constructor	Description
MySqlJdbcLiveAdapter()

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)
protected void	ensureConnected()
int	insert(String table, List<Map<String,Object>> rows)
protected static boolean	isTruthy(Object value)
List<String>	listTables()
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).
protected static String	resolveConnectionString(Map<String,Object> options, DatabaseType type)
Map<String,Object>	schema(String table)
static boolean	shouldUse(Map<String,Object> options)	TS/.NET/Go parity gate: opt-in via options.live == true (with a resolvable connection string) or the DUCTAPE_LIVE=true environment variable (mirrors .NET MySqlConnectorLiveAdapter.ShouldUse / Go newMySQLLiveBackend).
boolean	supportsDeferrableTransactions()	TS feature check used by TransactionManager for deferrable transactions.
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, releaseSavepoint, rollbackToSavepoint, rollbackTransaction

Methods inherited from class java.lang.Object

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

Field Details

connection

protected Connection connection

Constructor Details

MySqlJdbcLiveAdapter

public MySqlJdbcLiveAdapter()

Method Details

databaseType

protected DatabaseType databaseType()

Specified by:

databaseType in class BaseAdapter

shouldUse

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

TS/.NET/Go parity gate: opt-in via options.live == true (with a resolvable connection string) or the DUCTAPE_LIVE=true environment variable (mirrors .NET MySqlConnectorLiveAdapter.ShouldUse / Go newMySQLLiveBackend).

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

rawQuery

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

Description copied from class: BaseAdapter

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

Overrides:

rawQuery in class BaseAdapter

supportsDeferrableTransactions

public boolean supportsDeferrableTransactions()

Description copied from class: BaseAdapter

TS feature check used by TransactionManager for deferrable transactions.

Overrides:

supportsDeferrableTransactions in class BaseAdapter

ensureConnected

protected void ensureConnected()

resolveConnectionString

protected static String resolveConnectionString(Map<String,Object> options,
 DatabaseType type)

isTruthy

protected static boolean isTruthy(Object value)