hotfix for through tables and custom primarykeys

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

@@ -25,16 +25,12 @@ module.exports = (function() {
       //fully qualify
       //fully qualify
       var instancePrimaryKeys = Object.keys(self.instance.daoFactory.primaryKeys)
       var instancePrimaryKeys = Object.keys(self.instance.daoFactory.primaryKeys)
         , instancePrimaryKey = instancePrimaryKeys.length > 0 ? instancePrimaryKeys[0] : 'id'
         , instancePrimaryKey = instancePrimaryKeys.length > 0 ? instancePrimaryKeys[0] : 'id'
-
-      where[through.tableName+"."+self.association.identifier] = self.instance[instancePrimaryKey]
-
-      var primaryKeys = Object.keys(through.primaryKeys)
-        , foreignKey  = primaryKeys.filter(function(pk) { return pk != self.association.identifier })[0]
         , foreignPrimary = Object.keys(self.association.target.primaryKeys)
         , foreignPrimary = Object.keys(self.association.target.primaryKeys)
 
 
       foreignPrimary = foreignPrimary.length === 1 ? foreignPrimary[0] : 'id'
       foreignPrimary = foreignPrimary.length === 1 ? foreignPrimary[0] : 'id'
 
 
-      where[through.tableName+"."+foreignKey] = {join: self.association.target.tableName+"."+foreignPrimary}
+      where[through.tableName+"."+self.association.identifier] = self.instance[instancePrimaryKey]
+      where[through.tableName+"."+self.association.foreignIdentifier] = {join: self.association.target.tableName+"."+foreignPrimary}
 
 
       if (Object(targetAssociation.through) === targetAssociation.through) {
       if (Object(targetAssociation.through) === targetAssociation.through) {
         queryOptions.hasJoinTableModel = true
         queryOptions.hasJoinTableModel = true

test/associations/has-many.test.js

@@ -946,7 +946,7 @@ describe(Support.getTestDialectTeaser("HasMany"), function() {
       })
       })
     })
     })
     
     
-    describe('join table model', function () {
+    describe('through', function () {
       beforeEach(function (done) {
       beforeEach(function (done) {
         this.User = this.sequelize.define('User', {})
         this.User = this.sequelize.define('User', {})
         this.Project = this.sequelize.define('Project', {})
         this.Project = this.sequelize.define('Project', {})
@@ -1049,9 +1049,56 @@ describe(Support.getTestDialectTeaser("HasMany"), function() {
 
 
             this.sequelize.sync().done(function(err) {
             this.sequelize.sync().done(function(err) {
               expect(err).not.to.be.ok
               expect(err).not.to.be.ok
-              Worker.create().done(function (err, worker) {
+              Worker.create({id: 1337}).done(function (err, worker) {
+                expect(err).not.to.be.ok
+                Task.create({id: 7331}).done(function (err, task) {
+                  expect(err).not.to.be.ok
+                  worker.addTask(task).done(function (err) {
+                    expect(err).not.to.be.ok
+                    worker.addTask(task).done(function (err) {
+                      expect(err).not.to.be.ok
+                      done()
+                    })
+                  })
+                })
+              })
+            })
+          })
+
+          it('should be able to add twice (second call result in UPDATE call) with custom primary keys and without any attributes (and timestamps off) on the through model', function (done) {
+            var Worker = this.sequelize.define('Worker', {
+                id: {
+                  type: DataTypes.INTEGER,
+                  allowNull: false,
+                  primaryKey: true,
+                  autoIncrement: true
+                }
+              }, {timestamps: false})
+              , Task = this.sequelize.define('Task', {
+                id: {
+                  type: DataTypes.INTEGER,
+                  allowNull: false,
+                  primaryKey: true,
+                  autoIncrement: true
+                }
+              }, {timestamps: false})
+              , WorkerTasks = this.sequelize.define('WorkerTasks', {
+                id: {
+                  type: DataTypes.INTEGER,
+                  allowNull: false,
+                  primaryKey: true,
+                  autoIncrement: true
+                }
+              }, {timestamps: false})
+
+            Worker.hasMany(Task, { through: WorkerTasks })
+            Task.hasMany(Worker, { through: WorkerTasks })
+
+            this.sequelize.sync().done(function(err) {
+              expect(err).not.to.be.ok
+              Worker.create({id: 1337}).done(function (err, worker) {
                 expect(err).not.to.be.ok
                 expect(err).not.to.be.ok
-                Task.create().done(function (err, task) {
+                Task.create({id: 7331}).done(function (err, task) {
                   expect(err).not.to.be.ok
                   expect(err).not.to.be.ok
                   worker.addTask(task).done(function (err) {
                   worker.addTask(task).done(function (err) {
                     expect(err).not.to.be.ok
                     expect(err).not.to.be.ok