var executeSqlDataApi = function()

in quick-start/typescript/RedshiftDataAPI.js [124:159]
34 lines of code
7 McCabe index (conditional complexity)

var executeSqlDataApi = function (redshiftDataApiClient, redshiftClusterId, redshiftDatabaseName, redshiftUser, command, query, isSynchronous) { return __awaiter(void 0, void 0, void 0, function () {
    var queryId, input, queryStatus;
    return __generator(this, function (_a) {
        switch (_a.label) {
            case 0:
                queryId = '';
                input = {
                    ClusterIdentifier: redshiftClusterId,
                    Database: redshiftDatabaseName,
                    DbUser: redshiftUser,
                    Sql: query
                };
                // Calling Redshift Data API with executeStatement()
                return [4 /*yield*/, redshiftDataApiClient.executeStatement(input).promise()
                        .then(function (response) {
                        (queryId = response.Id);
                    })["catch"](function (error) {
                        console.log('ExecuteStatement has failed.');
                        throw new Error(error.message);
                    })];
            case 1:
                // Calling Redshift Data API with executeStatement()
                _a.sent();
                return [4 /*yield*/, getDescribeStatement(redshiftDataApiClient, queryId)];
            case 2:
                queryStatus = (_a.sent()).Status;
                console.log("Executed command: " + command + " | Query Status: " + queryStatus + " | QueryId: " + queryId);
                if (!isSynchronous) return [3 /*break*/, 4];
                return [4 /*yield*/, executeSynchronousWait(redshiftDataApiClient, queryStatus, queryId, command)];
            case 3:
                queryStatus = _a.sent();
                _a.label = 4;
            case 4: return [2 /*return*/, queryStatus];
        }
    });
}); };