Add missing @Override annotation (#2815)

benchmarks/benchmark-micronaut-data-jpa/src/main/java/example/BookRepository.java

@@ -90,6 +90,7 @@ public interface BookRepository extends CrudRepository<Book, Long> { // <2>
     // end::update2[]
 
     // tag::deleteall[]
+    @Override
     void deleteAll();
     // end::deleteall[]
 

data-azure-cosmos/src/test/java/io/micronaut/data/azure/repositories/FamilyRepository.java

@@ -27,6 +27,7 @@
 @CosmosRepository
 public abstract class FamilyRepository implements PageableRepository<Family, String>, JpaSpecificationExecutor<Family> {
 
+    @Override
     @NonNull
     public abstract Optional<Family> findById(@NonNull String id);
 

data-document-model/src/main/java/io/micronaut/data/document/model/query/builder/MongoQueryBuilder.java

@@ -1167,6 +1167,7 @@ private interface CriteriaContext extends PropertyParameterCreator {
 
         PersistentPropertyPath getRequiredProperty(String name, Class<?> criterionClazz);
 
+        @Override
         default int pushParameter(@NonNull BindingParameter bindingParameter, @NonNull BindingParameter.BindingContext bindingContext) {
             return getQueryState().pushParameter(bindingParameter, bindingContext);
         }

data-hibernate-jpa/src/test/java/io/micronaut/data/hibernate/BookRepository.java

@@ -43,6 +43,7 @@ public BookRepository(AuthorRepository authorRepository) {
     /**
      * @deprecated Order by 'author.name' case without a join. Hibernate will do the cross join if the association property is accessed by the property path without join.
      */
+    @Override
     @Query(value = "SELECT book_ FROM Book book_", countQuery = "SELECT count(book_) FROM Book book_ ")
     @Join(value = "author", type = Join.Type.FETCH)
     @Deprecated
@@ -92,6 +93,7 @@ public BookRepository(AuthorRepository authorRepository) {
     @Query("UPDATE Book SET author = :author WHERE id = :id")
     public abstract long updateAuthorCustomQuery(Long id, Author author);
 
+    @Override
     public abstract long updateAuthor(@Id Long id, Author author);
 
     @Query("SELECT b FROM Book b WHERE b.author = :author")

data-hibernate-jpa/src/test/java/io/micronaut/data/hibernate/PersonCrudRepository.java

@@ -43,6 +43,7 @@ public interface PersonCrudRepository extends JpaRepository<Person, Long>, Perso
     @Transactional
     List<Person> listPeople(String n);
 
+    @Override
     @Query(value = "from Person p where p.name like :n",
             countQuery = "select count(p) from Person p where p.name like :n")
     @Transactional

data-hibernate-jpa/src/test/java/io/micronaut/data/hibernate/RatingRepository.java

@@ -13,6 +13,7 @@
 @Repository
 @Transactional
 public interface RatingRepository extends CrudRepository<Rating, UUID> {
+    @Override
     @NotNull
     @EntityGraph("RatingEntityGraph")
     Optional<Rating> findById(@NotNull UUID id);

data-hibernate-reactive/src/main/java/io/micronaut/data/hibernate/reactive/repository/jpa/intercept/ReactiveFindPageSpecificationInterceptor.java

@@ -51,6 +51,7 @@ protected ReactiveFindPageSpecificationInterceptor(@NonNull RepositoryOperations
         super(operations);
     }
 
+    @Override
     protected final Pageable getPageable(MethodInvocationContext<?, ?> context) {
         final Object parameterValue = context.getParameterValues()[1];
         if (parameterValue instanceof Pageable) {

data-hibernate-reactive/src/test/java/io/micronaut/data/hibernate/reactive/PersonCrudRepository.java

@@ -52,11 +52,13 @@ default Mono<Person> findOneAndDelete(String name) {
     @Transactional
     Flux<Person> listPeople(String n);
 
+    @Override
     @Query(value = "from Person p where p.name like :n",
             countQuery = "select count(p) from Person p where p.name like :n")
     @Transactional
     Mono<Page<Person>> findPeople(String n, Pageable pageable);
 
+    @Override
     @Query("from Person p where p.name = :n")
     @Transactional
     Mono<Person> findByName(String n);

data-hibernate-reactive/src/test/java/io/micronaut/data/hibernate/reactive/RatingRepository.java

@@ -12,6 +12,7 @@
 @Repository
 public interface RatingRepository extends ReactorCrudRepository<Rating, UUID> {
 
+    @Override
     @EntityGraph("RatingEntityGraph")
     Mono<Rating> findById(@NotNull UUID id);
 

data-jdbc/src/main/java/io/micronaut/data/jdbc/operations/DefaultJdbcRepositoryOperations.java

@@ -729,6 +729,7 @@ public <R> Page<R> findPage(@NonNull PagedQuery<R> query) {
         throw new UnsupportedOperationException("The findPage method without an explicit query is not supported. Use findPage(PreparedQuery) instead");
     }
 
+    @Override
     @NonNull
     public <T> Iterable<T> persistAll(@NonNull InsertBatchOperation<T> operation) {
         return executeWrite(connection -> {

data-jdbc/src/test/java/io/micronaut/data/jdbc/h2/H2PatientRepository.java

@@ -13,6 +13,7 @@
 @JdbcRepository(dialect = Dialect.H2)
 public interface H2PatientRepository extends PatientRepository {
 
+    @Override
     @Query("UPDATE patient SET appointments = :appointments FORMAT JSON WHERE name = :name")
     void updateAppointmentsByName(@Parameter String name, @TypeDef(type = DataType.JSON) List<String> appointments);
 }

data-jdbc/src/test/java/io/micronaut/data/jdbc/h2/H2PersonRepository.java

@@ -40,8 +40,10 @@ public H2PersonRepository(JdbcOperations jdbcOperations) {
         this.jdbcOperations = jdbcOperations;
     }
 
+    @Override
     public abstract Person save(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)")
     public abstract int saveCustom(String name, int age);
 
@@ -98,4 +100,4 @@ private Map<String, Object> getMap() throws SQLException {
         }
         return record;
     }
-}
+}

data-jdbc/src/test/java/io/micronaut/data/jdbc/mysql/MySqlPatientRepository.java

@@ -13,6 +13,7 @@
 @JdbcRepository(dialect = Dialect.MYSQL)
 public interface MySqlPatientRepository extends PatientRepository {
 
+    @Override
     @Query("UPDATE patient SET appointments = CONVERT(:appointments USING UTF8MB4) WHERE name = :name")
     void updateAppointmentsByName(@Parameter String name, @TypeDef(type = DataType.JSON) List<String> appointments);
 }

data-jdbc/src/test/java/io/micronaut/data/jdbc/mysql/MySqlPersonRepository.java

@@ -23,8 +23,10 @@
 @JdbcRepository(dialect = Dialect.MYSQL)
 public interface MySqlPersonRepository extends io.micronaut.data.tck.repositories.PersonRepository {
 
+    @Override
     Person save(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)")
     int saveCustom(String name, int age);
 

data-jdbc/src/test/java/io/micronaut/data/jdbc/oraclexe/OracleXEAuthorRepository.java

@@ -23,6 +23,7 @@
 
 @JdbcRepository(dialect = Dialect.ORACLE)
 public interface OracleXEAuthorRepository extends AuthorRepository {
+    @Override
     @Join(value = "books", type = Join.Type.LEFT_FETCH)
     Author queryByName(String name);
 }

data-jdbc/src/test/java/io/micronaut/data/jdbc/oraclexe/OracleXEBookRepository.java

@@ -36,9 +36,11 @@ public OracleXEBookRepository(OracleXEAuthorRepository authorRepository) {
         super(authorRepository);
     }
 
+    @Override
     @Query(value = "select * from book b where b.title = any (:arg0)", nativeQuery = true)
     public abstract List<Book> listNativeBooksWithTitleAnyCollection(@Nullable Collection<String> arg0);
 
+    @Override
     @Query(value = "select * from book b where b.title = ANY (:arg0)", nativeQuery = true)
     public abstract List<Book> listNativeBooksWithTitleAnyArray(@Expandable @TypeDef(type = DataType.STRING) @Nullable String[] arg0);
 

data-jdbc/src/test/java/io/micronaut/data/jdbc/oraclexe/OracleXEPersonRepository.java

@@ -26,14 +26,18 @@
 @JdbcRepository(dialect = Dialect.ORACLE)
 public interface OracleXEPersonRepository extends PersonRepository {
 
+    @Override
     Person save(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(id, name, age, enabled) VALUES (\"PERSON_SEQ\".nextval, :name, :age, 1)")
     int saveCustom(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(id, name, age, enabled) VALUES (\"PERSON_SEQ\".nextval, :name, :age, 1)")
     int saveCustom(List<Person> people);
 
+    @Override
     @Query("INSERT INTO person(id, name, age, enabled) VALUES (\"PERSON_SEQ\".nextval, :name, :age, 1)")
     int saveCustomSingle(Person people);
 

data-jdbc/src/test/java/io/micronaut/data/jdbc/postgres/PostgresAuthorRepository.java

@@ -27,6 +27,7 @@
 @JdbcRepository(dialect = Dialect.POSTGRES)
 public interface PostgresAuthorRepository extends AuthorRepository {
 
+    @Override
     @Join(value = "books", type = Join.Type.LEFT_FETCH)
     List<Author> listAll();
 

data-jdbc/src/test/java/io/micronaut/data/jdbc/postgres/PostgresPatientRepository.java

@@ -13,6 +13,7 @@
 @JdbcRepository(dialect = Dialect.POSTGRES)
 public interface PostgresPatientRepository extends PatientRepository {
 
+    @Override
     @Query("UPDATE patient SET appointments = to_json(:appointments::json) WHERE name = :name")
     void updateAppointmentsByName(@Parameter String name, @TypeDef(type = DataType.JSON) List<String> appointments);
 }

data-jdbc/src/test/java/io/micronaut/data/jdbc/postgres/PostgresPersonRepository.java

@@ -23,8 +23,10 @@
 @JdbcRepository(dialect = Dialect.POSTGRES)
 public interface PostgresPersonRepository extends io.micronaut.data.tck.repositories.PersonRepository {
 
+    @Override
     Person save(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, TRUE)")
     int saveCustom(String name, int age);
 

data-jdbc/src/test/java/io/micronaut/data/jdbc/sqlserver/MSSQLPersonRepository.java

@@ -26,14 +26,18 @@
 @JdbcRepository(dialect = Dialect.SQL_SERVER)
 public interface MSSQLPersonRepository extends PersonRepository {
 
+    @Override
     Person save(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, 1)")
     int saveCustom(String name, int age);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, 1)")
     int saveCustom(List<Person> people);
 
+    @Override
     @Query("INSERT INTO person(name, age, enabled) VALUES (:name, :age, 1)")
     int saveCustomSingle(Person people);
 

data-jpa/src/main/java/io/micronaut/data/jpa/repository/intercept/FindPageSpecificationInterceptor.java

@@ -59,6 +59,7 @@ protected FindPageSpecificationInterceptor(@NonNull RepositoryOperations operati
         }
     }
 
+    @Override
     protected final Pageable getPageable(MethodInvocationContext<?, ?> context) {
         final Object parameterValue = context.getParameterValues()[1];
         if (parameterValue instanceof Pageable) {

data-model/src/main/java/io/micronaut/data/model/DefaultSort.java

@@ -60,6 +60,7 @@ final class DefaultSort implements Sort {
      * @param order The order object
      * @return The Query instance
      */
+    @Override
     public @NonNull DefaultSort order(@NonNull Order order) {
         ArgumentUtils.requireNonNull("order", order);
         List<Order> newOrderBy = new ArrayList<>(orderBy);

data-model/src/main/java/io/micronaut/data/model/PersistentEntity.java

@@ -47,6 +47,7 @@ public interface PersistentEntity extends PersistentElement {
      *
      * @return The entity name
      */
+    @Override
     @NonNull String getName();
 
     /**

data-model/src/main/java/io/micronaut/data/model/PersistentProperty.java

@@ -39,6 +39,7 @@ public interface PersistentProperty extends PersistentElement {
      * The name of the property.
      * @return The property name
      */
+    @Override
     @NonNull String getName();
 
     /**

data-model/src/main/java/io/micronaut/data/model/jpa/criteria/impl/AbstractPersistentEntityJoinSupport.java

@@ -65,6 +65,7 @@ public abstract class AbstractPersistentEntityJoinSupport<J, E> implements Persi
 
     protected final Map<String, PersistentAssociationPath> joins = new LinkedHashMap<>();
 
+    @Override
     public abstract PersistentEntity getPersistentEntity();
 
     protected abstract <X, Y> PersistentAssociationPath<X, Y> createJoinAssociation(@NonNull Association association,

data-model/src/main/java/io/micronaut/data/model/query/DefaultQuery.java

@@ -284,6 +284,7 @@ DefaultQuery eq(@NonNull String property, @NonNull Object parameter) {
      * @param values The values
      * @return This query instance
      */
+    @Override
     public @NonNull
     DefaultQuery allEq(@NonNull Map<String, Object> values) {
         QueryModel.Junction conjunction = conjunction();

data-model/src/main/java/io/micronaut/data/model/query/builder/AbstractSqlLikeQueryBuilder.java

@@ -2260,6 +2260,7 @@ protected interface CriteriaContext extends PropertyParameterCreator {
 
         QueryPropertyPath getRequiredProperty(String name, Class<?> criterionClazz);
 
+        @Override
         default void pushParameter(@NonNull BindingParameter bindingParameter, @NonNull BindingParameter.BindingContext bindingContext) {
             getQueryState().pushParameter(bindingParameter, bindingContext);
         }

data-model/src/main/java/io/micronaut/data/model/query/builder/sql/SqlQueryBuilder.java

@@ -173,6 +173,7 @@ public SqlQueryBuilder(Dialect dialect) {
     /**
      * @return The dialect being used by the builder.
      */
+    @Override
     public Dialect getDialect() {
         return dialect;
     }

data-model/src/main/java/io/micronaut/data/model/runtime/PreparedQuery.java

@@ -57,5 +57,6 @@ default Map<String, Object> getQueryHints() {
      *
      * @return true if it is raw query
      */
+    @Override
     boolean isRawQuery();
 }

data-model/src/main/java/io/micronaut/data/model/runtime/StoredQuery.java

@@ -88,6 +88,7 @@ public interface StoredQuery<E, R> extends Named, StoredDataOperation<R> {
      *
      * @return The query result type
      */
+    @Override
     @NonNull
     Argument<R> getResultArgument();
 

data-model/src/main/java/io/micronaut/data/operations/reactive/BlockingExecutorReactorRepositoryOperations.java

@@ -48,6 +48,7 @@ public interface BlockingExecutorReactorRepositoryOperations extends RepositoryO
 
     <T> Optional<T> blockOptional(Function<ReactorReactiveRepositoryOperations, Mono<T>> supplier);
 
+    @Override
     @Nullable
     default <T> T findOne(@NonNull Class<T> type, @NonNull Object id) {
         return block(reactive -> reactive.findOne(type, id));

data-model/src/main/java/io/micronaut/data/operations/reactive/BlockingReactorRepositoryOperations.java

@@ -49,6 +49,7 @@ private ContextView getContextView() {
         return ReactorPropagation.addPropagatedContext(Context.empty(), PropagatedContext.getOrEmpty());
     }
 
+    @Override
     @Nullable
     default <T> T findOne(@NonNull Class<T> type, @NonNull Object id) {
         return reactive().findOne(type, id)

data-model/src/main/java/io/micronaut/data/operations/reactive/ReactorCriteriaCapableRepository.java

@@ -30,6 +30,7 @@ public interface ReactorCriteriaCapableRepository extends ReactiveCriteriaCapabl
     /**
      * @return The reactive operations.
      */
+    @Override
     @NonNull
     ReactorCriteriaRepositoryOperations reactive();
 }