query without event emitter

splitice · splitice · commit bd06582128ab · 2025-07-17T16:11:08.000+10:00
diff --git a/packages/pg/lib/query.js b/packages/pg/lib/query.js
@@ -1,14 +1,10 @@
 'use strict'
 
-const { EventEmitter } = require('events')
-
 const Result = require('./result')
 const utils = require('./utils')
 
-class Query extends EventEmitter {
+class Query {
   constructor(config, values, callback) {
-    super()
-
     config = utils.normalizeQueryConfig(config, values, callback)
 
     this.text = config.text
@@ -93,7 +89,6 @@ class Query extends EventEmitter {
       return
     }
 
-    this.emit('row', row, this._result)
     if (this._accumulateRows) {
       this._result.addRow(row)
     }
@@ -130,7 +125,6 @@ class Query extends EventEmitter {
     if (this.callback) {
       return this.callback(err)
     }
-    this.emit('error', err)
   }
 
   handleReadyForQuery(con) {
@@ -146,7 +140,6 @@ class Query extends EventEmitter {
         })
       }
     }
-    this.emit('end', this._results)
   }
 
   submit(connection) {

Original file line number	Diff line number	Diff line change
`@@ -1,14 +1,10 @@`
`1`	`1`	`'use strict'`
`2`	`2`
`3`		`-const { EventEmitter } = require('events')`
`4`		`-`
`5`	`3`	`const Result = require('./result')`
`6`	`4`	`const utils = require('./utils')`
`7`	`5`
`8`		`-class Query extends EventEmitter {`
	`6`	`+class Query {`
`9`	`7`	`constructor(config, values, callback) {`
`10`		`- super()`
`11`		`-`
`12`	`8`	`config = utils.normalizeQueryConfig(config, values, callback)`
`13`	`9`
`14`	`10`	`this.text = config.text`
`@@ -93,7 +89,6 @@ class Query extends EventEmitter {`
`93`	`89`	`return`
`94`	`90`	`}`
`95`	`91`
`96`		`- this.emit('row', row, this._result)`
`97`	`92`	`if (this._accumulateRows) {`
`98`	`93`	`this._result.addRow(row)`
`99`	`94`	`}`
`@@ -130,7 +125,6 @@ class Query extends EventEmitter {`
`130`	`125`	`if (this.callback) {`
`131`	`126`	`return this.callback(err)`
`132`	`127`	`}`
`133`		`- this.emit('error', err)`
`134`	`128`	`}`
`135`	`129`
`136`	`130`	`handleReadyForQuery(con) {`
`@@ -146,7 +140,6 @@ class Query extends EventEmitter {`
`146`	`140`	`})`
`147`	`141`	`}`
`148`	`142`	`}`
`149`		`- this.emit('end', this._results)`
`150`	`143`	`}`
`151`	`144`
`152`	`145`	`submit(connection) {`