123456789101112131415161718192021222324252627282930313233343536373839404142 |
- var Utils = require("../../utils")
- , AbstractQuery = require('../abstract/query')
- module.exports = (function() {
- var Query = function(client, sequelize, callee, options) {
- this.client = client
- this.callee = callee
- this.sequelize = sequelize
- this.options = Utils._.extend({
- logging: console.log,
- plain: false,
- raw: false
- }, options || {})
- this.checkLoggingOption()
- }
- Utils.inherit(Query, AbstractQuery)
- Query.prototype.run = function(sql) {
- this.sql = sql
- if (this.options.logging !== false) {
- this.options.logging('Executing (' + this.options.uuid + '): ' + this.sql)
- }
- this.client.query(this.sql, function(err, results, fields) {
- this.emit('sql', this.sql)
- if (err) {
- err.sql = sql
- this.emit('error', err, this.callee)
- } else {
- this.emit('success', this.formatResults(results))
- }
- }.bind(this)).setMaxListeners(100)
- return this
- }
- return Query
- })()
|