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