john/dbt
1
Fork 0
Code Activity

Improve demo and error handling

Browse Source
This commit is contained in:
John Ahlroos
2018-05-05 10:05:23 +03:00
parent c2fda1ffaf
commit b51414e177
3 changed files with 49 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
dbt-core/src/main/groovy/com/devsoap/dbt/services/TransactionManagerService.groovy
View File

@@ -31,7 +31,13 @@ class TransactionManagerService implements Service {
}
def builder = new TransactionBuilder()
queryBuilder.build(builder)
try{
queryBuilder.build(builder)
} catch (Exception e) {
log.error('Failed to build transaction', e)
return Promise.error(e)
}
def transaction = builder.build()
log.info("Sending transaction $transaction.id to ledger at $config.ledger.remoteUrl")
@@ -39,6 +45,7 @@ class TransactionManagerService implements Service {
spec.body.text(mapper.writeValueAsString(transaction))
}).onError {
log.error("Failed to send transaction $transaction.id to ledger $config.ledger.remoteUrl")
return Promise.error(it)
}.map { response ->
if(response.status == Status.OK) {
mapper.readTree(response.body.text)
@@ -68,7 +75,14 @@ class TransactionManagerService implements Service {
log.info("Updating transaction $transactionId content with new query")
def builder = new TransactionBuilder(oldTransaction)
queryBuilder.build(builder)
try {
queryBuilder.build(builder)
} catch (Exception e) {
log.error("Failed to update transaction", e)
return Promise.error(e)
}
def transaction = builder.build()
if(transaction.id != transactionId) {
@@ -80,6 +94,7 @@ class TransactionManagerService implements Service {
spec.body.text(mapper.writeValueAsString(transaction))
}).onError {
log.error("Failed to send transaction $transaction.id to ledger $config.ledger.remoteUrl")
return Promise.error(it)
}
}.map { response ->
mapper.readTree(response.body.text)
@@ -100,16 +115,21 @@ class TransactionManagerService implements Service {
this.transaction = transaction
}
void query(String sql){
TransactionBuilder query(String sql){
if(sql == null || sql == '' || sql.trim() == '') {
throw new IllegalArgumentException("SQL statement cannot be null")
}
queries << sql
this
}
String id() {
transaction.id
}
void complete() {
TransactionBuilder complete() {
transaction.end()
this
}
private BlockTransaction build() {