add valuemapper to bind method

Author: iamkhush

packages/pg-batch-query/src/index.ts

@@ -1,13 +1,12 @@
 import { Submittable, Connection, QueryResult } from 'pg'
 const Result = require('pg/lib/result.js')
-const EventEmitter = require('events').EventEmitter
-
+const utils = require('pg/lib/utils.js')
 let nextUniqueID = 1 // concept borrowed from org.postgresql.core.v3.QueryExecutorImpl
 
 interface BatchQueryConfig {
   name?: string
   text: string
-  values?: string[][] 
+  values?: any[][] 
 }
 
 class BatchQuery implements Submittable  {
@@ -58,7 +57,8 @@ class BatchQuery implements Submittable  {
       this.connection.bind({
         statement: this.name,
         values: val,
-        portal: this._portal
+        portal: this._portal,
+        valueMapper: utils.prepareValue,
       }, true)
 
       // maybe we could avoid this for non-select queries

packages/pg-batch-query/test/test-query.ts

@@ -1,5 +1,5 @@
 import assert from 'assert'
-import BatchQuery from '../'
+import BatchQuery from '../src'
 import pg from 'pg'
 
 describe('batch query', function () {
@@ -54,4 +54,20 @@ describe('batch query', function () {
     const resp = await this.client.query('SELECT SUM(value) from bar')
     assert.strictEqual(resp.rows[0]['sum'], '3')
   })
+
+  it('If query is for an array', async function() {
+    await this.client.query('INSERT INTO foo (name) VALUES ($1)', ['first'])
+    await this.client.query('INSERT INTO foo (name) VALUES ($1)', ['second'])
+    const responses = await this.client.query(new BatchQuery({
+      text: `SELECT * from foo where name = ANY($1)`,
+      values: [
+          [['first', 'third']],
+          [['second', 'fourth']]
+      ],
+      name: 'optional'
+  })).execute()
+  assert.equal(responses.length, 2)
+  for ( const response of responses) {
+    assert.strictEqual(response.rowCount, 1)
+  }})
 })