athena-client - npm Package Compare versions

Comparing version 1.0.5 to 1.0.6

lib/client.js

@@ -84,2 +84,10 @@ 'use strict'
                     data = yield request.getQueryResults(queryId, nowConfig)
+                    let previousToken
+                    while (data.NextToken && data.NextToken !== previousToken) {
+                        let dataTmp = yield request.getQueryResults(queryId, nowConfig, data.NextToken)
+                        data.NextToken = dataTmp.NextToken || null
+                        data.ResultSet.Rows = data.ResultSet.Rows.concat(dataTmp.ResultSet.Rows)
+                        previousToken = data.NextToken
+                    }
+
                     let format = options.format || nowConfig.format
@@ -86,0 +94,0 @@ data = extractData(data, format)

lib/request.js

@@ -98,3 +98,3 @@ 'use strict'
 
-    getQueryResults(queryId, config, retryCount) {
+    getQueryResults(queryId, config, nextToken) {
         return new Promise((resolve, reject) => {
@@ -105,2 +105,5 @@ let retryCount = 0
             }
+            if (nextToken) {
+                params.NextToken = nextToken
+            }
             let loopFunc = () => {
@@ -107,0 +110,0 @@ athena.getQueryResults(params, (err, data) => {

package.json

 {
   "name": "athena-client",
-  "version": "1.0.5",
+  "version": "1.0.6",
   "description": "a nodejs simple aws athena client",
@@ -5,0 +5,0 @@ "homepage": "https://github.com/KoteiIto/node-athena",

test/client.js

@@ -81,3 +81,4 @@ 'use strict'
             ]
-        }
+        },
+        NextToken: "TOKEN",
     }
@@ -84,0 +85,0 @@ return new Promise((resolve, reject) => {

No alert changes

Improved metrics

Total package byte prevSize

36994

increased by1.6%

Lines of code

814

increased by1.37%

No dependency changes