Package app.ductape.sdk.database

Class DatabaseConnection

java.lang.Object

app.ductape.sdk.database.DatabaseConnection

public final class DatabaseConnection
extends Object

TS parity: sdk/ts/src/database/databases.service.ts DatabaseConnection. Connection-scoped facade over DatabaseService.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	DatabaseConnection.Schema
final class	DatabaseConnection.Triggers	TS parity: connection-scoped trigger operations object.

Constructor Summary

Constructors

Constructor	Description
DatabaseConnection(DatabaseService service, String database, String env, String product)

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	aggregate(Map<String,Object> options)
Number	avg(Map<String,Object> options)
TransactionTypes.Transaction	beginTransaction(Map<String,Object> options)
Number	count(Map<String,Object> options)
String	database()
Map<String,Object>	delete(Map<String,Object> options)
String	env()
BaseAdapter	getAdapter()	TS getAdapter().
List<Map<String,Object>>	groupBy(Map<String,Object> options)
Map<String,Object>	insert(Map<String,Object> options)
Object	max(Map<String,Object> options)
Object	min(Map<String,Object> options)
String	product()
Map<String,Object>	query(Map<String,Object> options)
Map<String,Object>	raw(Map<String,Object> options)
DatabaseConnection.Schema	schema()	TS connection.schema facade (subset over current Java service methods).
Number	sum(Map<String,Object> options)
<T> T	transaction(Map<String,Object> options, TransactionTypes.TransactionCallback<T> callback)
DatabaseConnection.Triggers	triggers()
Map<String,Object>	update(Map<String,Object> 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

DatabaseConnection

public DatabaseConnection(DatabaseService service,
 String database,
 String env,
 String product)

Method Details

database

public String database()

env

public String env()

product

public String product()

getAdapter

public BaseAdapter getAdapter()

TS getAdapter().

query

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

insert

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

update

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

delete

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

upsert

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

raw

public Map<String,Object> raw(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(Map<String,Object> options)

groupBy

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

schema

public DatabaseConnection.Schema schema()

TS connection.schema facade (subset over current Java service methods).

beginTransaction

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

transaction

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

Throws:

Exception

triggers

public DatabaseConnection.Triggers triggers()