Merge remote-tracking branch 'eugenp/master'

2019-02-18 16:53:26 +02:00
parent e9c0d901b3 6c237aaf3a
commit c23f5e1840
71 changed files with 1518 additions and 320 deletions
@@ -66,3 +66,10 @@ jmeter/src/main/resources/*-JMeter.csv
 **/nb-configuration.xml
 core-scala/.cache-main
 core-scala/.cache-tests
+
+
+persistence-modules/hibernate5/transaction.log
+apache-avro/src/main/java/com/baeldung/avro/model/
+jta/transaction-logs/
+software-security/sql-injection-samples/derby.log
+spring-soap/src/main/java/com/baeldung/springsoap/gen/
@@ -0,0 +1,8 @@
+package com.baeldung.traits
+
+trait AnimalTrait {
+    
+    String basicBehavior() {
+        return "Animalistic!!"
+    }
+}
@@ -0,0 +1,9 @@
+package com.baeldung.traits
+
+class Dog implements WalkingTrait, SpeakingTrait {
+     
+    String speakAndWalk() {
+        WalkingTrait.super.speakAndWalk()
+    }
+    
+}
@@ -0,0 +1,12 @@
+package com.baeldung.traits
+
+class Employee implements UserTrait {
+    
+    String name() {
+        return 'Bob'
+    }
+    
+    String lastName() {
+        return "Marley"
+    }
+}
@@ -0,0 +1,6 @@
+package com.baeldung.traits
+
+interface Human {
+    
+    String lastName()
+}
@@ -0,0 +1,13 @@
+package com.baeldung.traits
+
+trait SpeakingTrait {
+    
+    String basicAbility() {
+        return "Speaking!!"
+    }
+    
+    String speakAndWalk() {
+        return "Speak and walk!!"
+    }
+    
+}
@@ -0,0 +1,36 @@
+package com.baeldung.traits
+
+trait UserTrait implements Human {
+    
+    String sayHello() {
+        return "Hello!"
+    }
+    
+    abstract String name()
+    
+    String showName() {
+       return "Hello, ${name()}!"
+    }
+
+    private String greetingMessage() {
+        return 'Hello, from a private method!'
+    }
+    
+    String greet() {
+        def msg = greetingMessage()
+        println msg
+        msg
+    }
+    
+    def whoAmI() {
+        return this 
+    }
+    
+    String showLastName() {
+        return "Hello, ${lastName()}!"
+    }
+    
+    String email
+    String address
+}
+    
@@ -0,0 +1,13 @@
+package com.baeldung.traits
+
+trait WalkingTrait {
+    
+    String basicAbility() {
+        return "Walking!!"
+    }
+    
+    String speakAndWalk() {
+        return "Walk and speak!!"
+    }
+    
+}
@@ -0,0 +1,114 @@
+package com.baeldung.traits
+
+import spock.lang.Specification
+
+class TraitsUnitTest extends Specification {
+
+    Employee employee
+    Dog dog
+
+    void setup () {
+        employee = new Employee()
+        dog = new Dog()
+    }
+
+    def 'Should return msg string when using Employee.sayHello method provided by UserTrait' () {
+        when:
+            def msg = employee.sayHello()
+        then:
+            msg
+            msg instanceof String
+            assert msg == "Hello!"
+    }
+    
+    def 'Should return displayMsg string when using Employee.showName method' () {
+        when:
+            def displayMsg = employee.showName()
+        then:
+            displayMsg
+            displayMsg instanceof String
+            assert displayMsg == "Hello, Bob!"
+    }
+    
+    def 'Should return greetMsg string when using Employee.greet method' () {
+        when:
+            def greetMsg = employee.greet()
+        then:
+            greetMsg
+            greetMsg instanceof String
+            assert greetMsg == "Hello, from a private method!"
+    }
+    
+    def 'Should return MissingMethodException when using Employee.greetingMessage method' () {
+        when:
+            def exception
+            try {
+                employee.greetingMessage()
+            }catch(Exception e) {
+                exception = e
+            }
+            
+        then:
+            exception
+            exception instanceof groovy.lang.MissingMethodException
+            assert exception.message == "No signature of method: com.baeldung.traits.Employee.greetingMessage()"+
+            " is applicable for argument types: () values: []"
+    }
+    
+    def 'Should return employee instance when using Employee.whoAmI method' () {
+        when:
+            def emp = employee.whoAmI()
+        then:
+            emp
+            emp instanceof Employee
+            assert emp.is(employee)
+    }
+    
+    def 'Should display lastName when using Employee.showLastName method' () {
+        when:
+            def lastNameMsg = employee.showLastName()
+        then:
+            lastNameMsg
+            lastNameMsg instanceof String
+            assert lastNameMsg == "Hello, Marley!"
+    }
+    
+    def 'Should be able to define properties of UserTrait in Employee instance' () {
+        when:
+            employee = new Employee(email: "[email protected]", address: "baeldung.com")
+        then:
+            employee
+            employee instanceof Employee
+            assert employee.email == "[email protected]"
+            assert employee.address == "baeldung.com"
+    }
+    
+    def 'Should execute basicAbility method from SpeakingTrait and return msg string' () {
+        when:
+            def speakMsg = dog.basicAbility()
+        then:
+            speakMsg
+            speakMsg instanceof String
+            assert speakMsg == "Speaking!!"
+    }
+    
+    def 'Should verify multiple inheritance with traits and execute overridden traits method' () {
+        when:
+            def walkSpeakMsg = dog.speakAndWalk()
+            println walkSpeakMsg
+        then:
+            walkSpeakMsg
+            walkSpeakMsg instanceof String
+            assert walkSpeakMsg == "Walk and speak!!"
+    }
+    
+    def 'Should implement AnimalTrait at runtime and access basicBehavior method' () {
+        when:
+            def dogInstance = new Dog() as AnimalTrait
+            def basicBehaviorMsg = dogInstance.basicBehavior()
+        then:
+            basicBehaviorMsg
+            basicBehaviorMsg instanceof String
+            assert basicBehaviorMsg == "Animalistic!!"
+    }
+}
@@ -0,0 +1,13 @@
+package com.baeldung.customannotations;
+
+import static java.lang.annotation.ElementType.METHOD;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+@Retention(RUNTIME)
+@Target(METHOD)
+public @interface Init {
+
+}
@@ -0,0 +1,13 @@
+package com.baeldung.customannotations;
+
+import static java.lang.annotation.ElementType.FIELD;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+@Retention(RUNTIME)
+@Target({ FIELD })
+public @interface JsonElement {
+    public String key() default "";
+}
@@ -0,0 +1,13 @@
+package com.baeldung.customannotations;
+
+import static java.lang.annotation.ElementType.TYPE;
+import static java.lang.annotation.RetentionPolicy.RUNTIME;
+
+import java.lang.annotation.Retention;
+import java.lang.annotation.Target;
+
+@Retention(RUNTIME)
+@Target(TYPE)
+public @interface JsonSerializable {
+
+}
@@ -0,0 +1,10 @@
+package com.baeldung.customannotations;
+
+public class JsonSerializationException extends RuntimeException {
+
+    private static final long serialVersionUID = 1L;
+
+    public JsonSerializationException(String message) {
+        super(message);
+    }
+}
@@ -0,0 +1,67 @@
+package com.baeldung.customannotations;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+public class ObjectToJsonConverter {
+    public String convertToJson(Object object) throws JsonSerializationException {
+        try {
+
+            checkIfSerializable(object);
+            initializeObject(object);
+            return getJsonString(object);
+
+        } catch (Exception e) {
+            throw new JsonSerializationException(e.getMessage());
+        }
+    }
+
+    private void checkIfSerializable(Object object) {
+        if (Objects.isNull(object)) {
+            throw new JsonSerializationException("Can't serialize a null object");
+        }
+
+        Class<?> clazz = object.getClass();
+        if (!clazz.isAnnotationPresent(JsonSerializable.class)) {
+            throw new JsonSerializationException("The class " + clazz.getSimpleName() + " is not annotated with JsonSerializable");
+        }
+    }
+
+    private void initializeObject(Object object) throws IllegalAccessException, IllegalArgumentException, InvocationTargetException {
+        Class<?> clazz = object.getClass();
+        for (Method method : clazz.getDeclaredMethods()) {
+            if (method.isAnnotationPresent(Init.class)) {
+                method.setAccessible(true);
+                method.invoke(object);
+            }
+        }
+    }
+
+    private String getJsonString(Object object) throws IllegalArgumentException, IllegalAccessException {
+        Class<?> clazz = object.getClass();
+        Map<String, String> jsonElementsMap = new HashMap<>();
+        for (Field field : clazz.getDeclaredFields()) {
+            field.setAccessible(true);
+            if (field.isAnnotationPresent(JsonElement.class)) {
+                jsonElementsMap.put(getKey(field), (String) field.get(object));
+            }
+        }
+
+        String jsonString = jsonElementsMap.entrySet()
+            .stream()
+            .map(entry -> "\"" + entry.getKey() + "\":\"" + entry.getValue() + "\"")
+            .collect(Collectors.joining(","));
+        return "{" + jsonString + "}";
+    }
+
+    private String getKey(Field field) {
+        String value = field.getAnnotation(JsonElement.class)
+            .key();
+        return value.isEmpty() ? field.getName() : value;
+    }
+}
@@ -0,0 +1,66 @@
+package com.baeldung.customannotations;
+
+@JsonSerializable
+public class Person {
+    @JsonElement
+    private String firstName;
+    @JsonElement
+    private String lastName;
+    @JsonElement(key = "personAge")
+    private String age;
+
+    private String address;
+
+    public Person(String firstName, String lastName) {
+        super();
+        this.firstName = firstName;
+        this.lastName = lastName;
+    }
+
+    public Person(String firstName, String lastName, String age) {
+        this.firstName = firstName;
+        this.lastName = lastName;
+        this.age = age;
+    }
+
+    @Init
+    private void initNames() {
+        this.firstName = this.firstName.substring(0, 1)
+            .toUpperCase() + this.firstName.substring(1);
+        this.lastName = this.lastName.substring(0, 1)
+            .toUpperCase() + this.lastName.substring(1);
+    }
+
+    public String getFirstName() {
+        return firstName;
+    }
+
+    public void setFirstName(String firstName) {
+        this.firstName = firstName;
+    }
+
+    public String getLastName() {
+        return lastName;
+    }
+
+    public void setLastName(String lastName) {
+        this.lastName = lastName;
+    }
+
+    public String getAge() {
+        return age;
+    }
+
+    public void setAge(String age) {
+        this.age = age;
+    }
+
+    public String getAddress() {
+        return address;
+    }
+
+    public void setAddress(String address) {
+        this.address = address;
+    }
+
+}
@@ -85,10 +85,16 @@ public class Java8CollectorsUnitTest {
    }

    @Test
-    public void whenCollectingToMap_shouldCollectToMapMerging() throws Exception {
-        final Map<String, Integer> result = givenList.stream().collect(toMap(Function.identity(), String::length, (i1, i2) -> i1));
+    public void whenCollectingToMapwWithDuplicates_shouldCollectToMapMergingTheIdenticalItems() throws Exception {
+        final Map<String, Integer> result = listWithDuplicates.stream().collect(
+          toMap(
+            Function.identity(),
+            String::length,
+            (item, identicalItem) -> item
+          )
+        );

-        assertThat(result).containsEntry("a", 1).containsEntry("bb", 2).containsEntry("ccc", 3).containsEntry("dd", 2);
+        assertThat(result).containsEntry("a", 1).containsEntry("bb", 2).containsEntry("c", 1).containsEntry("d", 1);
    }

    @Test
@@ -0,0 +1,26 @@
+package com.baeldung.customannotations;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+
+import org.junit.jupiter.api.Test;
+
+public class JsonSerializerUnitTest {
+
+    @Test
+    public void givenObjectNotSerializedThenExceptionThrown() throws JsonSerializationException {
+        Object object = new Object();
+        ObjectToJsonConverter serializer = new ObjectToJsonConverter();
+        assertThrows(JsonSerializationException.class, () -> {
+            serializer.convertToJson(object);
+        });
+    }
+
+    @Test
+    public void givenObjectSerializedThenTrueReturned() throws JsonSerializationException {
+        Person person = new Person("soufiane", "cheouati", "34");
+        ObjectToJsonConverter serializer = new ObjectToJsonConverter();
+        String jsonString = serializer.convertToJson(person);
+        assertEquals("{\"personAge\":\"34\",\"firstName\":\"Soufiane\",\"lastName\":\"Cheouati\"}", jsonString);
+    }
+}
@@ -0,0 +1,16 @@
+package com.baeldung.multireleaseapp;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class App {
+
+    private static final Logger logger = LoggerFactory.getLogger(App.class);
+    
+    public static void main(String[] args) throws Exception {
+        String dateToCheck = args[0];
+        boolean isLeapYear = DateHelper.checkIfLeapYear(dateToCheck);
+        logger.info("Date given " + dateToCheck + " is leap year: " + isLeapYear);
+    }
+
+}
@@ -0,0 +1,22 @@
+package com.baeldung.multireleaseapp;
+
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.GregorianCalendar;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DateHelper {
+
+    private static final Logger logger = LoggerFactory.getLogger(DateHelper.class);
+
+    public static boolean checkIfLeapYear(String dateStr) throws Exception {
+        logger.info("Checking for leap year using Java 1 calendar API");
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(new SimpleDateFormat("yyyy-MM-dd").parse(dateStr));
+        int year = cal.get(Calendar.YEAR);
+        return (new GregorianCalendar()).isLeapYear(year);
+    }
+
+}
@@ -0,0 +1,18 @@
+package com.baeldung.multireleaseapp;
+
+import java.time.LocalDate;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DateHelper {
+
+    private static final Logger logger = LoggerFactory.getLogger(DateHelper.class);
+
+    public static boolean checkIfLeapYear(String dateStr) throws Exception {
+        logger.info("Checking for leap year using Java 9 Date Api");
+        return LocalDate.parse(dateStr)
+            .isLeapYear();
+    }
+
+}
@@ -0,0 +1,55 @@
+package com.baeldung.allequalelements;
+
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.List;
+import org.apache.commons.collections4.IterableUtils;
+import com.google.common.base.Predicate;
+import com.google.common.collect.Iterables;
+
+public class VerifyAllEqualListElements {
+
+    public boolean verifyAllEqualUsingALoop(List<String> list) {
+        for (String s : list) {
+            if (!s.equals(list.get(0)))
+                return false;
+        }
+        return true;
+    }
+
+    public boolean verifyAllEqualUsingHashSet(List<String> list) {
+        return new HashSet<String>(list).size() <= 1;
+    }
+
+    public boolean verifyAllEqualUsingFrequency(List<String> list) {
+        return list.isEmpty() || Collections.frequency(list, list.get(0)) == list.size();
+    }
+
+    public boolean verifyAllEqualUsingStream(List<String> list) {
+        return list.stream()
+            .distinct()
+            .count() <= 1;
+    }
+
+    public boolean verifyAllEqualAnotherUsingStream(List<String> list) {
+        return list.isEmpty() || list.stream()
+            .allMatch(list.get(0)::equals);
+    }
+
+    public boolean verifyAllEqualUsingGuava(List<String> list) {
+        return Iterables.all(list, new Predicate<String>() {
+            public boolean apply(String s) {
+                return s.equals(list.get(0));
+            }
+        });
+    }
+
+    public boolean verifyAllEqualUsingApacheCommon(List<String> list) {
+        return IterableUtils.matchesAll(list, new org.apache.commons.collections4.Predicate<String>() {
+            public boolean evaluate(String s) {
+                return s.equals(list.get(0));
+            }
+        });
+    }
+
+}
@@ -0,0 +1,172 @@
+package com.baeldung.allequalelements;
+
+import org.junit.Test;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+import static org.junit.Assert.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+public class VerifyAllEqualListElementsUnitTest {
+
+    private static List<String> notAllEqualList = new ArrayList<>();
+
+    private static List<String> emptyList = new ArrayList<>();
+
+    private static List<String> allEqualList = new ArrayList<>();
+
+    static {
+        notAllEqualList = Arrays.asList("Jack", "James", "Sam", "James");
+        emptyList = Arrays.asList();
+        allEqualList = Arrays.asList("Jack", "Jack", "Jack", "Jack");
+    }
+
+    private static VerifyAllEqualListElements verifyAllEqualListElements = new VerifyAllEqualListElements();
+
+    @Test
+    public void givenNotAllEqualList_whenUsingALoop_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingALoop(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingALoop_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingALoop(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingALoop_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingALoop(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingHashSet_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingHashSet(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingHashSet_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingHashSet(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingHashSet_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingHashSet(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingFrequency_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingFrequency(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingFrequency_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingFrequency(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingFrequency_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingFrequency(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingStream_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingStream(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingStream_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingStream(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingStream_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingStream(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingAnotherStream_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualAnotherUsingStream(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingAnotherStream_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualAnotherUsingStream(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingAnotherStream_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualAnotherUsingStream(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingGuava_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingGuava(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingGuava_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingGuava(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingGuava_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingGuava(allEqualList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenNotAllEqualList_whenUsingApacheCommon_thenReturnFalse() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingApacheCommon(notAllEqualList);
+
+        assertFalse(allEqual);
+    }
+
+    @Test
+    public void givenEmptyList_whenUsingApacheCommon_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingApacheCommon(emptyList);
+
+        assertTrue(allEqual);
+    }
+
+    @Test
+    public void givenAllEqualList_whenUsingApacheCommon_thenReturnTrue() {
+        boolean allEqual = verifyAllEqualListElements.verifyAllEqualUsingApacheCommon(allEqualList);
+
+        assertTrue(allEqual);
+    }
+}
@@ -5,6 +5,7 @@ import static org.junit.Assert.assertTrue;

 import java.io.File;
 import java.io.FileNotFoundException;
+import java.io.IOException;
 import java.io.PrintWriter;
 import java.util.ArrayList;
 import java.util.List;
@@ -17,7 +18,6 @@ import org.slf4j.LoggerFactory;
 public class WriteCsvFileExampleUnitTest {
    private static final Logger LOG = LoggerFactory.getLogger(WriteCsvFileExampleUnitTest.class);

-    private static final String CSV_FILE_NAME = "src/test/resources/exampleOutput.csv";
    private WriteCsvFileExample csvExample;

    @Before
@@ -65,12 +65,12 @@ public class WriteCsvFileExampleUnitTest {
    }

    @Test
-    public void givenDataArray_whenConvertToCSV_thenOutputCreated() {
+    public void givenDataArray_whenConvertToCSV_thenOutputCreated() throws IOException {
        List<String[]> dataLines = new ArrayList<String[]>();
        dataLines.add(new String[] { "John", "Doe", "38", "Comment Data\nAnother line of comment data" });
        dataLines.add(new String[] { "Jane", "Doe, Jr.", "19", "She said \"I'm being quoted\"" });

-        File csvOutputFile = new File(CSV_FILE_NAME);
+        File csvOutputFile = File.createTempFile("exampleOutput", ".csv");
        try (PrintWriter pw = new PrintWriter(csvOutputFile)) {
            dataLines.stream()
                .map(csvExample::convertToCSV)
@@ -80,5 +80,6 @@ public class WriteCsvFileExampleUnitTest {
        }

        assertTrue(csvOutputFile.exists());
+        csvOutputFile.deleteOnExit();
    }
 }
@@ -1,2 +0,0 @@
-John,Doe,38,Comment Data Another line of comment data
-Jane,"Doe, Jr.",19,"She said ""I'm being quoted"""
@@ -0,0 +1,83 @@
+package com.baeldung.stream;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+public class StreamMapUnitTest {
+
+    private Map<String, String> books;
+
+    @Before
+    public void setup() {
+        books = new HashMap<>();
+        books.put("978-0201633610", "Design patterns : elements of reusable object-oriented software");
+        books.put("978-1617291999", "Java 8 in Action: Lambdas, Streams, and functional-style programming");
+        books.put("978-0134685991", "Effective Java");
+    }
+
+
+    @Test
+    public void whenOptionalVersionCalledForExistingTitle_thenReturnOptionalWithISBN() {
+        Optional<String> optionalIsbn = books.entrySet().stream()
+                .filter(e -> "Effective Java".equals(e.getValue()))
+                .map(Map.Entry::getKey).findFirst();
+
+        assertEquals("978-0134685991", optionalIsbn.get());
+    }
+
+    @Test
+    public void whenOptionalVersionCalledForNonExistingTitle_thenReturnEmptyOptionalForISBN() {
+        Optional<String> optionalIsbn = books.entrySet().stream()
+                .filter(e -> "Non Existent Title".equals(e.getValue()))
+                .map(Map.Entry::getKey).findFirst();
+
+        assertEquals(false, optionalIsbn.isPresent());
+    }
+
+    @Test
+    public void whenMultipleResultsVersionCalledForExistingTitle_aCollectionWithMultipleValuesIsReturned() {
+        books.put("978-0321356680", "Effective Java: Second Edition");
+
+        List<String> isbnCodes = books.entrySet().stream()
+                .filter(e -> e.getValue().startsWith("Effective Java"))
+                .map(Map.Entry::getKey)
+                .collect(Collectors.toList());
+
+        assertTrue(isbnCodes.contains("978-0321356680"));
+        assertTrue(isbnCodes.contains("978-0134685991"));
+    }
+
+    @Test
+    public void whenMultipleResultsVersionCalledForNonExistingTitle_aCollectionWithNoValuesIsReturned() {
+        List<String> isbnCodes = books.entrySet().stream()
+                .filter(e -> e.getValue().startsWith("Spring"))
+                .map(Map.Entry::getKey)
+                .collect(Collectors.toList());
+
+        assertTrue(isbnCodes.isEmpty());
+    }
+
+    @Test
+    public void whenKeysFollowingPatternReturnsAllValuesForThoseKeys() {
+        List<String> titlesForKeyPattern = books.entrySet().stream()
+                .filter(e -> e.getKey().startsWith("978-0"))
+                .map(Map.Entry::getValue)
+                .collect(Collectors.toList());
+        assertEquals(2, titlesForKeyPattern.size());
+        assertTrue(titlesForKeyPattern.contains("Design patterns : elements of reusable object-oriented software"));
+        assertTrue(titlesForKeyPattern.contains("Effective Java"));
+    }
+    
+}
@@ -73,6 +73,16 @@
            <artifactId>hibernate-jpamodelgen</artifactId>
            <version>${hibernate.version}</version>
        </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-core</artifactId>
+            <version>${openjdk-jmh.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-generator-annprocess</artifactId>
+            <version>${openjdk-jmh.version}</version>
+        </dependency>
    </dependencies>

    <build>
@@ -92,6 +102,7 @@
        <h2database.version>1.4.196</h2database.version>
        <assertj-core.version>3.8.0</assertj-core.version>
        <jackson.version>2.9.7</jackson.version>
+        <openjdk-jmh.version>1.21</openjdk-jmh.version>
    </properties>

 </project>
@@ -68,6 +68,11 @@ public class HibernateUtil {
        return sessionFactory;
    }

+    public static SessionFactory getSessionFactoryByProperties(Properties properties) throws IOException {
+        ServiceRegistry serviceRegistry = configureServiceRegistry(properties);
+        return makeSessionFactory(serviceRegistry);
+    }
+
    private static SessionFactory makeSessionFactory(ServiceRegistry serviceRegistry) {
        MetadataSources metadataSources = new MetadataSources(serviceRegistry);

@@ -119,12 +124,15 @@ public class HibernateUtil {
    }

    private static ServiceRegistry configureServiceRegistry() throws IOException {
-        Properties properties = getProperties();
+        return configureServiceRegistry(getProperties());
+    }
+
+    private static ServiceRegistry configureServiceRegistry(Properties properties) throws IOException {
        return new StandardServiceRegistryBuilder().applySettings(properties)
                .build();
    }

-    private static Properties getProperties() throws IOException {
+    public static Properties getProperties() throws IOException {
        Properties properties = new Properties();
        URL propertiesURL = Thread.currentThread()
          .getContextClassLoader()
@@ -0,0 +1,106 @@
+package com.baeldung.hibernate.queryplancache;
+
+import com.baeldung.hibernate.HibernateUtil;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.hibernate.jpa.QueryHints;
+import org.hibernate.query.Query;
+import org.openjdk.jmh.annotations.Benchmark;
+import org.openjdk.jmh.annotations.BenchmarkMode;
+import org.openjdk.jmh.annotations.Fork;
+import org.openjdk.jmh.annotations.Measurement;
+import org.openjdk.jmh.annotations.Mode;
+import org.openjdk.jmh.annotations.OutputTimeUnit;
+import org.openjdk.jmh.annotations.Param;
+import org.openjdk.jmh.annotations.Scope;
+import org.openjdk.jmh.annotations.Setup;
+import org.openjdk.jmh.annotations.State;
+import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.annotations.Warmup;
+import org.openjdk.jmh.infra.Blackhole;
+import org.openjdk.jmh.runner.RunnerException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.util.Properties;
+import java.util.concurrent.TimeUnit;
+
+public class QueryPlanCacheBenchmark {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(QueryPlanCacheBenchmark.class);
+
+    @State(Scope.Thread)
+    public static class QueryPlanCacheBenchMarkState {
+        @Param({"1", "2", "3"})
+        public int planCacheSize;
+
+        public Session session;
+
+        @Setup
+        public void stateSetup() throws IOException {
+            LOGGER.info("State - Setup");
+            session = initSession(planCacheSize);
+            LOGGER.info("State - Setup Complete");
+        }
+
+        private Session initSession(int planCacheSize) throws IOException {
+            Properties properties = HibernateUtil.getProperties();
+            properties.put("hibernate.query.plan_cache_max_size", planCacheSize);
+            properties.put("hibernate.query.plan_parameter_metadata_max_size", planCacheSize);
+            SessionFactory sessionFactory = HibernateUtil.getSessionFactoryByProperties(properties);
+            return sessionFactory.openSession();
+        }
+
+        @TearDown
+        public void tearDownState() {
+            LOGGER.info("State - Teardown");
+            SessionFactory sessionFactory = session.getSessionFactory();
+            session.close();
+            sessionFactory.close();
+            LOGGER.info("State - Teardown complete");
+        }
+    }
+
+    @Benchmark
+    @BenchmarkMode(Mode.AverageTime)
+    @OutputTimeUnit(TimeUnit.MICROSECONDS)
+    @Fork(1)
+    @Warmup(iterations = 2)
+    @Measurement(iterations = 5)
+    public void givenQueryPlanCacheSize_thenCompileQueries(QueryPlanCacheBenchMarkState state, Blackhole blackhole) {
+
+        Query query1 = findEmployeesByDepartmentNameQuery(state.session);
+        Query query2 = findEmployeesByDesignationQuery(state.session);
+        Query query3 = findDepartmentOfAnEmployeeQuery(state.session);
+
+        blackhole.consume(query1);
+        blackhole.consume(query2);
+        blackhole.consume(query3);
+
+    }
+
+    private Query findEmployeesByDepartmentNameQuery(Session session) {
+        return session.createQuery("SELECT e FROM DeptEmployee e " +
+                "JOIN e.department WHERE e.department.name = :deptName")
+                .setMaxResults(30)
+                .setHint(QueryHints.HINT_FETCH_SIZE, 30);
+    }
+
+    private Query findEmployeesByDesignationQuery(Session session) {
+        return session.createQuery("SELECT e FROM DeptEmployee e " +
+                "WHERE e.title = :designation")
+                .setHint(QueryHints.SPEC_HINT_TIMEOUT, 1000);
+    }
+
+    private Query findDepartmentOfAnEmployeeQuery(Session session) {
+        return session.createQuery("SELECT e.department FROM DeptEmployee e " +
+                "JOIN e.department WHERE e.employeeNumber = :empId");
+
+    }
+
+    public static void main(String... args) throws IOException, RunnerException {
+        //main-class to run the benchmark
+        org.openjdk.jmh.Main.main(args);
+    }
+}
--- a/Show More
+++ b/Show More