optmizes for each

otaviojava · otaviojava · commit bd1ba251e252 · 2018-09-19T04:35:17.000-03:00
diff --git a/artemis-column/src/main/java/org/jnosql/artemis/column/query/AbstractColumnRepositoryAsyncProxy.java b/artemis-column/src/main/java/org/jnosql/artemis/column/query/AbstractColumnRepositoryAsyncProxy.java
@@ -76,7 +76,7 @@ private Object getJnosqlQuery(Method method, Object[] args) {
             getTemplate().query(value, consumer);
         } else {
             PreparedStatementAsync prepare = getTemplate().prepare(value);
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             prepare.getResultList(consumer);
         }
 
diff --git a/artemis-column/src/main/java/org/jnosql/artemis/column/query/AbstractColumnRepositoryProxy.java b/artemis-column/src/main/java/org/jnosql/artemis/column/query/AbstractColumnRepositoryProxy.java
@@ -82,7 +82,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)
             entities = getTemplate().query(value);
         } else {
             PreparedStatement prepare = getTemplate().prepare(value);
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             entities = prepare.getResultList();
         }
         return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);
diff --git a/artemis-column/src/main/java/org/jnosql/artemis/column/spi/ColumnFamilyProducerExtension.java b/artemis-column/src/main/java/org/jnosql/artemis/column/spi/ColumnFamilyProducerExtension.java
@@ -31,6 +31,7 @@
 import javax.enterprise.inject.spi.ProcessAnnotatedType;
 import javax.enterprise.inject.spi.ProcessProducer;
 import java.lang.reflect.Modifier;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
@@ -61,7 +62,7 @@ <T extends Repository> void onProcessAnnotatedType(@Observes final ProcessAnnota
         if (Repository.class.equals(javaClass)) {
             return;
         }
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(Repository.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(Repository.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new Repository as discovered on Column: " + javaClass);
             crudTypes.add(javaClass);
@@ -73,7 +74,7 @@ <T extends RepositoryAsync> void onProcessAnnotatedTypeAsync(@Observes final Pro
         if (RepositoryAsync.class.equals(javaClass)) {
             return;
         }
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(RepositoryAsync.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(RepositoryAsync.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new RepositoryAsync as discovered on Column: " + javaClass);
             crudAsyncTypes.add(javaClass);
diff --git a/artemis-core/src/main/java/org/jnosql/artemis/reflection/DefaultClassRepresentations.java b/artemis-core/src/main/java/org/jnosql/artemis/reflection/DefaultClassRepresentations.java
@@ -54,7 +54,7 @@ public void init() {
 
         classes.putAll(extension.getClasses());
         representations.putAll(extension.getRepresentations());
-        representations.values().stream().forEach(r -> {
+        representations.values().forEach(r -> {
             Class<?> entityClass = r.getClassInstance();
             findBySimpleName.put(entityClass.getSimpleName(), r);
             findByClassName.put(entityClass.getName(), r);
diff --git a/artemis-document/src/main/java/org/jnosql/artemis/document/query/AbstractDocumentRepositoryAsyncProxy.java b/artemis-document/src/main/java/org/jnosql/artemis/document/query/AbstractDocumentRepositoryAsyncProxy.java
@@ -100,7 +100,7 @@ private Object getJnosqlQuery(Method method, Object[] args) {
             getTemplate().query(value, consumer);
         } else {
             PreparedStatementAsync prepare = getTemplate().prepare(value);
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             prepare.getResultList(consumer);
         }
 
diff --git a/artemis-document/src/main/java/org/jnosql/artemis/document/query/AbstractDocumentRepositoryProxy.java b/artemis-document/src/main/java/org/jnosql/artemis/document/query/AbstractDocumentRepositoryProxy.java
@@ -80,7 +80,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)
             entities = getTemplate().query(value);
         } else {
             PreparedStatement prepare = getTemplate().prepare(value);
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             entities = prepare.getResultList();
         }
         return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);
diff --git a/artemis-document/src/main/java/org/jnosql/artemis/document/spi/DocumentCollectionProducerExtension.java b/artemis-document/src/main/java/org/jnosql/artemis/document/spi/DocumentCollectionProducerExtension.java
@@ -31,6 +31,7 @@
 import javax.enterprise.inject.spi.ProcessAnnotatedType;
 import javax.enterprise.inject.spi.ProcessProducer;
 import java.lang.reflect.Modifier;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
@@ -63,7 +64,7 @@ <T extends Repository> void onProcessAnnotatedType(@Observes final ProcessAnnota
         }
 
 
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(Repository.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(Repository.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new Repository as discovered on document: " + javaClass);
             crudTypes.add(javaClass);
@@ -77,7 +78,7 @@ <T extends RepositoryAsync> void onProcessAnnotatedTypeAsync(@Observes final Pro
             return;
         }
 
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(RepositoryAsync.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(RepositoryAsync.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new RepositoryAsync as discovered on document: " + javaClass);
             crudAsyncTypes.add(javaClass);
diff --git a/artemis-graph/src/main/java/org/jnosql/artemis/graph/query/AbstractGraphRepositoryProxy.java b/artemis-graph/src/main/java/org/jnosql/artemis/graph/query/AbstractGraphRepositoryProxy.java
@@ -128,7 +128,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)
             entities = getTemplate().query(value);
         } else {
             PreparedStatement prepare = getTemplate().prepare(value);
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             entities = prepare.getResultList();
         }
         return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);
diff --git a/artemis-graph/src/main/java/org/jnosql/artemis/graph/spi/GraphProducerExtension.java b/artemis-graph/src/main/java/org/jnosql/artemis/graph/spi/GraphProducerExtension.java
@@ -27,6 +27,7 @@
 import javax.enterprise.inject.spi.ProcessAnnotatedType;
 import javax.enterprise.inject.spi.ProcessProducer;
 import java.lang.reflect.Modifier;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
@@ -53,7 +54,7 @@ <T extends Repository> void onProcessAnnotatedType(@Observes final ProcessAnnota
         if (Repository.class.equals(javaClass)) {
             return;
         }
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(Repository.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(Repository.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new Repository as discovered on Graph: " + javaClass);
             crudTypes.add(javaClass);
diff --git a/artemis-key-value/src/main/java/org/jnosql/artemis/key/query/AbstractKeyValueRepositoryProxy.java b/artemis-key-value/src/main/java/org/jnosql/artemis/key/query/AbstractKeyValueRepositoryProxy.java
@@ -62,7 +62,7 @@ private Object executeQuery(Method method, Object[] args, String query) {
             entities = getTemplate().query(query, getEntityClass());
         } else {
             PreparedStatement prepare = getTemplate().prepare(query, getEntityClass());
-            params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
+            params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));
             entities = prepare.getResultList();
         }
         return ReturnTypeConverterUtil.returnObject(entities, getEntityClass(), method);
diff --git a/artemis-key-value/src/main/java/org/jnosql/artemis/key/spi/BucketManagerProducerExtension.java b/artemis-key-value/src/main/java/org/jnosql/artemis/key/spi/BucketManagerProducerExtension.java
@@ -28,6 +28,7 @@
 import javax.enterprise.inject.spi.ProcessAnnotatedType;
 import javax.enterprise.inject.spi.ProcessProducer;
 import java.lang.reflect.Modifier;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.Set;
@@ -59,7 +60,7 @@ <T extends Repository> void onProcessAnnotatedType(@Observes final ProcessAnnota
             return;
         }
 
-        if (Stream.of(javaClass.getInterfaces()).anyMatch(Repository.class::equals)
+        if (Arrays.asList(javaClass.getInterfaces()).contains(Repository.class)
                 && Modifier.isInterface(javaClass.getModifiers())) {
             LOGGER.info("Adding a new KeyValueRepository as discovered on Column: " + javaClass);
             crudTypes.add(repo.getAnnotatedType().getJavaClass());
diff --git a/artemis-validation/src/main/java/org/jnosql/artemis/validation/DefaultArtemisValidator.java b/artemis-validation/src/main/java/org/jnosql/artemis/validation/DefaultArtemisValidator.java
@@ -22,6 +22,7 @@
 import javax.validation.Validation;
 import javax.validation.Validator;
 import javax.validation.ValidatorFactory;
+import java.util.HashSet;
 import java.util.Set;
 
 import static java.util.stream.Collectors.toSet;
@@ -39,7 +40,7 @@ public void validate(Object bean) {
         Set<ConstraintViolation<Object>> violations = validator.validate(bean);
 
         if (!violations.isEmpty()) {
-            throw new ConstraintViolationException(violations.stream().collect(toSet()));
+            throw new ConstraintViolationException(new HashSet<>(violations));
         }
 
     }

Original file line number	Diff line number	Diff line change
`@@ -76,7 +76,7 @@ private Object getJnosqlQuery(Method method, Object[] args) {`
`76`	`76`	`getTemplate().query(value, consumer);`
`77`	`77`	`} else {`
`78`	`78`	`PreparedStatementAsync prepare = getTemplate().prepare(value);`
`79`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`79`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`80`	`80`	`prepare.getResultList(consumer);`
`81`	`81`	`}`
`82`	`82`
Original file line number	Diff line number	Diff line change
`@@ -82,7 +82,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)`
`82`	`82`	`entities = getTemplate().query(value);`
`83`	`83`	`} else {`
`84`	`84`	`PreparedStatement prepare = getTemplate().prepare(value);`
`85`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`85`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`86`	`86`	`entities = prepare.getResultList();`
`87`	`87`	`}`
`88`	`88`	`return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);`
Original file line number	Diff line number	Diff line change
`@@ -100,7 +100,7 @@ private Object getJnosqlQuery(Method method, Object[] args) {`
`100`	`100`	`getTemplate().query(value, consumer);`
`101`	`101`	`} else {`
`102`	`102`	`PreparedStatementAsync prepare = getTemplate().prepare(value);`
`103`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`103`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`104`	`104`	`prepare.getResultList(consumer);`
`105`	`105`	`}`
`106`	`106`
Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)`
`80`	`80`	`entities = getTemplate().query(value);`
`81`	`81`	`} else {`
`82`	`82`	`PreparedStatement prepare = getTemplate().prepare(value);`
`83`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`83`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`84`	`84`	`entities = prepare.getResultList();`
`85`	`85`	`}`
`86`	`86`	`return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);`
Original file line number	Diff line number	Diff line change
`@@ -128,7 +128,7 @@ private Object getJnosqlQuery(Method method, Object[] args, Class<?> typeClass)`
`128`	`128`	`entities = getTemplate().query(value);`
`129`	`129`	`} else {`
`130`	`130`	`PreparedStatement prepare = getTemplate().prepare(value);`
`131`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`131`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`132`	`132`	`entities = prepare.getResultList();`
`133`	`133`	`}`
`134`	`134`	`return ReturnTypeConverterUtil.returnObject(entities, typeClass, method);`
Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ private Object executeQuery(Method method, Object[] args, String query) {`
`62`	`62`	`entities = getTemplate().query(query, getEntityClass());`
`63`	`63`	`} else {`
`64`	`64`	`PreparedStatement prepare = getTemplate().prepare(query, getEntityClass());`
`65`		`- params.entrySet().stream().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
	`65`	`+ params.entrySet().forEach(e -> prepare.bind(e.getKey(), e.getValue()));`
`66`	`66`	`entities = prepare.getResultList();`
`67`	`67`	`}`
`68`	`68`	`return ReturnTypeConverterUtil.returnObject(entities, getEntityClass(), method);`