@@ -62,8 +62,8 @@ NativeQuery.prototype.handleError = function (err) {
62
62
if ( this . native && this . native . connection ) {
63
63
// Need to emit the error on the client/connection level too
64
64
process . nextTick ( ( ) => {
65
- this . native . connection . emit ( 'error' , err ) ;
66
- } ) ;
65
+ this . native . connection . emit ( 'error' , err )
66
+ } )
67
67
}
68
68
}
69
69
@@ -117,24 +117,24 @@ NativeQuery.prototype.submit = function (client) {
117
117
// Check the result size if maxResultSize is configured
118
118
if ( self . _maxResultSize ) {
119
119
// Calculate result size (rough approximation)
120
- let resultSize = 0 ;
120
+ let resultSize = 0
121
121
122
122
// For multiple result sets
123
123
if ( results . length > 1 ) {
124
124
for ( let i = 0 ; i < rows . length ; i ++ ) {
125
- resultSize += self . _calculateResultSize ( rows [ i ] ) ;
125
+ resultSize += self . _calculateResultSize ( rows [ i ] )
126
126
}
127
127
} else if ( rows . length > 0 ) {
128
- resultSize = self . _calculateResultSize ( rows ) ;
128
+ resultSize = self . _calculateResultSize ( rows )
129
129
}
130
130
131
131
// If the size limit is exceeded, generate an error
132
132
if ( resultSize > self . _maxResultSize ) {
133
- const error = new Error ( 'Query result size exceeded the configured limit' ) ;
134
- error . code = 'RESULT_SIZE_EXCEEDED' ;
135
- error . resultSize = resultSize ;
136
- error . maxResultSize = self . _maxResultSize ;
137
- return self . handleError ( error ) ;
133
+ const error = new Error ( 'Query result size exceeded the configured limit' )
134
+ error . code = 'RESULT_SIZE_EXCEEDED'
135
+ error . resultSize = resultSize
136
+ error . maxResultSize = self . _maxResultSize
137
+ return self . handleError ( error )
138
138
}
139
139
}
140
140
@@ -207,56 +207,56 @@ NativeQuery.prototype.submit = function (client) {
207
207
208
208
// Helper method to estimate the size of a result set
209
209
NativeQuery . prototype . _calculateResultSize = function ( rows ) {
210
- let size = 0 ;
210
+ let size = 0
211
211
212
212
// For empty results, return 0
213
213
if ( ! rows || rows . length === 0 ) {
214
- return 0 ;
214
+ return 0
215
215
}
216
216
217
217
// For array mode, calculate differently
218
218
if ( this . _arrayMode ) {
219
219
// Just use a rough approximation based on number of rows
220
- return rows . length * 100 ;
220
+ return rows . length * 100
221
221
}
222
222
223
223
// For each row, approximate its size
224
224
for ( let i = 0 ; i < rows . length ; i ++ ) {
225
- const row = rows [ i ] ;
225
+ const row = rows [ i ]
226
226
227
227
// Add base row size
228
- size += 24 ; // Overhead per row
228
+ size += 24 // Overhead per row
229
229
230
230
// Add size of each column
231
231
for ( const key in row ) {
232
232
if ( Object . prototype . hasOwnProperty . call ( row , key ) ) {
233
- const value = row [ key ] ;
233
+ const value = row [ key ]
234
234
235
235
// Add key size
236
- size += key . length * 2 ; // Assume 2 bytes per character
236
+ size += key . length * 2 // Assume 2 bytes per character
237
237
238
238
// Add value size based on type
239
239
if ( value === null || value === undefined ) {
240
- size += 8 ;
240
+ size += 8
241
241
} else if ( typeof value === 'string' ) {
242
- size += value . length * 2 ; // Assume 2 bytes per character
242
+ size += value . length * 2 // Assume 2 bytes per character
243
243
} else if ( typeof value === 'number' ) {
244
- size += 8 ;
244
+ size += 8
245
245
} else if ( typeof value === 'boolean' ) {
246
- size += 4 ;
246
+ size += 4
247
247
} else if ( value instanceof Date ) {
248
- size += 8 ;
248
+ size += 8
249
249
} else if ( Buffer . isBuffer ( value ) ) {
250
- size += value . length ;
250
+ size += value . length
251
251
} else if ( Array . isArray ( value ) ) {
252
- size += 16 + value . length * 8 ;
252
+ size += 16 + value . length * 8
253
253
} else {
254
254
// For objects, use a rough estimate
255
- size += 32 + JSON . stringify ( value ) . length * 2 ;
255
+ size += 32 + JSON . stringify ( value ) . length * 2
256
256
}
257
257
}
258
258
}
259
259
}
260
260
261
- return size ;
261
+ return size
262
262
}
0 commit comments