Fix update by field when entity parameter is present

data-processor/src/main/java/io/micronaut/data/processor/visitors/finders/criteria/UpdateCriteriaMethodMatch.java

@@ -170,12 +170,12 @@ protected <T> Predicate interceptPredicate(MethodMatchContext matchContext,
         final SourcePersistentEntity rootEntity = (SourcePersistentEntity) root.getPersistentEntity();
         Predicate predicate = null;
         if (entityParameter != null) {
-            if (rootEntity.getVersion() != null) {
+            if (rootEntity.getVersion() != null && existingPredicate == null) {
                 predicate = cb.and(
                     cb.equal(root.id(), cb.entityPropertyParameter(entityParameter, new PersistentPropertyPath(rootEntity.getIdentity()))),
                     cb.equal(root.version(), cb.entityPropertyParameter(entityParameter, new PersistentPropertyPath(rootEntity.getVersion())))
                 );
-            } else {
+            } else if (existingPredicate == null) {
                 predicate = cb.equal(root.id(), cb.entityPropertyParameter(entityParameter, new PersistentPropertyPath(rootEntity.getIdentity())));
             }
         } else {

data-processor/src/test/groovy/io/micronaut/data/processor/sql/BuildUpdateSpec.groovy

@@ -22,6 +22,7 @@ import io.micronaut.data.intercept.async.UpdateAsyncInterceptor
 import io.micronaut.data.intercept.reactive.UpdateReactiveInterceptor
 import io.micronaut.data.model.DataType
 import io.micronaut.data.processor.visitors.AbstractDataSpec
+import io.micronaut.data.tck.entities.Person
 import spock.lang.PendingFeature
 import spock.lang.Unroll
 
@@ -186,6 +187,28 @@ interface PersonRepository extends CrudRepository<Person, Long> {
     }
 
 
+    void "test update by field with entity parameter"() {
+        given:
+        def repository = buildRepository('test.PersonRepository', """
+import io.micronaut.data.jdbc.annotation.JdbcRepository;
+import io.micronaut.data.model.query.builder.sql.Dialect;
+import io.micronaut.data.repository.GenericRepository;
+import io.micronaut.data.tck.entities.Person;
+
+@JdbcRepository(dialect = Dialect.MYSQL)
+interface PersonRepository extends GenericRepository<Person, Long> {
+
+    void updateByName(String name, Person person);
+}
+""")
+
+        def method = repository.findMethod("updateByName", String, Person).get()
+        def updateQuery = getQuery(method)
+
+        expect:
+        updateQuery == 'UPDATE `person` SET `name`=?,`age`=?,`enabled`=?,`income`=? WHERE (`name` = ?)'
+    }
+
     void "test AutoGenerated update method"() {
       given:
       def repository = buildRepository('test.StudentRepository', """

data-tck/src/main/groovy/io/micronaut/data/tck/tests/AbstractRepositorySpec.groovy

@@ -1007,6 +1007,17 @@ abstract class AbstractRepositorySpec extends Specification {
         then:
         personRepository.findByName("Jack") == null
         personRepository.findByName("Jeffrey").age == 30
+
+        when:"Update by using entity with null id"
+        def jeffrey = personRepository.findByName("Jeffrey")
+        def initialAge = jeffrey.age
+        jeffrey.id = null
+        jeffrey.age = 31
+        personRepository.updateByName("Jeffrey", jeffrey)
+        def updatedJeffrey = personRepository.findByName("Jeffrey")
+        then:"Entity is updated"
+        initialAge == 30
+        updatedJeffrey.age == 31
     }
 
     void "test update by multiple fields"() {

data-tck/src/main/java/io/micronaut/data/tck/repositories/PersonRepository.java

@@ -81,6 +81,8 @@ public interface PersonRepository extends CrudRepository<Person, Long>, Pageable
 
     long updateByName(String name, int age);
 
+    void updateByName(String name, Person person);
+
     List<Person> list(Pageable pageable);
 
     int count(String name);