Added transaction support for hasMany `.addAssociation`

lib/associations/has-many-double-linked.js

@@ -21,7 +21,7 @@ module.exports = (function() {
         , options = _options || {}
         , queryOptions = {}
         , targetAssociation = self.association.targetAssociation
-        
+
       //fully qualify
       var instancePrimaryKeys = Object.keys(self.instance.daoFactory.primaryKeys)
         , instancePrimaryKey = instancePrimaryKeys.length > 0 ? instancePrimaryKeys[0] : 'id'
@@ -187,11 +187,17 @@ module.exports = (function() {
   HasManyDoubleLinked.prototype.injectAdder = function(emitterProxy, newAssociation, additionalAttributes, exists) {
     var attributes          = {}
       , targetAssociation   = this.association.targetAssociation
-      , foreignIdentifier   = targetAssociation.isSelfAssociation ? targetAssociation.foreignIdentifier : targetAssociation.identifier;
+      , foreignIdentifier   = targetAssociation.isSelfAssociation ? targetAssociation.foreignIdentifier : targetAssociation.identifier
+      , options = {}
 
     var sourceKeys = Object.keys(this.association.source.primaryKeys);
     var targetKeys = Object.keys(this.association.target.primaryKeys);
 
+    if ((additionalAttributes || {}).transaction instanceof Transaction) {
+      options.transaction = additionalAttributes.transaction
+      delete additionalAttributes.transaction
+    }
+
     attributes[this.association.identifier] = ((sourceKeys.length === 1) ? this.instance[sourceKeys[0]] : this.instance.id)
     attributes[foreignIdentifier] = ((targetKeys.length === 1) ? newAssociation[targetKeys[0]] : newAssociation.id)
 
@@ -207,7 +213,7 @@ module.exports = (function() {
     } else {
       attributes = Utils._.defaults(attributes, newAssociation[targetAssociation.through.name], additionalAttributes)
 
-      this.association.through.create(attributes)
+      this.association.through.create(attributes, options)
         .success(function() { emitterProxy.emit('success', newAssociation) })
         .error(function(err) { emitterProxy.emit('error', err) })
         .on('sql', function(sql) { emitterProxy.emit('sql', sql) })

lib/associations/has-many-single-linked.js

@@ -108,13 +108,19 @@ module.exports = (function() {
       .on('sql', function(sql) { emitter.emit('sql', sql) })
   }
 
-  HasManySingleLinked.prototype.injectAdder = function(emitterProxy, newAssociation) {
+  HasManySingleLinked.prototype.injectAdder = function(emitterProxy, newAssociation, additionalAttributes) {
     var primaryKeys = Object.keys(this.instance.daoFactory.primaryKeys)
       , primaryKey = primaryKeys.length === 1 ? primaryKeys[0] : 'id'
+      , options = {}
+
+    if ((additionalAttributes || {}).transaction instanceof Transaction) {
+      options.transaction = additionalAttributes.transaction
+      delete additionalAttributes.transaction
+    }
 
     newAssociation[this.__factory.identifier] = this.instance[primaryKey]
 
-    newAssociation.save()
+    newAssociation.save(options)
       .success(function() { emitterProxy.emit('success', newAssociation) })
       .error(function(err) { emitterProxy.emit('error', err) })
       .on('sql', function(sql) { emitterProxy.emit('sql', sql) })