ExecutionResult executeStatement()

in src/main/java/com/amazon/rdsdata/client/RdsDataClient.java [122:141]


    ExecutionResult executeStatement(String transactionId, String sql, Map<String, Object> params, boolean continueAfterTimeout) {
        val request = new ExecuteStatementRequest()
                .withDatabase(database)
                .withResourceArn(resourceArn)
                .withSecretArn(secretArn)
                .withSql(sql)
                .withParameters(toSqlParameterList(params))
                .withTransactionId(transactionId)
                .withContinueAfterTimeout(continueAfterTimeout)
                .withResultSetOptions(new ResultSetOptions()
                        .withDecimalReturnType(DecimalReturnType.STRING))
                .withIncludeResultMetadata(true);

        val response = rdsDataService.executeStatement(request);

        return new ExecutionResult(response.getColumnMetadata(),
            response.getRecords(),
            response.getNumberOfRecordsUpdated(),
            mappingOptions);
    }