| 394 | } |
| 395 | |
| 396 | function queryError(query, err) { |
| 397 | if (query.reserve) |
| 398 | return query.reject(err) |
| 399 | |
| 400 | if (!err || typeof err !== 'object') |
| 401 | err = new Error(err) |
| 402 | |
| 403 | 'query' in err || 'parameters' in err || Object.defineProperties(err, { |
| 404 | stack: { value: err.stack + query.origin.replace(/.*\n/, '\n'), enumerable: options.debug }, |
| 405 | query: { value: query.string, enumerable: options.debug }, |
| 406 | parameters: { value: query.parameters, enumerable: options.debug }, |
| 407 | args: { value: query.args, enumerable: options.debug }, |
| 408 | types: { value: query.statement && query.statement.types, enumerable: options.debug } |
| 409 | }) |
| 410 | query.reject(err) |
| 411 | } |
| 412 | |
| 413 | function end() { |
| 414 | return ending || ( |