Merge branch 'master' into BAEL-7919

Author: oscarramadhan

core-java-modules/core-java-reflection-3/pom.xml

@@ -30,6 +30,11 @@
             <artifactId>reflections</artifactId>
             <version>${reflections.version}</version>
         </dependency>
+        <dependency>
+            <groupId>commons-beanutils</groupId>
+            <artifactId>commons-beanutils</artifactId>
+            <version>1.11.0</version>
+        </dependency>
     </dependencies>
 
     <build>

core-java-modules/core-java-reflection-3/src/main/java/com/baeldung/reflectionbeans/BeanUtilsDemo.java

@@ -0,0 +1,36 @@
+package com.baeldung.reflectionbeans;
+
+import org.apache.commons.beanutils.BeanUtils;
+
+import java.util.Map;
+
+public class BeanUtilsDemo {
+
+    public static void main(String[] args) throws Exception {
+        Post post = new Post();
+        BeanUtils.setProperty(post, "title", "Commons BeanUtils Rocks");
+        String title = BeanUtils.getProperty(post, "title");
+
+        Map<String, Object> data = Map.of(
+                "title", "Map → Bean",
+                "author", "Baeldung Team"
+        );
+
+        BeanUtils.populate(post, data);
+        Post source = new Post();
+        source.setTitle("Source");
+        source.setAuthor("Alice");
+
+        Post target = new Post();
+        BeanUtils.copyProperties(target, source);
+        System.out.println(title);
+    }
+
+    public static void safeCopy(Object target, Object source) {
+        try {
+            BeanUtils.copyProperties(target, source);
+        } catch (ReflectiveOperationException ex) {
+            throw new IllegalStateException(ex);
+        }
+    }
+}

core-java-modules/core-java-reflection-3/src/main/java/com/baeldung/reflectionbeans/Post.java

@@ -0,0 +1,13 @@
+package com.baeldung.reflectionbeans;
+
+public class Post {
+
+    private String title;
+    private String author;
+
+    public String getTitle() { return title; }
+    public void setTitle(String title) { this.title = title; }
+
+    public String getAuthor() { return author; }
+    public void setAuthor(String author) { this.author = author; }
+}

core-java-modules/core-java-reflection-3/src/main/java/com/baeldung/reflectionbeans/PropertyDescriptorDemo.java

@@ -0,0 +1,29 @@
+package com.baeldung.reflectionbeans;
+
+import java.beans.BeanInfo;
+import java.beans.Introspector;
+import java.beans.PropertyDescriptor;
+import java.lang.reflect.Method;
+
+public class PropertyDescriptorDemo {
+
+    public static void main(String[] args) throws Exception {
+        BeanInfo beanInfo = Introspector.getBeanInfo(Post.class);
+
+        for (PropertyDescriptor pd : beanInfo.getPropertyDescriptors()) {
+            System.out.println(pd.getName());
+        }
+
+        Post post = new Post();
+        PropertyDescriptor titlePd = new PropertyDescriptor("title", Post.class);
+
+        Method write = titlePd.getWriteMethod();
+        Method read = titlePd.getReadMethod();
+
+
+        write.invoke(post, "Reflections in Java");
+        String value = (String) read.invoke(post);
+
+        System.out.println(value);
+    }
+}

core-java-modules/core-java-reflection-3/src/test/java/com/baeldung/reflectionbeans/BeanUtilsUnitTest.java

@@ -0,0 +1,36 @@
+package com.baeldung.reflectionbeans;
+
+import org.apache.commons.beanutils.BeanUtils;
+import org.junit.Test;
+
+import java.util.Map;
+
+import static org.junit.Assert.assertEquals;
+
+public class BeanUtilsUnitTest {
+
+    @Test
+    public void givenPost_whenPopulate_thenFieldsAreSet() throws Exception {
+        Post post = new Post();
+        Map<String, Object> data = Map.of("title", "Populate Test", "author", "Dana");
+
+        BeanUtils.populate(post, data);
+
+        assertEquals("Populate Test", BeanUtils.getProperty(post, "title"));
+        assertEquals("Dana", BeanUtils.getProperty(post, "author"));
+    }
+
+    @Test
+    public void givenTwoPosts_whenCopyProperties_thenTargetMatchesSource() throws Exception {
+        Post source = new Post();
+        source.setTitle("Copy");
+        source.setAuthor("Eve");
+
+        Post target = new Post();
+        BeanUtils.copyProperties(target, source);
+
+        assertEquals("Copy", target.getTitle());
+        assertEquals("Eve", target.getAuthor());
+    }
+}
+

core-java-modules/core-java-reflection-3/src/test/java/com/baeldung/reflectionbeans/PropertyDescriptorUnitTest.java

@@ -0,0 +1,19 @@
+package com.baeldung.reflectionbeans;
+
+import org.junit.Test;
+
+import java.beans.PropertyDescriptor;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+public class PropertyDescriptorUnitTest {
+
+    @Test
+    public void givenPost_whenUsingPropertyDescriptor_thenReadAndWrite() throws Exception {
+        Post post = new Post();
+        PropertyDescriptor pd = new PropertyDescriptor("author", Post.class);
+
+        pd.getWriteMethod().invoke(post, "Chris");
+        assertEquals("Chris", pd.getReadMethod().invoke(post));
+    }
+}

core-java-modules/core-java-security/pom.xml

@@ -42,22 +42,10 @@
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>
                 <version>${maven-surefire-plugin.version}</version>
-                <configuration>
-                    <argLine>--add-opens java.base/sun.security.x509=ALL-UNNAMED</argLine>
-                    <argLine>--add-exports java.base/sun.security.util=ALL-UNNAMED</argLine>
-                </configuration>
             </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-compiler-plugin</artifactId>
-                <configuration>
-                    <compilerArgs>
-                        <arg>--add-exports</arg>
-                        <arg>java.base/sun.security.x509=ALL-UNNAMED</arg>
-                        <arg>--add-exports</arg>
-                        <arg>java.base/sun.security.util=ALL-UNNAMED</arg>
-                    </compilerArgs>
-                </configuration>
             </plugin>
         </plugins>
     </build>

reactor-core-2/pom.xml

@@ -37,6 +37,17 @@
             <version>${lombok.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-core</artifactId>
+            <version>${jmh-core.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>org.openjdk.jmh</groupId>
+            <artifactId>jmh-generator-annprocess</artifactId>
+            <version>${jmh-generator.version}</version>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
     <properties>

reactor-core-2/src/main/java/com/baeldung/reactor/flux/parallelflux/Fibonacci.java

@@ -0,0 +1,8 @@
+package com.baeldung.reactor.flux.parallelflux;
+
+public class Fibonacci {
+    public static long fibonacci(int n) {
+        if (n <= 1) return n;
+        return fibonacci(n - 1) + fibonacci(n - 2);
+    }
+}

reactor-core-2/src/main/java/com/baeldung/reactor/flux/parallelflux/FibonacciFluxParallelFluxBenchmark.java

@@ -0,0 +1,33 @@
+package com.baeldung.reactor.flux.parallelflux;
+
+import org.openjdk.jmh.annotations.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.ParallelFlux;
+import reactor.core.scheduler.Schedulers;
+
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+@BenchmarkMode(Mode.AverageTime)
+@OutputTimeUnit(TimeUnit.MILLISECONDS)
+@State(Scope.Thread)
+public class FibonacciFluxParallelFluxBenchmark {
+
+    @Benchmark
+    public List<Long> benchMarkParallelFluxSequential() {
+        ParallelFlux<Long> parallelFluxFibonacci = Flux.just(43, 44, 45, 47, 48)
+                .parallel(3)
+                .runOn(Schedulers.parallel())
+                .map(Fibonacci::fibonacci);
+
+        return parallelFluxFibonacci.sequential().collectList().block();
+    }
+
+    @Benchmark
+    public List<Long> benchMarkFluxSequential() {
+        Flux<Long> fluxFibonacci = Flux.just(43, 44, 45, 47, 48)
+                .map(Fibonacci::fibonacci);
+
+        return fluxFibonacci.collectList().block();
+    }
+}