Updated chunked rowset test

Author: gionatamettifogo

examples/with-javascript-express/package.json

@@ -10,6 +10,6 @@
     "dotenv": "^16.3.1",
     "express": "^4.18.2",
     "http-errors": "^2.0.0",
-    "sqlitecloud-js": "^0.0.25"
+    "@sqlitecloud/drivers": "*"
   }
 }

examples/with-typescript-knex/package.json

@@ -7,7 +7,7 @@
   },
   "dependencies": {
     "knex": "^3.1.0",
-    "sqlitecloud-js": "^0.0.25"
+    "@sqlitecloud/drivers": "*"
   },
   "devDependencies": {
     "@types/node": "^20",

examples/with-typescript-nextjs/package.json

@@ -9,7 +9,7 @@
     "next": "14.0.3",
     "react": "^18",
     "react-dom": "^18",
-    "sqlitecloud-js": "^0.0.20-beta"
+    "@sqlitecloud/drivers": "*"
   },
   "devDependencies": {
     "@types/node": "^20",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@sqlitecloud/drivers",
-  "version": "0.0.35",
+  "version": "0.0.37",
   "description": "SQLiteCloud drivers for Typescript/Javascript in edge, web and node clients",
   "main": "./lib/index.js",
   "types": "./lib/index.d.ts",

src/transport-tls.ts

@@ -380,7 +380,6 @@ function parseRowsetColumnsMetadata(buffer: Buffer, metadata: SQLCloudRowsetMeta
     for (let i = 0; i < metadata.numberOfColumns; i++) metadata.columns[i].notNull = popForward() as boolean
     for (let i = 0; i < metadata.numberOfColumns; i++) metadata.columns[i].primaryKey = popForward() as boolean
     for (let i = 0; i < metadata.numberOfColumns; i++) metadata.columns[i].autoIncrement = popForward() as boolean
-    console.debug('metadata', metadata)
   }
 
   return buffer

src/types.ts

@@ -77,12 +77,12 @@ export interface SQLCloudRowsetMetadata {
     table?: string
     /** Original name of the column */
     column?: string
-    /** Column is not nullable? */
-    notNull?: boolean
-    /** Column is primary key */
-    primaryKey?: boolean
-    /** Column has autoincrement flag */
-    autoIncrement?: boolean
+    /** Column is not nullable? 1 */
+    notNull?: number
+    /** Column is primary key? 1 */
+    primaryKey?: number
+    /** Column has autoincrement flag? 1 */
+    autoIncrement?: number
   }[]
 }
 

test/connection-tls.test.ts

@@ -271,12 +271,53 @@ describe('connection-tls', () => {
           expect(results.numberOfColumns).toBe(1)
           expect(results.columnsNames).toEqual(['key'])
 
+          expect(results[0]['key']).toBe('REINDEX')
+          expect(results[1]['key']).toBe('INDEXED')
+          expect(results[2]['key']).toBe('INDEX')
+          expect(results[3]['key']).toBe('DESC')
+
           database.close()
           done()
         })
       },
       LONG_TIMEOUT
     )
+
+    it(
+      'should test chunked rowset twice',
+      done => {
+        // this operation sends 150 packets, so we need to increase the timeout
+        const database = getChinookTlsConnection(undefined, { timeout: 60 * 1000 })
+        database.sendCommands('TEST ROWSET_CHUNK', (error, results) => {
+          expect(error).toBeNull()
+          expect(results.numberOfRows).toBe(147)
+          expect(results.numberOfColumns).toBe(1)
+          expect(results.columnsNames).toEqual(['key'])
+          expect(results[0]['key']).toBe('REINDEX')
+          expect(results[1]['key']).toBe('INDEXED')
+          expect(results[2]['key']).toBe('INDEX')
+          expect(results[3]['key']).toBe('DESC')
+
+          database.sendCommands('TEST ROWSET_CHUNK', (error, results) => {
+            expect(error).toBeNull()
+            expect(results.numberOfRows).toBe(147)
+            expect(results.numberOfColumns).toBe(1)
+            expect(results.columnsNames).toEqual(['key'])
+            expect(results[0]['key']).toBe('REINDEX')
+            expect(results[1]['key']).toBe('INDEXED')
+            expect(results[2]['key']).toBe('INDEX')
+            expect(results[3]['key']).toBe('DESC')
+
+            database.sendCommands('SELECT 1', (error, results) => {
+              expect(error).toBeNull()
+              expect(results.numberOfRows).toBe(1)
+              done()
+            })
+          })
+        })
+      },
+      LONG_TIMEOUT
+    )
   })
 
   describe('operations', () => {