Merge pull request #2 from eugenp/master

sync with master
2018-07-21 19:51:28 +01:00
parent aa0af30497 8f52c3f6d3
commit 2c102c845a
253 changed files with 9529 additions and 1312 deletions
@@ -48,3 +48,12 @@ dependency-reduced-pom.xml
 *.so
 *.dylib
 *.dll
+
+xml/src/test/resources/example_dom4j_new.xml
+xml/src/test/resources/example_dom4j_updated.xml
+xml/src/test/resources/example_jaxb_new.xml
+core-java-io/hard_link.txt
+core-java-io/target_link.txt
+core-java/src/main/java/com/baeldung/manifest/MANIFEST.MF
+ethereum/logs/
+jmeter/src/main/resources/*-JMeter.csv
@@ -4,7 +4,7 @@ before_install:
  - echo "MAVEN_OPTS='-Xmx2048M -Xss128M -XX:+CMSClassUnloadingEnabled -XX:+UseG1GC -XX:-UseGCOverheadLimit'" > ~/.mavenrc

 install: skip
-script: travis_wait 60 mvn -q install
+script: travis_wait 60 mvn -q install -Pdefault

 sudo: required

@@ -19,7 +19,7 @@ In additional to Spring, the following technologies are in focus: `core Java`, `

 Building the project
 ====================
-To do the full build, do: `mvn install -Dgib.enabled=false`
+To do the full build, do: `mvn install -Pdefault -Dgib.enabled=false`


 Working with the code in Eclipse
@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.baeldung</groupId>
+    <artifactId>apache-avro-tutorial</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <compiler-plugin.version>3.5</compiler-plugin.version>
+        <avro.version>1.8.2</avro.version>
+        <java.version>1.8</java.version>
+        <slf4j.version>1.7.25</slf4j.version>
+    </properties>
+	
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>parent-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.10</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-simple</artifactId>
+            <version>${slf4j.version}</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro</artifactId>
+            <version>${avro.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro-compiler</artifactId>
+            <version>${avro.version}</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.avro</groupId>
+            <artifactId>avro-maven-plugin</artifactId>
+            <version>${avro.version}</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${compiler-plugin.version}</version>
+                <configuration>
+                    <source>${java.version}</source>
+                    <target>${java.version}</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.avro</groupId>
+                <artifactId>avro-maven-plugin</artifactId>
+                <version>${avro.version}</version>
+                <executions>
+                    <execution>
+                        <id>schemas</id>
+                        <phase>generate-sources</phase>
+                        <goals>
+                            <goal>schema</goal>
+                            <goal>protocol</goal>
+                            <goal>idl-protocol</goal>
+                        </goals>
+                        <configuration>
+                            <sourceDirectory>${project.basedir}/src/main/resources/</sourceDirectory>
+                            <outputDirectory>${project.basedir}/src/main/java/</outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>
@@ -0,0 +1,14 @@
+package com.baeldung.avro.util;
+
+import org.apache.avro.Schema;
+import org.apache.avro.compiler.specific.SpecificCompiler;
+
+import java.io.File;
+import java.io.IOException;
+
+public class AvroClassGenerator {
+    public void generateAvroClasses() throws IOException {
+        SpecificCompiler compiler = new SpecificCompiler(new Schema.Parser().parse(new File("src/main/resources/avroHttpRequest-schema.avsc")));
+        compiler.compileToDestination(new File("src/main/resources"), new File("src/main/java")); 
+    }
+}
@@ -0,0 +1,24 @@
+package com.baeldung.avro.util;
+
+
+import org.apache.avro.Schema;
+import org.apache.avro.SchemaBuilder;
+
+public class AvroSchemaBuilder {
+
+    public Schema createAvroHttpRequestSchema(){
+
+        Schema clientIdentifier = SchemaBuilder.record("ClientIdentifier").namespace("com.baeldung.avro.model")
+                .fields().requiredString("hostName").requiredString("ipAddress").endRecord();
+
+        Schema avroHttpRequest = SchemaBuilder.record("AvroHttpRequest").namespace("com.baeldung.avro.model").fields()
+                .requiredLong("requestTime")
+                .name("clientIdentifier").type(clientIdentifier).noDefault()
+                .name("employeeNames").type().array().items().stringType().arrayDefault(null)
+                .name("active").type().enumeration("Active").symbols("YES", "NO").noDefault()
+                .endRecord();
+        return avroHttpRequest;
+    }
+}
+
+
@@ -0,0 +1,13 @@
+/**
+ * Autogenerated by Avro
+ *
+ * DO NOT EDIT DIRECTLY
+ */
+package com.baeldung.avro.util.model;
+@SuppressWarnings("all")
+@org.apache.avro.specific.AvroGenerated
+public enum Active {
+  YES, NO  ;
+  public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"enum\",\"name\":\"Active\",\"namespace\":\"com.baeldung.avro.model\",\"symbols\":[\"YES\",\"NO\"]}");
+  public static org.apache.avro.Schema getClassSchema() { return SCHEMA$; }
+}
@@ -0,0 +1,33 @@
+package com.baeldung.avro.util.serealization;
+
+import com.baeldung.avro.util.model.AvroHttpRequest;
+import org.apache.avro.io.DatumReader;
+import org.apache.avro.io.Decoder;
+import org.apache.avro.io.DecoderFactory;
+import org.apache.avro.specific.SpecificDatumReader;
+
+import java.io.IOException;
+
+public class AvroDeSerealizer {
+
+public AvroHttpRequest deSerealizeAvroHttpRequestJSON(byte[] data){
+    DatumReader<AvroHttpRequest> reader = new SpecificDatumReader<>(AvroHttpRequest.class);
+    Decoder decoder = null;
+    try {
+        decoder = DecoderFactory.get().jsonDecoder(AvroHttpRequest.getClassSchema(), new String(data));
+        return reader.read(null, decoder);
+    } catch (IOException e) {
+        return null;
+    }
+}
+
+public AvroHttpRequest deSerealizeAvroHttpRequestBinary(byte[] data){
+    DatumReader<AvroHttpRequest> employeeReader = new SpecificDatumReader<>(AvroHttpRequest.class);
+    Decoder decoder = DecoderFactory.get().binaryDecoder(data, null);
+    try {
+        return employeeReader.read(null, decoder);
+    } catch (IOException e) {
+        return null;
+    }
+}
+}
@@ -0,0 +1,44 @@
+package com.baeldung.avro.util.serealization;
+
+import com.baeldung.avro.util.model.AvroHttpRequest;
+import org.apache.avro.io.*;
+import org.apache.avro.specific.SpecificDatumWriter;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+
+public class AvroSerealizer {
+
+public byte[] serealizeAvroHttpRequestJSON(AvroHttpRequest request){
+    DatumWriter<AvroHttpRequest> writer = new SpecificDatumWriter<>(AvroHttpRequest.class);
+    byte[] data = new byte[0];
+    ByteArrayOutputStream stream = new ByteArrayOutputStream();
+    Encoder jsonEncoder = null;
+    try {
+        jsonEncoder = EncoderFactory.get().jsonEncoder(AvroHttpRequest.getClassSchema(), stream);
+        writer.write(request, jsonEncoder);
+        jsonEncoder.flush();
+        data = stream.toByteArray();
+    } catch (IOException e) {
+        data =null;
+    }
+    return data;
+}
+
+public byte[] serealizeAvroHttpRequestBinary(AvroHttpRequest request){
+    DatumWriter<AvroHttpRequest> writer = new SpecificDatumWriter<>(AvroHttpRequest.class);
+    byte[] data = new byte[0];
+    ByteArrayOutputStream stream = new ByteArrayOutputStream();
+    Encoder jsonEncoder = EncoderFactory.get().binaryEncoder(stream,null);
+    try {
+        writer.write(request, jsonEncoder);
+        jsonEncoder.flush();
+        data = stream.toByteArray();
+    } catch (IOException e) {
+        data = null;
+    }
+
+    return data;
+}
+
+}
@@ -0,0 +1,47 @@
+{
+  "type":"record",
+  "name":"AvroHttpRequest",
+  "namespace":"com.baeldung.avro.model",
+  "fields":[
+    {
+      "name":"requestTime",
+      "type":"long"
+    },
+    {
+      "name":"clientIdentifier",
+      "type":{
+        "type":"record",
+        "name":"ClientIdentifier",
+        "fields":[
+          {
+            "name":"hostName",
+            "type":"string"
+          },
+          {
+            "name":"ipAddress",
+            "type":"string"
+          }
+        ]
+      }
+    },
+    {
+      "name":"employeeNames",
+      "type":{
+        "type":"array",
+        "items":"string"
+      },
+      "default":null
+    },
+    {
+      "name":"active",
+      "type":{
+        "type":"enum",
+        "name":"Active",
+        "symbols":[
+          "YES",
+          "NO"
+        ]
+      }
+    }
+  ]
+}
@@ -0,0 +1,75 @@
+package com.baeldung.avro.util.serealization;
+
+import com.baeldung.avro.util.model.Active;
+import com.baeldung.avro.util.model.AvroHttpRequest;
+import com.baeldung.avro.util.model.ClientIdentifier;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Objects;
+
+import static org.junit.Assert.*;
+
+public class AvroSerealizerDeSerealizerTest {
+
+    AvroSerealizer serealizer;
+    AvroDeSerealizer deSerealizer;
+    AvroHttpRequest request;
+
+    @Before
+    public void setUp() throws Exception {
+        serealizer = new AvroSerealizer();
+        deSerealizer = new AvroDeSerealizer();
+
+        ClientIdentifier clientIdentifier = ClientIdentifier.newBuilder().
+                setHostName("localhost").setIpAddress("255.255.255.0").build();
+
+        List<CharSequence> employees = new ArrayList();
+        employees.add("James");
+        employees.add("Alice");
+        employees.add("David");
+        employees.add("Han");
+
+        request = AvroHttpRequest.newBuilder().setRequestTime(01l)
+                .setActive(Active.YES).setClientIdentifier(clientIdentifier)
+                .setEmployeeNames(employees).build();
+    }
+
+    @After
+    public void tearDown() throws Exception {
+    }
+
+@Test
+public void WhenSerialized_UsingJSONEncoder_ObjectGetsSerialized(){
+    byte[] data = serealizer.serealizeAvroHttpRequestJSON(request);
+    assertTrue(Objects.nonNull(data));
+    assertTrue(data.length > 0);
+}
+
+@Test
+public void WhenSerialized_UsingBinaryEncoder_ObjectGetsSerialized(){
+    byte[] data = serealizer.serealizeAvroHttpRequestBinary(request);
+    assertTrue(Objects.nonNull(data));
+    assertTrue(data.length > 0);
+}
+
+@Test
+public void WhenDeserialize_UsingJSONDecoder_ActualAndExpectedObjectsAreEqual(){
+    byte[] data = serealizer.serealizeAvroHttpRequestJSON(request);
+    AvroHttpRequest actualRequest = deSerealizer.deSerealizeAvroHttpRequestJSON(data);
+    assertEquals(actualRequest,request);
+    assertTrue(actualRequest.getRequestTime().equals(request.getRequestTime()));
+}
+
+@Test
+public void WhenDeserialize_UsingBinaryecoder_ActualAndExpectedObjectsAreEqual(){
+    byte[] data = serealizer.serealizeAvroHttpRequestBinary(request);
+    AvroHttpRequest actualRequest = deSerealizer.deSerealizeAvroHttpRequestBinary(data);
+    assertEquals(actualRequest,request);
+    assertTrue(actualRequest.getRequestTime().equals(request.getRequestTime()));
+}
+}
+
@@ -0,0 +1,14 @@
+package com.baeldung.java10.list;
+
+import org.junit.Test;
+
+import java.util.Arrays;
+import java.util.List;
+
+public class CopyListServiceUnitTest {
+
+    @Test(expected = UnsupportedOperationException.class)
+    public void whenModifyCopyOfList_thenThrowsException() {
+        List<Integer> copyList = List.copyOf(Arrays.asList(1, 2, 3, 4));
+    }
+}
@@ -0,0 +1,27 @@
+package com.baeldung.convertlisttomap;
+
+public class Animal {
+    private int id;
+    private String name;
+
+    public Animal(int id, String name) {
+        this.id = id;
+        this.setName(name);
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+}
@@ -0,0 +1,42 @@
+package com.baeldung.convertlisttomap;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import org.apache.commons.collections4.MapUtils;
+import com.google.common.collect.Maps;
+
+public class ConvertListToMapService {
+
+    public Map<Integer, Animal> convertListBeforeJava8(List<Animal> list) {
+
+        Map<Integer, Animal> map = new HashMap<>();
+
+        for (Animal animal : list) {
+            map.put(animal.getId(), animal);
+        }
+        return map;
+    }
+
+    public Map<Integer, Animal> convertListAfterJava8(List<Animal> list) {
+        Map<Integer, Animal> map = list.stream().collect(Collectors.toMap(Animal::getId, animal -> animal));
+        return map;
+    }
+
+    public Map<Integer, Animal> convertListWithGuava(List<Animal> list) {
+
+        Map<Integer, Animal> map = Maps.uniqueIndex(list, Animal::getId);
+        return map;
+    }
+
+    public Map<Integer, Animal> convertListWithApacheCommons(List<Animal> list) {
+
+        Map<Integer, Animal> map = new HashMap<>();
+
+        MapUtils.populateMap(map, list, Animal::getId);
+
+        return map;
+    }
+}
@@ -0,0 +1,73 @@
+package com.baeldung.list;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+public class CopyListService {
+
+    public List<Flower> copyListByConstructor(List<Flower> source) {
+        return new ArrayList<Flower>(source);
+    }
+
+    public List<Flower> copyListByConstructorAndEditOneFlowerInTheNewList(List<Flower> source) {
+        List<Flower> flowers = new ArrayList<>(source);
+        if(flowers.size() > 0) {
+            flowers.get(0).setPetals(flowers.get(0).getPetals() * 3);
+        }
+
+        return flowers;
+    }
+
+    public List<Flower> copyListByAddAllMethod(List<Flower> source) {
+        List<Flower> flowers = new ArrayList<>();
+        flowers.addAll(source);
+        return flowers;
+    }
+
+    public List<Flower> copyListByAddAllMethodAndEditOneFlowerInTheNewList(List<Flower> source) {
+        List<Flower> flowers = new ArrayList<>();
+        flowers.addAll(source);
+
+        if(flowers.size() > 0) {
+            flowers.get(0).setPetals(flowers.get(0).getPetals() * 3);
+        }
+
+        return flowers;
+    }
+
+    public List<Integer> copyListByCopyMethod(List<Integer> source, List<Integer> dest) {
+        Collections.copy(dest, source);
+        return dest;
+    }
+
+    public List<Flower> copyListByStream(List<Flower> source) {
+        return source.stream().collect(Collectors.toList());
+    }
+
+    public List<Flower> copyListByStreamAndSkipFirstElement(List<Flower> source) {
+        return source.stream().skip(1).collect(Collectors.toList());
+    }
+
+    public List<Flower> copyListByStreamWithFilter(List<Flower> source, Integer moreThanPetals) {
+        return source.stream().filter(f -> f.getPetals() > moreThanPetals).collect(Collectors.toList());
+    }
+
+    public List<Flower> copyListByStreamWithOptional(List<Flower> source) {
+        return Optional.ofNullable(source)
+                 .map(List::stream)
+                 .orElseGet(Stream::empty)
+                 .collect(Collectors.toList());
+    }
+
+    public List<Flower> copyListByStreamWithOptionalAndSkip(List<Flower> source) {
+        return Optional.ofNullable(source)
+                .map(List::stream)
+                .orElseGet(Stream::empty)
+                .skip(1)
+                .collect(Collectors.toList());
+    }
+}
@@ -0,0 +1,28 @@
+package com.baeldung.list;
+
+public class Flower {
+
+    private String name;
+    private int petals;
+
+    public Flower(String name, int petals) {
+        this.name = name;
+        this.petals = petals;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public int getPetals() {
+        return petals;
+    }
+
+    public void setPetals(int petals) {
+        this.petals = petals;
+    }
+}
@@ -0,0 +1,67 @@
+package com.baeldung.convertlisttomap;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.*;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class ConvertListToMapServiceUnitTest {
+    List<Animal> list;
+
+    private ConvertListToMapService convertListService;
+
+    @Before
+    public void init() {
+        this.convertListService = new ConvertListToMapService();
+        this.list = new ArrayList<>();
+
+        Animal cat = new Animal(1, "Cat");
+        list.add(cat);
+        Animal dog = new Animal(2, "Dog");
+        list.add(dog);
+        Animal pig = new Animal(3, "Pig");
+        list.add(pig);
+        Animal cow = new Animal(4, "Cow");
+        list.add(cow);
+        Animal goat = new Animal(5, "Goat");
+        list.add(goat);
+
+    }
+
+    @Test
+    public void givenAList_whenConvertBeforeJava8_thenReturnMapWithTheSameElements() {
+
+        Map<Integer, Animal> map = convertListService.convertListBeforeJava8(list);
+
+        assertThat(map.values(), containsInAnyOrder(list.toArray()));
+    }
+
+    @Test
+    public void givenAList_whenConvertAfterJava8_thenReturnMapWithTheSameElements() {
+
+        Map<Integer, Animal> map = convertListService.convertListAfterJava8(list);
+
+        assertThat(map.values(), containsInAnyOrder(list.toArray()));
+    }
+
+    @Test
+    public void givenAList_whenConvertWithGuava_thenReturnMapWithTheSameElements() {
+
+        Map<Integer, Animal> map = convertListService.convertListWithGuava(list);
+
+        assertThat(map.values(), containsInAnyOrder(list.toArray()));
+    }
+
+    @Test
+    public void givenAList_whenConvertWithApacheCommons_thenReturnMapWithTheSameElements() {
+
+        Map<Integer, Animal> map = convertListService.convertListWithApacheCommons(list);
+
+        assertThat(map.values(), containsInAnyOrder(list.toArray()));
+    }
+
+}
@@ -0,0 +1,68 @@
+package com.baeldung.convertlisttomap;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.hasItem;
+import static org.hamcrest.Matchers.hasSize;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+import org.junit.Before;
+import org.junit.Test;
+
+public class ConvertListWithDiplicatedIdToMapServiceUnitTest {
+    List<Animal> duplicatedIdList;
+
+    private ConvertListToMapService convertListService = new ConvertListToMapService();
+
+    @Before
+    public void init() {
+
+        this.duplicatedIdList = new ArrayList<>();
+
+        Animal cat = new Animal(1, "Cat");
+        duplicatedIdList.add(cat);
+        Animal dog = new Animal(2, "Dog");
+        duplicatedIdList.add(dog);
+        Animal pig = new Animal(3, "Pig");
+        duplicatedIdList.add(pig);
+        Animal cow = new Animal(4, "Cow");
+        duplicatedIdList.add(cow);
+        Animal goat = new Animal(4, "Goat");
+        duplicatedIdList.add(goat);
+
+    }
+
+    @Test
+    public void givenADupIdList_whenConvertBeforeJava8_thenReturnMapWithRewrittenElement() {
+
+        Map<Integer, Animal> map = convertListService.convertListBeforeJava8(duplicatedIdList);
+
+        assertThat(map.values(), hasSize(4));
+        assertThat(map.values(), hasItem(duplicatedIdList.get(4)));
+    }
+
+    @Test
+    public void givenADupIdList_whenConvertWithApacheCommons_thenReturnMapWithRewrittenElement() {
+
+        Map<Integer, Animal> map = convertListService.convertListWithApacheCommons(duplicatedIdList);
+
+        assertThat(map.values(), hasSize(4));
+        assertThat(map.values(), hasItem(duplicatedIdList.get(4)));
+    }
+
+    @Test(expected = IllegalStateException.class)
+    public void givenADupIdList_whenConvertAfterJava8_thenException() {
+
+        convertListService.convertListAfterJava8(duplicatedIdList);
+    }
+
+    @Test(expected = IllegalArgumentException.class)
+    public void givenADupIdList_whenConvertWithGuava_thenException() {
+
+        convertListService.convertListWithGuava(duplicatedIdList);
+
+    }
+
+}
@@ -0,0 +1,129 @@
+package com.baeldung.list;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+import static org.junit.Assert.*;
+
+public class CopyListServiceUnitTest {
+
+    List<Flower> flowers;
+
+    private CopyListService copyListService;
+
+    @Before
+    public void init() {
+        this.copyListService = new CopyListService();
+        this.flowers = new ArrayList<>();
+
+        Flower poppy = new Flower("Poppy", 12);
+        flowers.add(poppy);
+        Flower anemone = new Flower("Anemone", 8);
+        flowers.add(anemone);
+        Flower catmint = new Flower("Catmint", 12);
+        flowers.add(catmint);
+        Flower diascia = new Flower("Diascia", 5);
+        flowers.add(diascia);
+        Flower iris = new Flower("Iris", 3);
+        flowers.add(iris);
+        Flower pansy = new Flower("Pansy", 5);
+        flowers.add(pansy);
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithTheSameElementsByConstructor() {
+        List<Flower> copy = copyListService.copyListByConstructor(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithOneModifiedElementByConstructor() {
+        List<Flower> copy = copyListService.copyListByConstructorAndEditOneFlowerInTheNewList(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithTheSameElementsByAddAllmethod() {
+        List<Flower> copy = copyListService.copyListByAddAllMethod(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithOneModifiedElementByAddAllmethod() {
+        List<Flower> copy = copyListService.copyListByAddAllMethodAndEditOneFlowerInTheNewList(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListsHaveSameSize_thenReturnAnotherListWithTheSameElementsByCopyMethod() {
+        List<Integer> source = Arrays.asList(1,2,3);
+        List<Integer> dest = Arrays.asList(4,5,6);
+
+        dest = copyListService.copyListByCopyMethod(source, dest);
+        assertEquals(dest.size(), source.size());
+        assertTrue(dest.containsAll(source));
+    }
+
+    @Test
+    public void givenAList_whenListsHaveDifferentSize_thenReturnAnotherListWithTheSameElementsByCopyMethod() {
+        List<Integer> source = Arrays.asList(1,2,3);
+        List<Integer> dest = Arrays.asList(5,6,7,8,9,10);
+
+        dest = copyListService.copyListByCopyMethod(source, dest);
+        assertNotEquals(dest.size(), source.size());
+        assertTrue(dest.containsAll(source));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithTheSameElementsByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStream(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithOneElementLessByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStreamAndSkipFirstElement(flowers);
+        assertNotEquals(copy.size(), flowers.size());
+        assertEquals(copy.size() + 1, flowers.size());
+        assertFalse(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListDoesNotHaveNullElements_thenReturnAnotherListWithFilterElementsByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStreamWithFilter(flowers, 5);
+        assertNotEquals(copy.size(), flowers.size());
+        assertEquals(copy.size() + 3, flowers.size());
+        assertFalse(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListIsNull_thenReturnEmptyListByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStreamWithOptional(null);
+        assertNotNull(copy);
+        assertEquals(copy.size(), 0);
+    }
+
+    @Test
+    public void givenAList_whenListIsNotNull_thenReturnAnotherListWithTheElementsByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStreamWithOptional(flowers);
+        assertEquals(copy.size(), flowers.size());
+        assertTrue(copy.containsAll(flowers));
+    }
+
+    @Test
+    public void givenAList_whenListIsNotNull_thenReturnAnotherListWithOneElementLessByStreamProcess() {
+        List<Flower> copy = copyListService.copyListByStreamWithOptionalAndSkip(flowers);
+        assertNotEquals(copy.size(), flowers.size());
+        assertEquals(copy.size() + 1, flowers.size());
+        assertFalse(copy.containsAll(flowers));
+    }
+}
@@ -0,0 +1,70 @@
+package com.baeldung.java.set;
+
+import com.google.common.collect.ImmutableSet;
+import com.google.common.collect.Sets;
+import org.junit.jupiter.api.Test;
+  
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import static org.junit.Assert.assertEquals;
+
+public class HashSetInitalizingUnitTest {
+    @Test
+    public void whenUsingJava_usingArraysStaticMethod_thenCorrectSize() {
+        Set<String> set = new HashSet<>(Arrays.asList("a", "b", "c"));
+        assertEquals(3, set.size());
+    }
+
+    @Test
+    public void whenUsingJava_usingAnonymousClass_thenCorrectSize() {
+        Set<String> set = new HashSet<String>(){{
+            add("a");
+            add("b");
+            add("c");
+        }};
+        assertEquals(3, set.size());
+    }
+
+    @Test
+    public void whenUsingJava_creatingSingletonSet_thenCorrectSize() {
+        Set<String> set = Collections.singleton("a");
+        assertEquals(1, set.size());
+    }
+
+    public static final <T> Set<T> newHashSet(T... objs) {
+        Set<T> set = new HashSet<T>();
+        Collections.addAll(set, objs);
+        return set;
+    }
+
+    @Test
+    public void whenUsingJava_usingCustomStaticUtilMethod_thenCorrectSize() {
+        Set<String> set = newHashSet("a","b","c");
+        assertEquals(3, set.size());
+    }
+
+    @Test
+    public void whenUsingJava8_usingCollectOnStream_thenCorrectSize() {
+        Set<String> set = Stream.of("a", "b", "c").collect(Collectors.toCollection(HashSet::new));
+        assertEquals(3, set.size());
+    }
+
+    @Test
+    public void whenUsingGoogleGuava_createMutableSet_thenCorrectSize() {
+        Set<String> set = Sets.newHashSet("a", "b", "c");
+        assertEquals(3, set.size());
+    }
+
+    @Test
+    public void whenUsingGoogleGuava_createImmutableSet_thenCorrectSize() {
+        Set<String> set = ImmutableSet.of("a", "b", "c");
+        assertEquals(3, set.size());
+    }
+  
+}
+
@@ -1,5 +1,5 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.baeldung</groupId>
    <artifactId>core-java</artifactId>
@@ -73,9 +73,10 @@
        <dependency>
            <groupId>org.assertj</groupId>
            <artifactId>assertj-core</artifactId>
-            <version>${assertj.version}</version>
+            <version>${assertj-core.version}</version>
            <scope>test</scope>
        </dependency>
+
        <dependency>
            <groupId>commons-codec</groupId>
            <artifactId>commons-codec</artifactId>
@@ -146,6 +147,32 @@
            <artifactId>icu4j</artifactId>
            <version>${icu4j.version}</version>
        </dependency>
+        <!-- Mime Type Resolution Libraries -->
+        <dependency>
+            <groupId>org.apache.tika</groupId>
+            <artifactId>tika-core</artifactId>
+            <version>${tika.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>net.sf.jmimemagic</groupId>
+            <artifactId>jmimemagic</artifactId>
+            <version>${jmime-magic.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-dbcp2</artifactId>
+            <version>${commons-dbcp2.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>${HikariCP.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.mchange</groupId>
+            <artifactId>c3p0</artifactId>
+            <version>${c3p0.version}</version>
+        </dependency>
    </dependencies>

    <build>
@@ -301,7 +328,7 @@
                    </arguments>
                </configuration>
            </plugin>
-
+            
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-javadoc-plugin</artifactId>
@@ -348,6 +375,7 @@
                    <plugin>
                        <groupId>org.codehaus.mojo</groupId>
                        <artifactId>exec-maven-plugin</artifactId>
+                        <version>${exec-maven-plugin.version}</version>
                        <executions>
                            <execution>
                                <id>run-benchmarks</id>
@@ -375,6 +403,7 @@
    </profiles>

    <properties>
+        
        <!-- marshalling -->
        <jackson.version>2.8.5</jackson.version>
        <gson.version>2.8.2</gson.version>
@@ -395,16 +424,23 @@
        <vavr.version>0.9.0</vavr.version>

        <!-- testing -->
-        <assertj.version>3.6.1</assertj.version>
+        <assertj-core.version>3.10.0</assertj-core.version>

+        <!-- JDBC pooling frameworks -->
+        <commons-dbcp2.version>2.4.0</commons-dbcp2.version>
+        <HikariCP.version>3.2.0</HikariCP.version>
+        <c3p0.version>0.9.5.2</c3p0.version>
+        
        <!-- maven plugins -->
        <maven-surefire-plugin.version>2.19.1</maven-surefire-plugin.version>
        <springframework.spring-web.version>4.3.4.RELEASE</springframework.spring-web.version>
        <springframework.boot.spring-boot-starter.version>1.5.8.RELEASE</springframework.boot.spring-boot-starter.version>
+        
        <javamoney.moneta.version>1.1</javamoney.moneta.version>
        <h2database.version>1.4.197</h2database.version>
        <esapi.version>2.1.0.1</esapi.version>
        <jmh-core.version>1.19</jmh-core.version>
+       
        <jmh-generator-annprocess.version>1.19</jmh-generator-annprocess.version>
        <maven-javadoc-plugin.version>3.0.0-M1</maven-javadoc-plugin.version>
        <javax.mail.version>1.5.0-b01</javax.mail.version>
@@ -412,7 +448,11 @@
        <onejar-maven-plugin.version>1.4.4</onejar-maven-plugin.version>
        <maven-shade-plugin.version>3.1.1</maven-shade-plugin.version>
        <spring-boot-maven-plugin.version>2.0.3.RELEASE</spring-boot-maven-plugin.version>
+        <exec-maven-plugin.version>1.6.0</exec-maven-plugin.version>
        <icu4j.version>61.1</icu4j.version>
+        <!-- Mime Type Libraries -->
+        <tika.version>1.18</tika.version>
+        <jmime-magic.version>0.1.5</jmime-magic.version>
    </properties>

-</project>
+</project>
@@ -0,0 +1,87 @@
+package com.baeldung.connectionpool.connectionpools;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
+
+public class BasicConnectionPool implements ConnectionPool {
+
+    private final String url;
+    private final String user;
+    private final String password;
+    private final List<Connection> connectionPool;
+    private final List<Connection> usedConnections = new ArrayList<>();
+    private static final int INITIAL_POOL_SIZE = 10;
+    private final int MAX_POOL_SIZE = 20;
+    
+    public static BasicConnectionPool create(String url, String user, String password) throws SQLException {
+        List<Connection> pool = new ArrayList<>(INITIAL_POOL_SIZE);
+        for (int i = 0; i < INITIAL_POOL_SIZE; i++) {
+            pool.add(createConnection(url, user, password));
+        }
+        return new BasicConnectionPool(url, user, password, pool);
+    }
+    
+    private BasicConnectionPool(String url, String user, String password, List<Connection> connectionPool) {
+        this.url = url;
+        this.user = user;
+        this.password = password;
+        this.connectionPool = connectionPool;
+    }
+    
+    @Override
+    public Connection getConnection() throws SQLException {
+        if (connectionPool.size() == 0) {
+            if (usedConnections.size() < MAX_POOL_SIZE) {
+                connectionPool.add(createConnection(url, user, password));
+            } else {
+                throw new RuntimeException("Maximum pool size reached, no available connections!");
+            }
+        }
+
+        Connection connection = connectionPool.remove(connectionPool.size() - 1);
+        usedConnections.add(connection);
+        return connection;
+    }
+    
+    @Override
+    public boolean releaseConnection(Connection connection) {
+        connectionPool.add(connection);
+        return usedConnections.remove(connection);
+    }
+    
+    private static Connection createConnection(String url, String user, String password) throws SQLException {
+        return DriverManager.getConnection(url, user, password);
+    }
+    
+    public int getSize() {
+        return connectionPool.size() + usedConnections.size();
+    }
+
+    @Override
+    public String getUrl() {
+        return url;
+    }
+
+    @Override
+    public String getUser() {
+        return user;
+    }
+
+    @Override
+    public String getPassword() {
+        return password;
+    }
+
+    public void shutdown() throws SQLException {
+        for (Connection c : usedConnections) {
+            this.releaseConnection(c);
+        }
+        for (Connection c : connectionPool) {
+            c.close();
+        }
+        connectionPool.clear();
+    }
+}
@@ -0,0 +1,28 @@
+package com.baeldung.connectionpool.connectionpools;
+
+import com.mchange.v2.c3p0.ComboPooledDataSource;
+import java.beans.PropertyVetoException;
+import java.sql.Connection;
+import java.sql.SQLException;
+
+public class C3poDataSource {
+
+    private static final ComboPooledDataSource cpds = new ComboPooledDataSource();
+
+    static {
+        try {
+            cpds.setDriverClass("org.h2.Driver");
+            cpds.setJdbcUrl("jdbc:h2:mem:test");
+            cpds.setUser("user");
+            cpds.setPassword("password");
+        } catch (PropertyVetoException e) {
+            e.printStackTrace();
+        }
+    }
+    
+    public static Connection getConnection() throws SQLException {
+        return cpds.getConnection();
+    }
+    
+    private C3poDataSource(){}
+}
@@ -0,0 +1,18 @@
+package com.baeldung.connectionpool.connectionpools;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.List;
+
+public interface ConnectionPool {
+
+    Connection getConnection() throws SQLException;
+    
+    boolean releaseConnection(Connection connection);
+    
+    String getUrl();
+    
+    String getUser();
+
+    String getPassword();
+}   
@@ -0,0 +1,25 @@
+package com.baeldung.connectionpool.connectionpools;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+import org.apache.commons.dbcp2.BasicDataSource;
+
+public class DBCPDataSource {
+    
+    private static final BasicDataSource ds = new BasicDataSource();
+    
+    static {
+        ds.setUrl("jdbc:h2:mem:test");
+        ds.setUsername("user");
+        ds.setPassword("password");
+        ds.setMinIdle(5);
+        ds.setMaxIdle(10);
+        ds.setMaxOpenPreparedStatements(100);
+    }
+    
+    public static Connection getConnection() throws SQLException {
+        return ds.getConnection();
+    }
+    
+    private DBCPDataSource(){}
+}
@@ -0,0 +1,28 @@
+package com.baeldung.connectionpool.connectionpools;
+
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import java.sql.Connection;
+import java.sql.SQLException;
+
+public class HikariCPDataSource {
+    
+    private static final HikariConfig config = new HikariConfig();
+    private static final HikariDataSource ds;
+    
+    static {
+        config.setJdbcUrl("jdbc:h2:mem:test");
+        config.setUsername("user");
+        config.setPassword("password");
+        config.addDataSourceProperty("cachePrepStmts", "true");
+        config.addDataSourceProperty("prepStmtCacheSize", "250");
+        config.addDataSourceProperty("prepStmtCacheSqlLimit", "2048");
+        ds = new HikariDataSource(config);
+    }
+    
+    public static Connection getConnection() throws SQLException {
+        return ds.getConnection();
+    }
+    
+    private HikariCPDataSource(){}
+}
@@ -0,0 +1,69 @@
+package com.baeldung.connectionpool;
+
+import com.baeldung.connectionpool.connectionpools.BasicConnectionPool;
+import com.baeldung.connectionpool.connectionpools.ConnectionPool;
+import java.sql.Connection;
+import java.sql.SQLException;
+import java.util.List;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class BasicConnectionPoolUnitTest {
+    
+    private static ConnectionPool connectionPool;
+
+    @BeforeClass
+    public static void setUpBasicConnectionPoolInstance() throws SQLException {
+        connectionPool = BasicConnectionPool.create("jdbc:h2:mem:test", "user", "password");
+    }
+    
+    @Test
+    public void givenBasicConnectionPoolInstance_whenCalledgetConnection_thenCorrect() throws Exception {
+        assertTrue(connectionPool.getConnection().isValid(1));
+    }
+    
+    @Test
+    public void givenBasicConnectionPoolInstance_whenCalledreleaseConnection_thenCorrect() throws Exception {
+        Connection connection = connectionPool.getConnection();
+        assertThat(connectionPool.releaseConnection(connection)).isTrue();
+    }
+    
+    @Test
+    public void givenBasicConnectionPoolInstance_whenCalledgetUrl_thenCorrect() {
+        assertThat(connectionPool.getUrl()).isEqualTo("jdbc:h2:mem:test");
+    }
+    
+    @Test
+    public void givenBasicConnectionPoolInstance_whenCalledgetUser_thenCorrect() {
+        assertThat(connectionPool.getUser()).isEqualTo("user");
+    }
+    
+    @Test
+    public void givenBasicConnectionPoolInstance_whenCalledgetPassword_thenCorrect() {
+        assertThat(connectionPool.getPassword()).isEqualTo("password");
+    }
+
+    @Test(expected = RuntimeException.class)
+    public void givenBasicConnectionPoolInstance_whenAskedForMoreThanMax_thenError() throws Exception {
+        // this test needs to be independent so it doesn't share the same connection pool as other tests
+        ConnectionPool cp = BasicConnectionPool.create("jdbc:h2:mem:test", "user", "password");
+        final int MAX_POOL_SIZE = 20;
+        for (int i = 0; i < MAX_POOL_SIZE + 1; i++) {
+            cp.getConnection();
+        }
+        fail();
+    }
+
+    @Test
+    public void givenBasicConnectionPoolInstance_whenSutdown_thenEmpty() throws Exception {
+        ConnectionPool cp = BasicConnectionPool.create("jdbc:h2:mem:test", "user", "password");
+        assertThat(((BasicConnectionPool)cp).getSize()).isEqualTo(10);
+
+        ((BasicConnectionPool) cp).shutdown();
+        assertThat(((BasicConnectionPool)cp).getSize()).isEqualTo(0);
+    }
+}
--- a/Show More
+++ b/Show More