supplier) {
+ return new GenericBuilder<>(supplier);
+ }
+
+ public GenericBuilder with(BiConsumer consumer, P value) {
+ return new GenericBuilder<>(() -> {
+ T object = supplier.get();
+ consumer.accept(object, value);
+ return object;
+ });
+ }
+
+ public T build() {
+ return supplier.get();
+ }
+}
diff --git a/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/LombokPost.java b/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/LombokPost.java
new file mode 100644
index 0000000000..76edf2390c
--- /dev/null
+++ b/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/LombokPost.java
@@ -0,0 +1,18 @@
+package com.baeldung.builder.implementation;
+
+import lombok.Builder;
+import lombok.Getter;
+import lombok.Setter;
+
+@Builder
+@Getter
+@Setter
+public class LombokPost {
+
+ private String title;
+
+ private String text;
+
+ private String category;
+
+}
diff --git a/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/Post.java b/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/Post.java
new file mode 100644
index 0000000000..621618a0e6
--- /dev/null
+++ b/patterns-modules/design-patterns-creational-2/src/main/java/com/baeldung/builder/implementation/Post.java
@@ -0,0 +1,74 @@
+package com.baeldung.builder.implementation;
+
+public class Post {
+
+ private String title;
+
+ private String text;
+
+ private String category;
+
+ Post(Builder builder) {
+ this.title = builder.title;
+ this.text = builder.text;
+ this.category = builder.category;
+ }
+
+ Post() {}
+
+ public String getTitle() {
+ return title;
+ }
+
+ public String getText() {
+ return text;
+ }
+
+ public String getCategory() {
+ return category;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+
+ public void setText(String text) {
+ this.text = text;
+ }
+
+ public void setCategory(String category) {
+ this.category = category;
+ }
+
+ @Override
+ public String toString() {
+ return "Post{" + "title='" + title + '\'' + ", text='" + text + '\'' + ", category='" + category + '\'' + '}';
+ }
+
+ public static class Builder {
+ private String title;
+ private String text;
+ private String category;
+
+ public Builder() {}
+
+ public Builder title(String title) {
+ this.title = title;
+ return this;
+ }
+
+ public Builder text(String text) {
+ this.text = text;
+ return this;
+ }
+
+ public Builder category(String category) {
+ this.category = category;
+ return this;
+ }
+
+ public Post build() {
+ return new Post(this);
+ }
+ }
+}
diff --git a/patterns-modules/design-patterns-creational-2/src/test/java/com/baeldung/builder/implementation/BuilderImplementationUnitTest.java b/patterns-modules/design-patterns-creational-2/src/test/java/com/baeldung/builder/implementation/BuilderImplementationUnitTest.java
new file mode 100644
index 0000000000..e05d4f476a
--- /dev/null
+++ b/patterns-modules/design-patterns-creational-2/src/test/java/com/baeldung/builder/implementation/BuilderImplementationUnitTest.java
@@ -0,0 +1,50 @@
+package com.baeldung.builder.implementation;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+import org.junit.jupiter.api.Test;
+
+public class BuilderImplementationUnitTest {
+
+ @Test
+ void givenClassicBuilder_whenBuild_thenReturnObject() {
+
+ Post post = new Post.Builder()
+ .title("Java Builder Pattern")
+ .text("Explaining how to implement the Builder Pattern in Java")
+ .category("Programming")
+ .build();
+
+ assertEquals("Java Builder Pattern", post.getTitle());
+ assertEquals("Explaining how to implement the Builder Pattern in Java", post.getText());
+ assertEquals("Programming", post.getCategory());
+ }
+
+ @Test
+ void givenGenericBuilder_whenBuild_thenReturnObject() {
+
+ Post post = GenericBuilder.of(Post::new)
+ .with(Post::setTitle, "Java Builder Pattern")
+ .with(Post::setText, "Explaining how to implement the Builder Pattern in Java")
+ .with(Post::setCategory, "Programming")
+ .build();
+
+ assertEquals("Java Builder Pattern", post.getTitle());
+ assertEquals("Explaining how to implement the Builder Pattern in Java", post.getText());
+ assertEquals("Programming", post.getCategory());
+ }
+
+ @Test
+ void givenLombokBuilder_whenBuild_thenReturnObject() {
+
+ LombokPost post = LombokPost.builder()
+ .title("Java Builder Pattern")
+ .text("Explaining how to implement the Builder Pattern in Java")
+ .category("Programming")
+ .build();
+
+ assertEquals("Java Builder Pattern", post.getTitle());
+ assertEquals("Explaining how to implement the Builder Pattern in Java", post.getText());
+ assertEquals("Programming", post.getCategory());
+ }
+}
diff --git a/patterns-modules/monkey-patching/pom.xml b/patterns-modules/monkey-patching/pom.xml
index 1d0146d990..93693a7fe3 100644
--- a/patterns-modules/monkey-patching/pom.xml
+++ b/patterns-modules/monkey-patching/pom.xml
@@ -3,7 +3,6 @@
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">
4.0.0
- com.baeldung
monkey-patching
1.0.0-SNAPSHOT
monkey-patching
@@ -19,12 +18,12 @@
org.springframework.boot
spring-boot-starter-web
- 2.7.0
+ ${spring-boot.version}
org.springframework.boot
spring-boot-starter-test
- 2.7.0
+ ${spring-boot.version}
org.springframework.boot
@@ -45,5 +44,7 @@
2.7.0
+ 1.7.32
+ 1.2.7
diff --git a/persistence-modules/duckdb/pom.xml b/persistence-modules/duckdb/pom.xml
new file mode 100644
index 0000000000..9ce4205ee6
--- /dev/null
+++ b/persistence-modules/duckdb/pom.xml
@@ -0,0 +1,42 @@
+
+ 4.0.0
+
+ org.baeldung
+ duckdb
+ duckdb
+
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 9
+ 9
+
+
+
+
+ 0.0.1-SNAPSHOT
+
+
+ com.baeldung
+ persistence-modules
+ 1.0.0-SNAPSHOT
+
+
+
+ UTF-8
+ 0.10.0
+
+
+
+
+ org.duckdb
+ duckdb_jdbc
+ ${duckdb.version}
+
+
+
+
diff --git a/persistence-modules/duckdb/src/test/java/com/baeldung/DuckDbAccess.java b/persistence-modules/duckdb/src/test/java/com/baeldung/DuckDbAccess.java
new file mode 100644
index 0000000000..47c70a2256
--- /dev/null
+++ b/persistence-modules/duckdb/src/test/java/com/baeldung/DuckDbAccess.java
@@ -0,0 +1,198 @@
+package com.baeldung;
+
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.io.File;
+import java.io.IOException;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.ResultSetMetaData;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+
+
+class DuckDbAccessIntegrationTest {
+
+ private Connection conn = null;
+ private Statement stmt = null;
+
+ @BeforeAll
+ static void setupOnce() throws Exception {
+ Class.forName("org.duckdb.DuckDBDriver");
+ }
+
+ @BeforeEach
+ void setup() throws SQLException {
+ conn = DriverManager.getConnection("jdbc:duckdb:");
+ stmt = conn.createStatement();
+ }
+
+ @Test
+ void whenQueryCurrentDate_thenReturnToday() throws SQLException {
+ ResultSet rs = stmt.executeQuery("SELECT current_date");
+ Date currentDate = rs.next() ? rs.getDate(1) : null;
+
+ Calendar calendar = Calendar.getInstance();
+ calendar.set(Calendar.HOUR_OF_DAY, 0);
+ calendar.set(Calendar.MINUTE, 0);
+ calendar.set(Calendar.SECOND, 0);
+ calendar.set(Calendar.MILLISECOND, 0);
+ Date expectedDate = calendar.getTime();
+
+ assertThat(currentDate).isEqualTo(expectedDate);
+ }
+
+ @Test
+ void whenReadCsv_thenReturnHeaderAndData() throws SQLException {
+ String filePath = getResourceAbsolutePath("/customer.csv");
+ String query = String.format("SELECT * FROM read_csv('%s')", filePath);
+
+ ResultSet rs = stmt.executeQuery(query);
+ ResultSetMetaData metadata = rs.getMetaData();
+
+ List actualHeaderNames = new ArrayList<>();
+ for (int n=1; n<=metadata.getColumnCount(); n++) {
+ actualHeaderNames.add(metadata.getColumnLabel(n));
+ }
+
+ // Then
+ List expectedHeaderNames = List.of("CustomerId", "FirstName", "LastName", "Gender");
+ assertThat(actualHeaderNames).isEqualTo(expectedHeaderNames);
+
+ int rowCount = 0;
+ while (rs.next()) {
+ rowCount++;
+ }
+ assertThat(rowCount).isEqualTo(10);
+ }
+
+ @Test
+ void whenImportByCsv_thenReturnCorrectRowCount() throws SQLException {
+ // When
+ String filePath = getResourceAbsolutePath("/customer.csv");
+ String query = String.format("CREATE TABLE customer AS SELECT * FROM read_csv('%s')", filePath);
+ stmt.executeUpdate(query);
+
+ // Then
+ assertThat(getTableRowCount(conn, "customer")).isEqualTo(10);
+ }
+
+ @Test
+ void whenImportByJson_thenReturnCorrectRowCount() throws SQLException {
+ // When
+ String filePath = getResourceAbsolutePath("/product.json");
+ String query = String.format("CREATE TABLE product AS SELECT * FROM read_json('%s')", filePath);
+ stmt.executeUpdate(query);
+
+ // Then
+ assertThat(getTableRowCount(conn, "product")).isEqualTo(3);
+ }
+
+ @Test
+ void whenImportByInsert_thenReturnCorrectRowCount() throws SQLException {
+ // When
+ stmt.executeUpdate("CREATE TABLE purchase(customerId BIGINT, productId BIGINT)");
+
+ String query = "INSERT INTO purchase(customerId, productId) VALUES (?,?)";
+ try (PreparedStatement pStmt = conn.prepareStatement(query)) {
+
+ pStmt.setInt(1, 101);
+ pStmt.setInt(2, 1);
+ pStmt.addBatch();
+
+ pStmt.setInt(1, 101);
+ pStmt.setInt(2, 2);
+ pStmt.addBatch();
+
+ pStmt.setInt(1, 102);
+ pStmt.setInt(2, 2);
+ pStmt.addBatch();
+
+ pStmt.executeBatch();
+ }
+
+ // Then
+ assertThat(getTableRowCount(conn, "purchase")).isEqualTo(3);
+ }
+
+ @Test
+ void whenQueryWithJoin_thenReturnCorrectCount() throws SQLException {
+ String customerFilePath = getResourceAbsolutePath("/customer.csv");
+ String productFilePath = getResourceAbsolutePath("/product.json");
+ whenImportByInsert_thenReturnCorrectRowCount();
+
+ String query = String.format("SELECT C.firstName, C.lastName, P.productName " +
+ "FROM read_csv('%s') AS C, read_json('%s') AS P, purchase S " +
+ "WHERE S.customerId = C.customerId " +
+ "AND S.productId = P.productId ",
+ customerFilePath, productFilePath);
+
+ int count = 0;
+ ResultSet rs = stmt.executeQuery(query);
+ while (rs.next()) {
+ count++;
+ }
+
+ assertThat(count).isEqualTo(3);
+ }
+
+ @Test
+ void whenExportData_thenFileIsCreated() throws IOException, SQLException {
+ createPurchaseView(conn);
+
+ File tempFile = File.createTempFile("temp", "");
+ String exportFilePath = tempFile.getAbsolutePath();
+ String query = String.format("COPY purchase_view TO '%s'", exportFilePath);
+ stmt.executeUpdate(query);
+
+ assertThat(tempFile.length()).isGreaterThan(0);
+ tempFile.delete();
+ }
+
+ @AfterEach
+ void tearDown() throws SQLException {
+ stmt.close();
+ conn.close();
+ }
+
+ private String getResourceAbsolutePath(String name) {
+ return this.getClass().getResource(name).getPath().replaceFirst("/", "");
+ }
+
+ private int getTableRowCount(Connection conn, String tableName) throws SQLException {
+ try (Statement stmt = conn.createStatement()) {
+ ResultSet rs = stmt.executeQuery(String.format("SELECT COUNT(*) FROM %s", tableName));
+ return (rs.next()) ? rs.getInt(1) : 0;
+ }
+ }
+
+ private void createPurchaseView(Connection conn) throws SQLException {
+ whenImportByCsv_thenReturnCorrectRowCount();
+ whenImportByJson_thenReturnCorrectRowCount();
+ whenImportByInsert_thenReturnCorrectRowCount();
+
+ String query = "CREATE VIEW purchase_view AS " +
+ "SELECT P.productName, COUNT(*) AS purchaseCount " +
+ "FROM customer C, product P, purchase S " +
+ "WHERE S.customerId = C.customerId " +
+ "AND S.productId = P.productId " +
+ "GROUP BY P.productName " +
+ "ORDER BY COUNT(*) DESC ";
+
+ try (Statement stmt = conn.createStatement()) {
+ stmt.executeUpdate(query);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/persistence-modules/duckdb/src/test/resources/customer.csv b/persistence-modules/duckdb/src/test/resources/customer.csv
new file mode 100644
index 0000000000..f0da8f569d
--- /dev/null
+++ b/persistence-modules/duckdb/src/test/resources/customer.csv
@@ -0,0 +1,11 @@
+CustomerId,FirstName,LastName,Gender
+101,John,Smith,Male
+102,Sarah,Jones,Female
+103,Michael,Johnson,Male
+104,Emily,Davis,Female
+105,David,Brown,Male
+106,Emma,Williams,Female
+107,Alexander,Miller,Male
+108,Samantha,Anderson,Female
+109,Matthew,Taylor,Male
+110,Olivia,Thompson,Female
\ No newline at end of file
diff --git a/persistence-modules/duckdb/src/test/resources/product.json b/persistence-modules/duckdb/src/test/resources/product.json
new file mode 100644
index 0000000000..ae3b47de28
--- /dev/null
+++ b/persistence-modules/duckdb/src/test/resources/product.json
@@ -0,0 +1,17 @@
+[
+ {
+ "productId": 1,
+ "productName":"EZ Curl Bar",
+ "category": "Sports Equipment"
+ },
+ {
+ "productId": 2,
+ "productName": "7' Barbell",
+ "category": "Sports Equipment"
+ },
+ {
+ "productId": 3,
+ "productName": "Single Mouthguard - Black",
+ "category": "Sports Equipment"
+ }
+]
\ No newline at end of file
diff --git a/persistence-modules/hibernate-annotations-2/README.md b/persistence-modules/hibernate-annotations-2/README.md
new file mode 100644
index 0000000000..9da9b37245
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/README.md
@@ -0,0 +1,6 @@
+## Hibernate Annotations
+
+This module contains articles about Annotations used in Hibernate.
+
+### Relevant Articles:
+- [@Subselect Annotation in Hibernate](https://www.baeldung.com/hibernate-subselect)
diff --git a/persistence-modules/hibernate-annotations-2/pom.xml b/persistence-modules/hibernate-annotations-2/pom.xml
new file mode 100644
index 0000000000..046fbae619
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/pom.xml
@@ -0,0 +1,109 @@
+
+
+ 4.0.0
+
+ hibernate-annotations-2
+ 0.1-SNAPSHOT
+ hibernate-annotations-2
+ jar
+ Hibernate annotations module, part 2
+
+
+ com.baeldung
+ persistence-modules
+ 1.0.0-SNAPSHOT
+
+
+
+
+
+ org.springframework
+ spring-context
+ ${org.springframework.version}
+
+
+ org.springframework.data
+ spring-data-jpa
+ ${org.springframework.data.version}
+
+
+ org.hibernate.orm
+ hibernate-core
+ ${hibernate-core.version}
+
+
+ org.hsqldb
+ hsqldb
+ ${hsqldb.version}
+
+
+ com.h2database
+ h2
+ ${h2.version}
+
+
+ org.apache.commons
+ commons-lang3
+ ${commons-lang3.version}
+
+
+ org.hibernate.orm
+ hibernate-testing
+ ${hibernate-core.version}
+
+
+ org.hibernate.orm
+ hibernate-spatial
+ ${hibernate-core.version}
+
+
+ org.apache.tomcat
+ tomcat-dbcp
+ ${tomcat-dbcp.version}
+
+
+
+
+ com.google.guava
+ guava
+ ${guava.version}
+
+
+
+ org.springframework
+ spring-test
+ ${org.springframework.version}
+ test
+
+
+ io.hypersistence
+ hypersistence-utils-hibernate-60
+ ${hypersistance-utils-hibernate-60.version}
+
+
+ org.liquibase
+ liquibase-core
+ ${liquibase-core.version}
+
+
+ org.projectlombok
+ lombok
+ ${lombok.version}
+
+
+
+
+
+ 6.0.6
+ 3.0.3
+ 6.4.2.Final
+ true
+ 9.0.0.M26
+ 3.3.1
+ 1.18.30
+ 4.24.0
+
+
+
\ No newline at end of file
diff --git a/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/HibernateAnnotationUtil.java b/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/HibernateAnnotationUtil.java
new file mode 100644
index 0000000000..74046854e7
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/HibernateAnnotationUtil.java
@@ -0,0 +1,50 @@
+package com.baeldung.hibernate;
+
+import com.baeldung.hibernate.subselect.RuntimeConfiguration;
+import java.util.HashMap;
+import java.util.Map;
+import org.hibernate.SessionFactory;
+import org.hibernate.boot.Metadata;
+import org.hibernate.boot.MetadataSources;
+import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
+import org.hibernate.cfg.Environment;
+import org.hibernate.service.ServiceRegistry;
+
+public class HibernateAnnotationUtil {
+
+ private static final SessionFactory SESSION_FACTORY = buildSessionFactory();
+
+ /**
+ * Utility class
+ */
+ private HibernateAnnotationUtil() {
+ }
+
+ public static SessionFactory getSessionFactory() {
+ return SESSION_FACTORY;
+ }
+
+ private static SessionFactory buildSessionFactory() {
+ ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
+ .applySettings(dbSettings())
+ .build();
+
+ Metadata metadata = new MetadataSources(serviceRegistry)
+ .addAnnotatedClass(RuntimeConfiguration.class)
+ .buildMetadata();
+
+ return metadata.buildSessionFactory();
+ }
+
+ private static Map dbSettings() {
+ Map dbSettings = new HashMap<>();
+ dbSettings.put(Environment.URL, "jdbc:h2:mem:spring_hibernate_one_to_many");
+ dbSettings.put(Environment.USER, "sa");
+ dbSettings.put(Environment.PASS, "");
+ dbSettings.put(Environment.DRIVER, "org.h2.Driver");
+ dbSettings.put(Environment.CURRENT_SESSION_CONTEXT_CLASS, "thread");
+ dbSettings.put(Environment.SHOW_SQL, "true");
+ dbSettings.put(Environment.HBM2DDL_AUTO, "create");
+ return dbSettings;
+ }
+}
diff --git a/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/PersistenceConfig.java b/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/PersistenceConfig.java
new file mode 100644
index 0000000000..c34b77282c
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/PersistenceConfig.java
@@ -0,0 +1,67 @@
+package com.baeldung.hibernate;
+
+import com.google.common.base.Preconditions;
+import java.util.Properties;
+import javax.sql.DataSource;
+import org.apache.tomcat.dbcp.dbcp2.BasicDataSource;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.core.env.Environment;
+import org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor;
+import org.springframework.orm.hibernate5.HibernateTransactionManager;
+import org.springframework.orm.hibernate5.LocalSessionFactoryBean;
+import org.springframework.transaction.PlatformTransactionManager;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+@Configuration
+@EnableTransactionManagement
+@PropertySource({ "classpath:persistence-h2.properties" })
+public class PersistenceConfig {
+
+ @Autowired
+ private Environment env;
+
+ @Bean
+ public LocalSessionFactoryBean sessionFactory() {
+ final LocalSessionFactoryBean sessionFactory = new LocalSessionFactoryBean();
+ sessionFactory.setDataSource(dataSource());
+ sessionFactory.setPackagesToScan(new String[] { "com.baeldung.hibernate" });
+ sessionFactory.setHibernateProperties(hibernateProperties());
+ return sessionFactory;
+ }
+
+ @Bean
+ public DataSource dataSource() {
+ final BasicDataSource dataSource = new BasicDataSource();
+ dataSource.setDriverClassName(Preconditions.checkNotNull(env.getProperty("jdbc.driverClassName")));
+ dataSource.setUrl(Preconditions.checkNotNull(env.getProperty("jdbc.url")));
+ dataSource.setUsername(Preconditions.checkNotNull(env.getProperty("jdbc.user")));
+ dataSource.setPassword(Preconditions.checkNotNull(env.getProperty("jdbc.pass")));
+
+ return dataSource;
+ }
+
+ @Bean
+ public PlatformTransactionManager hibernateTransactionManager() {
+ final HibernateTransactionManager transactionManager = new HibernateTransactionManager();
+ transactionManager.setSessionFactory(sessionFactory().getObject());
+ return transactionManager;
+ }
+
+ @Bean
+ public PersistenceExceptionTranslationPostProcessor exceptionTranslation() {
+ return new PersistenceExceptionTranslationPostProcessor();
+ }
+
+ private final Properties hibernateProperties() {
+ final Properties hibernateProperties = new Properties();
+ hibernateProperties.setProperty("hibernate.hbm2ddl.auto", env.getProperty("hibernate.hbm2ddl.auto"));
+ hibernateProperties.setProperty("hibernate.dialect", env.getProperty("hibernate.dialect"));
+ hibernateProperties.setProperty("hibernate.show_sql", "false");
+ return hibernateProperties;
+ }
+
+}
\ No newline at end of file
diff --git a/persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/subselect/RuntimeConfiguration.java b/persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/subselect/RuntimeConfiguration.java
similarity index 100%
rename from persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/subselect/RuntimeConfiguration.java
rename to persistence-modules/hibernate-annotations-2/src/main/java/com/baeldung/hibernate/subselect/RuntimeConfiguration.java
diff --git a/persistence-modules/hibernate-annotations/src/main/resources/migrations/V1__init.xml b/persistence-modules/hibernate-annotations-2/src/main/resources/migrations/V1__init.xml
similarity index 100%
rename from persistence-modules/hibernate-annotations/src/main/resources/migrations/V1__init.xml
rename to persistence-modules/hibernate-annotations-2/src/main/resources/migrations/V1__init.xml
diff --git a/persistence-modules/hibernate-annotations/src/main/resources/migrations/master.xml b/persistence-modules/hibernate-annotations-2/src/main/resources/migrations/master.xml
similarity index 100%
rename from persistence-modules/hibernate-annotations/src/main/resources/migrations/master.xml
rename to persistence-modules/hibernate-annotations-2/src/main/resources/migrations/master.xml
diff --git a/persistence-modules/hibernate-annotations-2/src/main/resources/persistence-h2.properties b/persistence-modules/hibernate-annotations-2/src/main/resources/persistence-h2.properties
new file mode 100644
index 0000000000..4bc5e98f56
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/src/main/resources/persistence-h2.properties
@@ -0,0 +1,15 @@
+# jdbc.X
+jdbc.driverClassName=org.h2.Driver
+jdbc.url=jdbc:h2:mem:db;DB_CLOSE_DELAY=-1
+jdbc.eventGeneratedId=sa
+jdbc.user=sa
+jdbc.pass=
+
+# hibernate.X
+hibernate.dialect=org.hibernate.dialect.H2Dialect
+hibernate.show_sql=false
+hibernate.hbm2ddl.auto=create-drop
+hibernate.cache.use_second_level_cache=true
+hibernate.cache.use_query_cache=true
+hibernate.cache.region.factory_class=org.hibernate.cache.ehcache.EhCacheRegionFactory
+
diff --git a/persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/SpringContextTest.java b/persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/SpringContextTest.java
new file mode 100644
index 0000000000..2db3ec53d5
--- /dev/null
+++ b/persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/SpringContextTest.java
@@ -0,0 +1,18 @@
+package com.baeldung;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.test.context.support.AnnotationConfigContextLoader;
+
+import com.baeldung.hibernate.PersistenceConfig;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration(classes = { PersistenceConfig.class }, loader = AnnotationConfigContextLoader.class)
+public class SpringContextTest {
+
+ @Test
+ public void whenSpringContextIsBootstrapped_thenNoExceptions() {
+ }
+}
diff --git a/persistence-modules/hibernate-annotations/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java b/persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java
similarity index 96%
rename from persistence-modules/hibernate-annotations/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java
rename to persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java
index 074468ca37..fee67240e4 100644
--- a/persistence-modules/hibernate-annotations/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java
+++ b/persistence-modules/hibernate-annotations-2/src/test/java/com/baeldung/hibernate/subselect/SubselectIntegrationTest.java
@@ -1,6 +1,6 @@
package com.baeldung.hibernate.subselect;
-import com.baeldung.hibernate.oneToMany.config.HibernateAnnotationUtil;
+import com.baeldung.hibernate.HibernateAnnotationUtil;
import jakarta.persistence.criteria.Root;
import liquibase.Contexts;
import liquibase.LabelExpression;
diff --git a/persistence-modules/hibernate-annotations/README.md b/persistence-modules/hibernate-annotations/README.md
index 663c39ea33..446dde9ece 100644
--- a/persistence-modules/hibernate-annotations/README.md
+++ b/persistence-modules/hibernate-annotations/README.md
@@ -13,3 +13,4 @@ This module contains articles about Annotations used in Hibernate.
- [Hibernate @CreationTimestamp and @UpdateTimestamp](https://www.baeldung.com/hibernate-creationtimestamp-updatetimestamp)
- [Difference Between @JoinColumn and @PrimaryKeyJoinColumn in JPA](https://www.baeldung.com/java-jpa-join-vs-primarykeyjoin)
- [A Guide to the @SoftDelete Annotation in Hibernate](https://www.baeldung.com/java-hibernate-softdelete-annotation)
+- [@Subselect Annotation in Hibernate](https://www.baeldung.com/hibernate-subselect)
diff --git a/persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/oneToMany/config/HibernateAnnotationUtil.java b/persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/oneToMany/config/HibernateAnnotationUtil.java
index 0bf03e3fee..99410e1f76 100644
--- a/persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/oneToMany/config/HibernateAnnotationUtil.java
+++ b/persistence-modules/hibernate-annotations/src/main/java/com/baeldung/hibernate/oneToMany/config/HibernateAnnotationUtil.java
@@ -4,7 +4,6 @@ import com.baeldung.hibernate.oneToMany.model.Cart;
import com.baeldung.hibernate.oneToMany.model.CartOIO;
import com.baeldung.hibernate.oneToMany.model.Item;
import com.baeldung.hibernate.oneToMany.model.ItemOIO;
-import com.baeldung.hibernate.subselect.RuntimeConfiguration;
import org.hibernate.SessionFactory;
import org.hibernate.boot.Metadata;
import org.hibernate.boot.MetadataSources;
@@ -39,7 +38,6 @@ public class HibernateAnnotationUtil {
.addAnnotatedClass(CartOIO.class)
.addAnnotatedClass(Item.class)
.addAnnotatedClass(ItemOIO.class)
- .addAnnotatedClass(RuntimeConfiguration.class)
.buildMetadata();
return metadata.buildSessionFactory();
diff --git a/persistence-modules/hibernate-jpa-2/README.md b/persistence-modules/hibernate-jpa-2/README.md
new file mode 100644
index 0000000000..68ffa73a18
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/README.md
@@ -0,0 +1,10 @@
+## Hibernate JPA
+
+This module contains articles specific to use of Hibernate as a JPA implementation, such as Locking, Bootstrapping, One-to-One Relationship, Persistence Context, and more.
+
+### Relevant articles:
+
+- [JPA/Hibernate Persistence Context](https://www.baeldung.com/jpa-hibernate-persistence-context)
+- [Quick Guide to EntityManager#getReference()](https://www.baeldung.com/jpa-entity-manager-get-reference)
+- [JPA Entities and the Serializable Interface](https://www.baeldung.com/jpa-entities-serializable)
+- [The @Struct Annotation Type in Hibernate – Structured User-Defined Types](https://www.baeldung.com/java-hibernate-struct-annotation)
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa-2/pom.xml b/persistence-modules/hibernate-jpa-2/pom.xml
index 8bacdde59c..3fceb8f152 100644
--- a/persistence-modules/hibernate-jpa-2/pom.xml
+++ b/persistence-modules/hibernate-jpa-2/pom.xml
@@ -1,7 +1,7 @@
+ 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">
4.0.0
hibernate-jpa-2
0.0.1-SNAPSHOT
@@ -92,4 +92,4 @@
1.4.6
-
\ No newline at end of file
+
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Game.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Game.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Game.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Game.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Player.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Player.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Player.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/entitymanager/getreference/Player.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/Account.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/Account.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/Account.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/Account.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/Email.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/Email.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/Email.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/Email.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/User.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/User.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/User.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/User.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/UserId.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/UserId.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/hibernate/serializable/UserId.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/serializable/UserId.java
diff --git a/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructDepartment.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructDepartment.java
new file mode 100644
index 0000000000..419c47791a
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructDepartment.java
@@ -0,0 +1,51 @@
+package com.baeldung.hibernate.struct.entities;
+
+import jakarta.persistence.*;
+
+@Entity
+public class StructDepartment {
+ @Id
+ @GeneratedValue
+ private Integer id;
+
+ @Column
+ private String departmentName;
+
+ @Embedded
+ @Column
+ private StructManager manager;
+
+ @Override
+ public String toString() {
+ return "Department{" +
+ "id=" + id +
+ ", departmentName='" + departmentName + '\'' +
+ ", manager=" + manager +
+ '}';
+ }
+
+ public StructDepartment(String departmentName, StructManager manager) {
+ this.departmentName = departmentName;
+ this.manager = manager;
+ }
+
+ public Integer getId() {
+ return id;
+ }
+
+ public String getDepartmentName() {
+ return departmentName;
+ }
+
+ public void setDepartmentName(String departmentName) {
+ this.departmentName = departmentName;
+ }
+
+ public StructManager getManager() {
+ return manager;
+ }
+
+ public void setManager(StructManager manager) {
+ this.manager = manager;
+ }
+}
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructManager.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructManager.java
new file mode 100644
index 0000000000..10595ecc55
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/hibernate/struct/entities/StructManager.java
@@ -0,0 +1,52 @@
+package com.baeldung.hibernate.struct.entities;
+import jakarta.persistence.Embeddable;
+import org.hibernate.annotations.Struct;
+
+import java.io.Serializable;
+
+@Embeddable
+@Struct(name = "Department_Manager_Type", attributes = {"firstName", "lastName", "qualification"})
+public class StructManager implements Serializable {
+ private String firstName;
+ private String lastName;
+ private String qualification;
+
+ @Override
+ public String toString() {
+ return "Manager{" +
+ "firstName='" + firstName + '\'' +
+ ", lastName='" + lastName + '\'' +
+ ", qualification='" + qualification + '\'' +
+ '}';
+ }
+
+ public StructManager(String firstName, String lastName, String qualification) {
+ this.firstName = firstName;
+ this.lastName = lastName;
+ this.qualification = qualification;
+ }
+
+ 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 getQualification() {
+ return qualification;
+ }
+
+ public void setQualification(String qualification) {
+ this.qualification = qualification;
+ }
+}
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/PersistenceContextDemoApplication.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/PersistenceContextDemoApplication.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/PersistenceContextDemoApplication.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/PersistenceContextDemoApplication.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/entity/User.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/entity/User.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/entity/User.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/entity/User.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/service/ExtendedPersistenceContextUserService.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/service/ExtendedPersistenceContextUserService.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/service/ExtendedPersistenceContextUserService.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/service/ExtendedPersistenceContextUserService.java
diff --git a/persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/service/TransctionPersistenceContextUserService.java b/persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/service/TransctionPersistenceContextUserService.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/main/java/com/baeldung/persistencecontext/service/TransctionPersistenceContextUserService.java
rename to persistence-modules/hibernate-jpa-2/src/main/java/com/baeldung/persistencecontext/service/TransctionPersistenceContextUserService.java
diff --git a/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/create-db.sql b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/create-db.sql
new file mode 100644
index 0000000000..7074b603f6
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/create-db.sql
@@ -0,0 +1,3 @@
+create table Game (id bigint not null, name varchar(255), primary key (id));
+create table Player (id bigint not null, name varchar(255), game_id bigint, primary key (id));
+alter table Player add constraint FKohr86afuapoujklti79wo27aa foreign key (game_id) references Game(id);
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/data.sql b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/data.sql
new file mode 100644
index 0000000000..1e83082801
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/data.sql
@@ -0,0 +1,5 @@
+insert into Game (id, name) values (1, 'Game 1');
+insert into Game (id, name) values (2, 'Game 2');
+insert into Player (game_id, name, id) values (null, 'Player 1', 1);
+insert into Player (game_id, name, id) values (null, 'Player 2', 2);
+insert into Player (game_id, name, id) values (null, 'Player 3', 3);
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/drop-db.sql b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/drop-db.sql
new file mode 100644
index 0000000000..275324fcae
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/resources/META-INF/drop-db.sql
@@ -0,0 +1,2 @@
+drop table if exists Player;
+drop table if exists Game;
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa-2/src/main/resources/log4j.xml b/persistence-modules/hibernate-jpa-2/src/main/resources/log4j.xml
new file mode 100644
index 0000000000..f58dbdc514
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/main/resources/log4j.xml
@@ -0,0 +1,22 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceH2IntegrationTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceH2IntegrationTest.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceH2IntegrationTest.java
rename to persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceH2IntegrationTest.java
diff --git a/persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceMySQLManualTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceMySQLManualTest.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceMySQLManualTest.java
rename to persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferenceMySQLManualTest.java
diff --git a/persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferencePostgreSQLManualTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferencePostgreSQLManualTest.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferencePostgreSQLManualTest.java
rename to persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/entitymanager/getreference/GetReferencePostgreSQLManualTest.java
diff --git a/persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/serializable/JPASerializableIntegrationTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/serializable/JPASerializableIntegrationTest.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/test/java/com/baeldung/hibernate/serializable/JPASerializableIntegrationTest.java
rename to persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/serializable/JPASerializableIntegrationTest.java
diff --git a/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/struct/HibernateStructUnitTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/struct/HibernateStructUnitTest.java
new file mode 100644
index 0000000000..f63fbf80e2
--- /dev/null
+++ b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/hibernate/struct/HibernateStructUnitTest.java
@@ -0,0 +1,100 @@
+package com.baeldung.hibernate.struct;
+
+import com.baeldung.hibernate.struct.entities.StructDepartment;
+import com.baeldung.hibernate.struct.entities.StructManager;
+import org.apache.commons.lang3.StringUtils;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.hibernate.Transaction;
+import org.hibernate.boot.Metadata;
+import org.hibernate.boot.MetadataSources;
+import org.hibernate.boot.registry.StandardServiceRegistryBuilder;
+import org.hibernate.service.ServiceRegistry;
+import org.junit.After;
+import org.junit.Before;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.net.URL;
+import java.util.Properties;
+
+public class HibernateStructUnitTest {
+
+ private Session session;
+ private Transaction transaction;
+
+ 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);
+ metadataSources.addPackage("com.baeldung.hibernate.struct.entities");
+ metadataSources.addAnnotatedClass(StructDepartment.class);
+ metadataSources.addAnnotatedClass(StructManager.class);
+
+ Metadata metadata = metadataSources.getMetadataBuilder()
+ .build();
+
+ return metadata.getSessionFactoryBuilder()
+ .build();
+
+ }
+ private static ServiceRegistry configureServiceRegistry(Properties properties) throws IOException {
+ return new StandardServiceRegistryBuilder().applySettings(properties)
+ .build();
+ }
+
+ public static Properties getProperties() throws IOException {
+ Properties properties = new Properties();
+ URL propertiesURL = Thread.currentThread()
+ .getContextClassLoader()
+ .getResource(StringUtils.defaultString(PROPERTY_FILE_NAME, "hibernate-derby.properties"));
+ try (FileInputStream inputStream = new FileInputStream(propertiesURL.getFile())) {
+ properties.load(inputStream);
+ }
+ return properties;
+ }
+
+ private static ServiceRegistry configureServiceRegistry() throws IOException {
+ return configureServiceRegistry(getProperties());
+ }
+ private static String PROPERTY_FILE_NAME;
+ public static SessionFactory getSessionFactory(String propertyFileName) throws IOException {
+ PROPERTY_FILE_NAME = propertyFileName;
+ ServiceRegistry serviceRegistry = configureServiceRegistry();
+ return makeSessionFactory(serviceRegistry);
+ }
+ @Before
+ public void setUp() throws IOException {
+ session = getSessionFactory("hibernate-derby.properties")
+ .openSession();
+ transaction = session.beginTransaction();
+
+ transaction.commit();
+ transaction = session.beginTransaction();
+ }
+
+ @After
+ public void tearDown() {
+ transaction.rollback();
+ session.close();
+ }
+
+
+
+/* This unit test is for reference only because the Hibernate dialect for
+ Apache Derby database does not support @Struct annotation.
+
+ @Test
+ public void givenSaveDepartmentObject_ThenManagerUDTExists() {
+ StructDepartment d = new StructDepartment("Information Technology"
+ , new StructManager("Zeeshan", "Arif", "Qualified"));
+
+ session.persist(d);
+ session.flush();
+ session.clear();
+
+ }*/
+}
diff --git a/persistence-modules/hibernate-jpa/src/test/java/com/baeldung/persistencecontext/PersistenceContextIntegrationTest.java b/persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/persistencecontext/PersistenceContextIntegrationTest.java
similarity index 100%
rename from persistence-modules/hibernate-jpa/src/test/java/com/baeldung/persistencecontext/PersistenceContextIntegrationTest.java
rename to persistence-modules/hibernate-jpa-2/src/test/java/com/baeldung/persistencecontext/PersistenceContextIntegrationTest.java
diff --git a/persistence-modules/hibernate-jpa/README.md b/persistence-modules/hibernate-jpa/README.md
index 5599140732..65b3ac8158 100644
--- a/persistence-modules/hibernate-jpa/README.md
+++ b/persistence-modules/hibernate-jpa/README.md
@@ -10,7 +10,4 @@ This module contains articles specific to use of Hibernate as a JPA implementati
- [Optimistic Locking in JPA](https://www.baeldung.com/jpa-optimistic-locking)
- [Criteria API – An Example of IN Expressions](https://www.baeldung.com/jpa-criteria-api-in-expressions)
- [One-to-One Relationship in JPA](https://www.baeldung.com/jpa-one-to-one)
-- [Enabling Transaction Locks in Spring Data JPA](https://www.baeldung.com/java-jpa-transaction-locks)
-- [JPA/Hibernate Persistence Context](https://www.baeldung.com/jpa-hibernate-persistence-context)
-- [Quick Guide to EntityManager#getReference()](https://www.baeldung.com/jpa-entity-manager-get-reference)
-- [JPA Entities and the Serializable Interface](https://www.baeldung.com/jpa-entities-serializable)
\ No newline at end of file
+- [Enabling Transaction Locks in Spring Data JPA](https://www.baeldung.com/java-jpa-transaction-locks)
\ No newline at end of file
diff --git a/persistence-modules/hibernate-jpa/src/test/resources/hibernate-derby.properties b/persistence-modules/hibernate-jpa/src/test/resources/hibernate-derby.properties
new file mode 100644
index 0000000000..72256d1687
--- /dev/null
+++ b/persistence-modules/hibernate-jpa/src/test/resources/hibernate-derby.properties
@@ -0,0 +1,17 @@
+hibernate.connection.driver_class=org.apache.derby.jdbc.EmbeddedDriver
+hibernate.connection.url=jdbc:derby:db/derby.dbfile;create=true
+hibernate.connection.username=
+hibernate.connection.autocommit=true
+jdbc.password=
+
+hibernate.dialect=org.hibernate.dialect.DerbyDialect
+
+# enable to see Hibernate generated SQL
+hibernate.show_sql=false
+
+hibernate.hbm2ddl.auto=create-drop
+
+hibernate.c3p0.min_size=5
+hibernate.c3p0.max_size=20
+hibernate.c3p0.acquire_increment=5
+hibernate.c3p0.timeout=1800
diff --git a/persistence-modules/hibernate-queries/README.md b/persistence-modules/hibernate-queries/README.md
index 9e6c52d6dc..60a84de779 100644
--- a/persistence-modules/hibernate-queries/README.md
+++ b/persistence-modules/hibernate-queries/README.md
@@ -13,3 +13,4 @@ This module contains articles about use of Queries in Hibernate.
- [Distinct Queries in HQL](https://www.baeldung.com/java-hql-distinct)
- [JPA and Hibernate – Criteria vs. JPQL vs. HQL Query](https://www.baeldung.com/jpql-hql-criteria-query)
- [Database Keywords as Columns in Hibernate Entities](https://www.baeldung.com/java-hibernate-db-keywords-as-columns)
+- [Get List of Entity From Database in Hibernate](https://www.baeldung.com/java-hibernate-fetch-entity-list)
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/DefaultCatalog.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/DefaultCatalog.java
new file mode 100644
index 0000000000..a730e9bfc6
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/DefaultCatalog.java
@@ -0,0 +1,56 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables;
+
+
+import com.baeldung.jooq.jointables.public_.Public;
+
+import java.util.Arrays;
+import java.util.List;
+
+import org.jooq.Constants;
+import org.jooq.Schema;
+import org.jooq.impl.CatalogImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class DefaultCatalog extends CatalogImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of DEFAULT_CATALOG
+ */
+ public static final DefaultCatalog DEFAULT_CATALOG = new DefaultCatalog();
+
+ /**
+ * The schema public.
+ */
+ public final Public PUBLIC = Public.PUBLIC;
+
+ /**
+ * No further instances allowed
+ */
+ private DefaultCatalog() {
+ super("");
+ }
+
+ @Override
+ public final List getSchemas() {
+ return Arrays.asList(
+ Public.PUBLIC
+ );
+ }
+
+ /**
+ * A reference to the 3.19 minor release of the code generator. If this
+ * doesn't compile, it's because the runtime library uses an older minor
+ * release, namely: 3.19. You can turn off the generation of this reference
+ * by specifying /configuration/generator/generate/jooqVersionReference
+ */
+ private static final String REQUIRE_RUNTIME_JOOQ_VERSION = Constants.VERSION_3_19;
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/JoinTables.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/JoinTables.java
new file mode 100644
index 0000000000..2c67ef2ad3
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/JoinTables.java
@@ -0,0 +1,75 @@
+package com.baeldung.jooq.jointables;
+
+import static org.jooq.impl.DSL.field;
+
+import org.jooq.DSLContext;
+import org.jooq.Record;
+import org.jooq.Result;
+import org.jooq.SelectJoinStep;
+
+import com.baeldung.jooq.jointables.public_.Tables;
+
+public class JoinTables {
+
+ public static Result usingJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .join(Tables.BOOKAUTHOR)
+ .on(field(Tables.BOOK.AUTHOR_ID).eq(field(Tables.BOOKAUTHOR.ID)));
+ return query.fetch();
+ }
+
+ public static Result usingMultipleJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .join(Tables.BOOKAUTHOR)
+ .on(field(Tables.BOOK.AUTHOR_ID).eq(field(Tables.BOOKAUTHOR.ID)))
+ .join(Tables.STORE)
+ .on(field(Tables.BOOK.STORE_ID).eq(field(Tables.STORE.ID)));
+ return query.fetch();
+ }
+
+ public static Result usingLeftOuterJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .leftOuterJoin(Tables.BOOKAUTHOR)
+ .on(field(Tables.BOOK.AUTHOR_ID).eq(field(Tables.BOOKAUTHOR.ID)));
+ return query.fetch();
+ }
+
+ public static Result usingRightOuterJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .rightOuterJoin(Tables.BOOKAUTHOR)
+ .on(field(Tables.BOOK.AUTHOR_ID).eq(field(Tables.BOOKAUTHOR.ID)));
+ return query.fetch();
+ }
+
+ public static Result usingFullOuterJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .fullOuterJoin(Tables.BOOKAUTHOR)
+ .on(field(Tables.BOOK.AUTHOR_ID).eq(field(Tables.BOOKAUTHOR.ID)));
+ return query.fetch();
+ }
+
+ public static Result usingNaturalJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.BOOK)
+ .naturalJoin(Tables.BOOKAUTHOR);
+ return query.fetch();
+ }
+
+ public static Result usingCrossJoinMethod(DSLContext context) {
+ SelectJoinStep query = context.select()
+ .from(Tables.STORE)
+ .crossJoin(Tables.BOOK);
+ return query.fetch();
+ }
+
+ public static void printResult(Result result) {
+ for (Record record : result) {
+ System.out.println(record);
+ }
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Keys.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Keys.java
new file mode 100644
index 0000000000..86c1939891
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Keys.java
@@ -0,0 +1,34 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_;
+
+
+import com.baeldung.jooq.jointables.public_.tables.Book;
+import com.baeldung.jooq.jointables.public_.tables.Bookauthor;
+import com.baeldung.jooq.jointables.public_.tables.Store;
+import com.baeldung.jooq.jointables.public_.tables.records.BookRecord;
+import com.baeldung.jooq.jointables.public_.tables.records.BookauthorRecord;
+import com.baeldung.jooq.jointables.public_.tables.records.StoreRecord;
+
+import org.jooq.TableField;
+import org.jooq.UniqueKey;
+import org.jooq.impl.DSL;
+import org.jooq.impl.Internal;
+
+
+/**
+ * A class modelling foreign key relationships and constraints of tables in
+ * public.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Keys {
+
+ // -------------------------------------------------------------------------
+ // UNIQUE and PRIMARY KEY definitions
+ // -------------------------------------------------------------------------
+
+ public static final UniqueKey BOOK_PKEY = Internal.createUniqueKey(Book.BOOK, DSL.name("Book_pkey"), new TableField[] { Book.BOOK.ID }, true);
+ public static final UniqueKey AUTHOR_PKEY = Internal.createUniqueKey(Bookauthor.BOOKAUTHOR, DSL.name("Author_pkey"), new TableField[] { Bookauthor.BOOKAUTHOR.ID }, true);
+ public static final UniqueKey STORE_PKEY = Internal.createUniqueKey(Store.STORE, DSL.name("Store_pkey"), new TableField[] { Store.STORE.ID }, true);
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Public.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Public.java
new file mode 100644
index 0000000000..1b2e8dda87
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Public.java
@@ -0,0 +1,69 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_;
+
+
+import com.baeldung.jooq.jointables.DefaultCatalog;
+import com.baeldung.jooq.jointables.public_.tables.Book;
+import com.baeldung.jooq.jointables.public_.tables.Bookauthor;
+import com.baeldung.jooq.jointables.public_.tables.Store;
+
+import java.util.Arrays;
+import java.util.List;
+
+import org.jooq.Catalog;
+import org.jooq.Table;
+import org.jooq.impl.SchemaImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Public extends SchemaImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of public
+ */
+ public static final Public PUBLIC = new Public();
+
+ /**
+ * The table public.Book.
+ */
+ public final Book BOOK = Book.BOOK;
+
+ /**
+ * The table public.BookAuthor.
+ */
+ public final Bookauthor BOOKAUTHOR = Bookauthor.BOOKAUTHOR;
+
+ /**
+ * The table public.Store.
+ */
+ public final Store STORE = Store.STORE;
+
+ /**
+ * No further instances allowed
+ */
+ private Public() {
+ super("public", null);
+ }
+
+
+ @Override
+ public Catalog getCatalog() {
+ return DefaultCatalog.DEFAULT_CATALOG;
+ }
+
+ @Override
+ public final List> getTables() {
+ return Arrays.asList(
+ Book.BOOK,
+ Bookauthor.BOOKAUTHOR,
+ Store.STORE
+ );
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Tables.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Tables.java
new file mode 100644
index 0000000000..789c131a25
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/Tables.java
@@ -0,0 +1,32 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_;
+
+
+import com.baeldung.jooq.jointables.public_.tables.Book;
+import com.baeldung.jooq.jointables.public_.tables.Bookauthor;
+import com.baeldung.jooq.jointables.public_.tables.Store;
+
+
+/**
+ * Convenience access to all tables in public.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Tables {
+
+ /**
+ * The table public.Book.
+ */
+ public static final Book BOOK = Book.BOOK;
+
+ /**
+ * The table public.BookAuthor.
+ */
+ public static final Bookauthor BOOKAUTHOR = Bookauthor.BOOKAUTHOR;
+
+ /**
+ * The table public.Store.
+ */
+ public static final Store STORE = Store.STORE;
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Book.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Book.java
new file mode 100644
index 0000000000..4e21648cbd
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Book.java
@@ -0,0 +1,238 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables;
+
+
+import com.baeldung.jooq.jointables.public_.Keys;
+import com.baeldung.jooq.jointables.public_.Public;
+import com.baeldung.jooq.jointables.public_.tables.records.BookRecord;
+
+import java.util.Collection;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.PlainSQL;
+import org.jooq.QueryPart;
+import org.jooq.SQL;
+import org.jooq.Schema;
+import org.jooq.Select;
+import org.jooq.Stringly;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.UniqueKey;
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Book extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of public.Book
+ */
+ public static final Book BOOK = new Book();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return BookRecord.class;
+ }
+
+ /**
+ * The column public.Book.id.
+ */
+ public final TableField ID = createField(DSL.name("id"), SQLDataType.INTEGER.nullable(false), this, "");
+
+ /**
+ * The column public.Book.author_id.
+ */
+ public final TableField AUTHOR_ID = createField(DSL.name("author_id"), SQLDataType.INTEGER, this, "");
+
+ /**
+ * The column public.Book.title.
+ */
+ public final TableField TITLE = createField(DSL.name("title"), SQLDataType.VARCHAR, this, "");
+
+ /**
+ * The column public.Book.description.
+ */
+ public final TableField DESCRIPTION = createField(DSL.name("description"), SQLDataType.VARCHAR, this, "");
+
+ /**
+ * The column public.Book.store_id.
+ */
+ public final TableField STORE_ID = createField(DSL.name("store_id"), SQLDataType.INTEGER, this, "");
+
+ private Book(Name alias, Table aliased) {
+ this(alias, aliased, (Field[]) null, null);
+ }
+
+ private Book(Name alias, Table aliased, Field[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.table(), where);
+ }
+
+ /**
+ * Create an aliased public.Book table reference
+ */
+ public Book(String alias) {
+ this(DSL.name(alias), BOOK);
+ }
+
+ /**
+ * Create an aliased public.Book table reference
+ */
+ public Book(Name alias) {
+ this(alias, BOOK);
+ }
+
+ /**
+ * Create a public.Book table reference
+ */
+ public Book() {
+ this(DSL.name("Book"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : Public.PUBLIC;
+ }
+
+ @Override
+ public UniqueKey getPrimaryKey() {
+ return Keys.BOOK_PKEY;
+ }
+
+ @Override
+ public Book as(String alias) {
+ return new Book(DSL.name(alias), this);
+ }
+
+ @Override
+ public Book as(Name alias) {
+ return new Book(alias, this);
+ }
+
+ @Override
+ public Book as(Table alias) {
+ return new Book(alias.getQualifiedName(), this);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Book rename(String name) {
+ return new Book(DSL.name(name), null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Book rename(Name name) {
+ return new Book(name, null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Book rename(Table name) {
+ return new Book(name.getQualifiedName(), null);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book where(Condition condition) {
+ return new Book(getQualifiedName(), aliased() ? this : null, null, condition);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book where(Collection conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book where(Condition... conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book where(Field condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Book where(SQL condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Book where(@Stringly.SQL String condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Book where(@Stringly.SQL String condition, Object... binds) {
+ return where(DSL.condition(condition, binds));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Book where(@Stringly.SQL String condition, QueryPart... parts) {
+ return where(DSL.condition(condition, parts));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book whereExists(Select select) {
+ return where(DSL.exists(select));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Book whereNotExists(Select select) {
+ return where(DSL.notExists(select));
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Bookauthor.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Bookauthor.java
new file mode 100644
index 0000000000..9d828e9add
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Bookauthor.java
@@ -0,0 +1,228 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables;
+
+
+import com.baeldung.jooq.jointables.public_.Keys;
+import com.baeldung.jooq.jointables.public_.Public;
+import com.baeldung.jooq.jointables.public_.tables.records.BookauthorRecord;
+
+import java.util.Collection;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.PlainSQL;
+import org.jooq.QueryPart;
+import org.jooq.SQL;
+import org.jooq.Schema;
+import org.jooq.Select;
+import org.jooq.Stringly;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.UniqueKey;
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Bookauthor extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of public.BookAuthor
+ */
+ public static final Bookauthor BOOKAUTHOR = new Bookauthor();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return BookauthorRecord.class;
+ }
+
+ /**
+ * The column public.BookAuthor.id.
+ */
+ public final TableField ID = createField(DSL.name("id"), SQLDataType.INTEGER.nullable(false), this, "");
+
+ /**
+ * The column public.BookAuthor.name.
+ */
+ public final TableField NAME = createField(DSL.name("name"), SQLDataType.VARCHAR.nullable(false), this, "");
+
+ /**
+ * The column public.BookAuthor.country.
+ */
+ public final TableField COUNTRY = createField(DSL.name("country"), SQLDataType.VARCHAR, this, "");
+
+ private Bookauthor(Name alias, Table aliased) {
+ this(alias, aliased, (Field[]) null, null);
+ }
+
+ private Bookauthor(Name alias, Table aliased, Field[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.table(), where);
+ }
+
+ /**
+ * Create an aliased public.BookAuthor table reference
+ */
+ public Bookauthor(String alias) {
+ this(DSL.name(alias), BOOKAUTHOR);
+ }
+
+ /**
+ * Create an aliased public.BookAuthor table reference
+ */
+ public Bookauthor(Name alias) {
+ this(alias, BOOKAUTHOR);
+ }
+
+ /**
+ * Create a public.BookAuthor table reference
+ */
+ public Bookauthor() {
+ this(DSL.name("BookAuthor"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : Public.PUBLIC;
+ }
+
+ @Override
+ public UniqueKey getPrimaryKey() {
+ return Keys.AUTHOR_PKEY;
+ }
+
+ @Override
+ public Bookauthor as(String alias) {
+ return new Bookauthor(DSL.name(alias), this);
+ }
+
+ @Override
+ public Bookauthor as(Name alias) {
+ return new Bookauthor(alias, this);
+ }
+
+ @Override
+ public Bookauthor as(Table alias) {
+ return new Bookauthor(alias.getQualifiedName(), this);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Bookauthor rename(String name) {
+ return new Bookauthor(DSL.name(name), null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Bookauthor rename(Name name) {
+ return new Bookauthor(name, null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Bookauthor rename(Table name) {
+ return new Bookauthor(name.getQualifiedName(), null);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor where(Condition condition) {
+ return new Bookauthor(getQualifiedName(), aliased() ? this : null, null, condition);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor where(Collection conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor where(Condition... conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor where(Field condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Bookauthor where(SQL condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Bookauthor where(@Stringly.SQL String condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Bookauthor where(@Stringly.SQL String condition, Object... binds) {
+ return where(DSL.condition(condition, binds));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Bookauthor where(@Stringly.SQL String condition, QueryPart... parts) {
+ return where(DSL.condition(condition, parts));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor whereExists(Select select) {
+ return where(DSL.exists(select));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Bookauthor whereNotExists(Select select) {
+ return where(DSL.notExists(select));
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Store.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Store.java
new file mode 100644
index 0000000000..d97f3da21b
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/Store.java
@@ -0,0 +1,223 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables;
+
+
+import com.baeldung.jooq.jointables.public_.Keys;
+import com.baeldung.jooq.jointables.public_.Public;
+import com.baeldung.jooq.jointables.public_.tables.records.StoreRecord;
+
+import java.util.Collection;
+
+import org.jooq.Condition;
+import org.jooq.Field;
+import org.jooq.Name;
+import org.jooq.PlainSQL;
+import org.jooq.QueryPart;
+import org.jooq.SQL;
+import org.jooq.Schema;
+import org.jooq.Select;
+import org.jooq.Stringly;
+import org.jooq.Table;
+import org.jooq.TableField;
+import org.jooq.TableOptions;
+import org.jooq.UniqueKey;
+import org.jooq.impl.DSL;
+import org.jooq.impl.SQLDataType;
+import org.jooq.impl.TableImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class Store extends TableImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * The reference instance of public.Store
+ */
+ public static final Store STORE = new Store();
+
+ /**
+ * The class holding records for this type
+ */
+ @Override
+ public Class getRecordType() {
+ return StoreRecord.class;
+ }
+
+ /**
+ * The column public.Store.id.
+ */
+ public final TableField ID = createField(DSL.name("id"), SQLDataType.INTEGER.nullable(false), this, "");
+
+ /**
+ * The column public.Store.name.
+ */
+ public final TableField NAME = createField(DSL.name("name"), SQLDataType.VARCHAR.nullable(false), this, "");
+
+ private Store(Name alias, Table aliased) {
+ this(alias, aliased, (Field[]) null, null);
+ }
+
+ private Store(Name alias, Table aliased, Field[] parameters, Condition where) {
+ super(alias, null, aliased, parameters, DSL.comment(""), TableOptions.table(), where);
+ }
+
+ /**
+ * Create an aliased public.Store table reference
+ */
+ public Store(String alias) {
+ this(DSL.name(alias), STORE);
+ }
+
+ /**
+ * Create an aliased public.Store table reference
+ */
+ public Store(Name alias) {
+ this(alias, STORE);
+ }
+
+ /**
+ * Create a public.Store table reference
+ */
+ public Store() {
+ this(DSL.name("Store"), null);
+ }
+
+ @Override
+ public Schema getSchema() {
+ return aliased() ? null : Public.PUBLIC;
+ }
+
+ @Override
+ public UniqueKey getPrimaryKey() {
+ return Keys.STORE_PKEY;
+ }
+
+ @Override
+ public Store as(String alias) {
+ return new Store(DSL.name(alias), this);
+ }
+
+ @Override
+ public Store as(Name alias) {
+ return new Store(alias, this);
+ }
+
+ @Override
+ public Store as(Table alias) {
+ return new Store(alias.getQualifiedName(), this);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Store rename(String name) {
+ return new Store(DSL.name(name), null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Store rename(Name name) {
+ return new Store(name, null);
+ }
+
+ /**
+ * Rename this table
+ */
+ @Override
+ public Store rename(Table name) {
+ return new Store(name.getQualifiedName(), null);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store where(Condition condition) {
+ return new Store(getQualifiedName(), aliased() ? this : null, null, condition);
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store where(Collection conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store where(Condition... conditions) {
+ return where(DSL.and(conditions));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store where(Field condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Store where(SQL condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Store where(@Stringly.SQL String condition) {
+ return where(DSL.condition(condition));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Store where(@Stringly.SQL String condition, Object... binds) {
+ return where(DSL.condition(condition, binds));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ @PlainSQL
+ public Store where(@Stringly.SQL String condition, QueryPart... parts) {
+ return where(DSL.condition(condition, parts));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store whereExists(Select select) {
+ return where(DSL.exists(select));
+ }
+
+ /**
+ * Create an inline derived table from this table
+ */
+ @Override
+ public Store whereNotExists(Select select) {
+ return where(DSL.notExists(select));
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookRecord.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookRecord.java
new file mode 100644
index 0000000000..0636ff2fdf
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookRecord.java
@@ -0,0 +1,124 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables.records;
+
+
+import com.baeldung.jooq.jointables.public_.tables.Book;
+
+import org.jooq.Record1;
+import org.jooq.impl.UpdatableRecordImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class BookRecord extends UpdatableRecordImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * Setter for public.Book.id.
+ */
+ public void setId(Integer value) {
+ set(0, value);
+ }
+
+ /**
+ * Getter for public.Book.id.
+ */
+ public Integer getId() {
+ return (Integer) get(0);
+ }
+
+ /**
+ * Setter for public.Book.author_id.
+ */
+ public void setAuthorId(Integer value) {
+ set(1, value);
+ }
+
+ /**
+ * Getter for public.Book.author_id.
+ */
+ public Integer getAuthorId() {
+ return (Integer) get(1);
+ }
+
+ /**
+ * Setter for public.Book.title.
+ */
+ public void setTitle(String value) {
+ set(2, value);
+ }
+
+ /**
+ * Getter for public.Book.title.
+ */
+ public String getTitle() {
+ return (String) get(2);
+ }
+
+ /**
+ * Setter for public.Book.description.
+ */
+ public void setDescription(String value) {
+ set(3, value);
+ }
+
+ /**
+ * Getter for public.Book.description.
+ */
+ public String getDescription() {
+ return (String) get(3);
+ }
+
+ /**
+ * Setter for public.Book.store_id.
+ */
+ public void setStoreId(Integer value) {
+ set(4, value);
+ }
+
+ /**
+ * Getter for public.Book.store_id.
+ */
+ public Integer getStoreId() {
+ return (Integer) get(4);
+ }
+
+ // -------------------------------------------------------------------------
+ // Primary key information
+ // -------------------------------------------------------------------------
+
+ @Override
+ public Record1 key() {
+ return (Record1) super.key();
+ }
+
+ // -------------------------------------------------------------------------
+ // Constructors
+ // -------------------------------------------------------------------------
+
+ /**
+ * Create a detached BookRecord
+ */
+ public BookRecord() {
+ super(Book.BOOK);
+ }
+
+ /**
+ * Create a detached, initialised BookRecord
+ */
+ public BookRecord(Integer id, Integer authorId, String title, String description, Integer storeId) {
+ super(Book.BOOK);
+
+ setId(id);
+ setAuthorId(authorId);
+ setTitle(title);
+ setDescription(description);
+ setStoreId(storeId);
+ resetChangedOnNotNull();
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookauthorRecord.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookauthorRecord.java
new file mode 100644
index 0000000000..0e99b2d93b
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/BookauthorRecord.java
@@ -0,0 +1,94 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables.records;
+
+
+import com.baeldung.jooq.jointables.public_.tables.Bookauthor;
+
+import org.jooq.Record1;
+import org.jooq.impl.UpdatableRecordImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class BookauthorRecord extends UpdatableRecordImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * Setter for public.BookAuthor.id.
+ */
+ public void setId(Integer value) {
+ set(0, value);
+ }
+
+ /**
+ * Getter for public.BookAuthor.id.
+ */
+ public Integer getId() {
+ return (Integer) get(0);
+ }
+
+ /**
+ * Setter for public.BookAuthor.name.
+ */
+ public void setName(String value) {
+ set(1, value);
+ }
+
+ /**
+ * Getter for public.BookAuthor.name.
+ */
+ public String getName() {
+ return (String) get(1);
+ }
+
+ /**
+ * Setter for public.BookAuthor.country.
+ */
+ public void setCountry(String value) {
+ set(2, value);
+ }
+
+ /**
+ * Getter for public.BookAuthor.country.
+ */
+ public String getCountry() {
+ return (String) get(2);
+ }
+
+ // -------------------------------------------------------------------------
+ // Primary key information
+ // -------------------------------------------------------------------------
+
+ @Override
+ public Record1 key() {
+ return (Record1) super.key();
+ }
+
+ // -------------------------------------------------------------------------
+ // Constructors
+ // -------------------------------------------------------------------------
+
+ /**
+ * Create a detached BookauthorRecord
+ */
+ public BookauthorRecord() {
+ super(Bookauthor.BOOKAUTHOR);
+ }
+
+ /**
+ * Create a detached, initialised BookauthorRecord
+ */
+ public BookauthorRecord(Integer id, String name, String country) {
+ super(Bookauthor.BOOKAUTHOR);
+
+ setId(id);
+ setName(name);
+ setCountry(country);
+ resetChangedOnNotNull();
+ }
+}
diff --git a/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/StoreRecord.java b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/StoreRecord.java
new file mode 100644
index 0000000000..f8628818e3
--- /dev/null
+++ b/persistence-modules/jooq/src/main/java/com/baeldung/jooq/jointables/public_/tables/records/StoreRecord.java
@@ -0,0 +1,79 @@
+/*
+ * This file is generated by jOOQ.
+ */
+package com.baeldung.jooq.jointables.public_.tables.records;
+
+
+import com.baeldung.jooq.jointables.public_.tables.Store;
+
+import org.jooq.Record1;
+import org.jooq.impl.UpdatableRecordImpl;
+
+
+/**
+ * This class is generated by jOOQ.
+ */
+@SuppressWarnings({ "all", "unchecked", "rawtypes", "this-escape" })
+public class StoreRecord extends UpdatableRecordImpl {
+
+ private static final long serialVersionUID = 1L;
+
+ /**
+ * Setter for public.Store.id.
+ */
+ public void setId(Integer value) {
+ set(0, value);
+ }
+
+ /**
+ * Getter for public.Store.id.
+ */
+ public Integer getId() {
+ return (Integer) get(0);
+ }
+
+ /**
+ * Setter for public.Store.name.
+ */
+ public void setName(String value) {
+ set(1, value);
+ }
+
+ /**
+ * Getter for public.Store.name.
+ */
+ public String getName() {
+ return (String) get(1);
+ }
+
+ // -------------------------------------------------------------------------
+ // Primary key information
+ // -------------------------------------------------------------------------
+
+ @Override
+ public Record1 key() {
+ return (Record1) super.key();
+ }
+
+ // -------------------------------------------------------------------------
+ // Constructors
+ // -------------------------------------------------------------------------
+
+ /**
+ * Create a detached StoreRecord
+ */
+ public StoreRecord() {
+ super(Store.STORE);
+ }
+
+ /**
+ * Create a detached, initialised StoreRecord
+ */
+ public StoreRecord(Integer id, String name) {
+ super(Store.STORE);
+
+ setId(id);
+ setName(name);
+ resetChangedOnNotNull();
+ }
+}
diff --git a/persistence-modules/jooq/src/test/java/com/baeldung/jooq/jointables/JoinTablesLiveTest.java b/persistence-modules/jooq/src/test/java/com/baeldung/jooq/jointables/JoinTablesLiveTest.java
new file mode 100644
index 0000000000..a5daf53542
--- /dev/null
+++ b/persistence-modules/jooq/src/test/java/com/baeldung/jooq/jointables/JoinTablesLiveTest.java
@@ -0,0 +1,111 @@
+package com.baeldung.jooq.jointables;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+
+import org.jooq.DSLContext;
+import org.jooq.Record;
+import org.jooq.Result;
+import org.jooq.SQLDialect;
+import org.jooq.impl.DSL;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import com.baeldung.jooq.jointables.public_.Tables;
+import com.baeldung.jooq.jointables.public_.tables.Book;
+import com.baeldung.jooq.jointables.public_.tables.Bookauthor;
+import com.baeldung.jooq.jointables.public_.tables.Store;
+
+public class JoinTablesLiveTest {
+
+ static DSLContext context;
+
+ @BeforeClass
+ public static void setUp() throws Exception {
+ // URL jooqConfigURL = getClass().getClassLoader().getResource("jooq-config-2.xml");
+ // File file = new File(jooqConfigURL.getFile());
+ // GenerationTool.generate(Files.readString(file.toPath()));
+
+ String url = "jdbc:postgresql://localhost:5432/postgres";
+ String username = "postgres";
+ String password = "";
+
+ Connection conn = DriverManager.getConnection(url, username, password);
+ context = DSL.using(conn, SQLDialect.POSTGRES);
+
+ context.insertInto(Tables.STORE, Store.STORE.ID, Store.STORE.NAME)
+ .values(1, "ABC Branch I ")
+ .values(2, "ABC Branch II")
+ .execute();
+
+ context.insertInto(Tables.BOOK, Book.BOOK.ID, Book.BOOK.TITLE, Book.BOOK.DESCRIPTION, Book.BOOK.AUTHOR_ID, Book.BOOK.STORE_ID)
+ .values(1, "Book 1", "This is book 1", 1, 1)
+ .values(2, "Book 2", "This is book 2", 2, 2)
+ .values(3, "Book 3", "This is book 3", 1, 2)
+ .values(4, "Book 4", "This is book 4", 5, 1)
+ .execute();
+
+ context.insertInto(Tables.BOOKAUTHOR, Bookauthor.BOOKAUTHOR.ID, Bookauthor.BOOKAUTHOR.NAME, Bookauthor.BOOKAUTHOR.COUNTRY)
+ .values(1, "John Smith", "Japan")
+ .values(2, "William Walce", "Japan")
+ .values(3, "Marry Sity", "South Korea")
+ .values(4, "Morry Toh", "England")
+ .execute();
+ }
+
+ @AfterClass
+ public static void cleanup() throws Exception {
+ context.truncateTable(Store.STORE)
+ .execute();
+ context.truncateTable(Book.BOOK)
+ .execute();
+ context.truncateTable(Bookauthor.BOOKAUTHOR)
+ .execute();
+ }
+
+ @Test
+ public void _whenUsingJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingJoinMethod(context);
+ assertEquals(3, result.size());
+ }
+
+ @Test
+ public void _whenUsingMultipleJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingMultipleJoinMethod(context);
+ assertEquals(3, result.size());
+ }
+
+ @Test
+ public void givenContext_whenUsingLeftOuterJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingLeftOuterJoinMethod(context);
+ assertEquals(4, result.size());
+ }
+
+ @Test
+ public void whenUsingRightOuterJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingRightOuterJoinMethod(context);
+ assertEquals(5, result.size());
+ }
+
+ @Test
+ public void whenUsingFullOuterJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingFullOuterJoinMethod(context);
+ assertEquals(6, result.size());
+ }
+
+ @Test
+ public void whenUsingNaturalJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingNaturalJoinMethod(context);
+ assertEquals(4, result.size());
+ }
+
+ @Test
+ public void whenUsingCrossJoinMethod_thenQueryExecuted() {
+ Result result = JoinTables.usingCrossJoinMethod(context);
+ assertEquals(8, result.size());
+ }
+}
diff --git a/persistence-modules/jooq/src/test/resources/jooq-config-2.xml b/persistence-modules/jooq/src/test/resources/jooq-config-2.xml
new file mode 100644
index 0000000000..a644e3fef5
--- /dev/null
+++ b/persistence-modules/jooq/src/test/resources/jooq-config-2.xml
@@ -0,0 +1,19 @@
+
+
+ org.postgresql.Driver
+ jdbc:postgresql://localhost:5432/postgres
+ postgres
+
+
+
+
+ org.jooq.meta.postgres.PostgresDatabase
+ Store|Book|BookAuthor
+
+
+
+ com.baeldung.jooq.jointables
+ src/main/java
+
+
+
diff --git a/persistence-modules/pom.xml b/persistence-modules/pom.xml
index f717287f29..e282e8dee2 100644
--- a/persistence-modules/pom.xml
+++ b/persistence-modules/pom.xml
@@ -24,6 +24,7 @@
core-java-persistence-2
core-java-persistence-3
couchbase
+ duckdb
elasticsearch
flyway
flyway-repair
@@ -69,6 +70,7 @@
spring-boot-persistence-mongodb
spring-boot-persistence-mongodb-2
spring-boot-persistence-mongodb-3
+ spring-boot-persistence-mongodb-4
spring-data-arangodb
spring-data-cassandra-test
@@ -89,6 +91,7 @@
spring-data-jpa-query
spring-data-jpa-query-2
spring-data-jpa-query-3
+ spring-data-jpa-query-4
spring-data-jpa-repo
spring-data-jpa-repo-2
spring-data-jpa-repo-4
@@ -108,6 +111,7 @@
spring-hibernate-6
spring-jpa
spring-jpa-2
+ spring-jpa-3
spring-jdbc
spring-jdbc-2
diff --git a/persistence-modules/spring-boot-persistence-4/pom.xml b/persistence-modules/spring-boot-persistence-4/pom.xml
index 75b444f7cc..d4bf8ba5cb 100644
--- a/persistence-modules/spring-boot-persistence-4/pom.xml
+++ b/persistence-modules/spring-boot-persistence-4/pom.xml
@@ -60,6 +60,11 @@
${lombok.version}
provided
+
+ org.springframework
+ spring-tx
+ ${spring.tx.version}
+
@@ -84,6 +89,7 @@
3.2.0
1.16.1
1.18.30
+ 6.1.4
\ No newline at end of file
diff --git a/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/Account.java b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/Account.java
new file mode 100644
index 0000000000..6bb070cad2
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/Account.java
@@ -0,0 +1,23 @@
+package com.baeldung.transactionalandasync;
+
+import jakarta.persistence.*;
+import lombok.*;
+
+import java.math.BigDecimal;
+
+@Entity
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode(of = {"id"})
+@Table(name = "account")
+@Data
+public class Account {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ private Long id;
+
+
+ @Column(name = "balance")
+ private BigDecimal balance;
+}
diff --git a/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountRepository.java b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountRepository.java
new file mode 100644
index 0000000000..a3c15e25eb
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountRepository.java
@@ -0,0 +1,6 @@
+package com.baeldung.transactionalandasync;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface AccountRepository extends JpaRepository {
+}
diff --git a/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountService.java b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountService.java
new file mode 100644
index 0000000000..d54f90e2e5
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/AccountService.java
@@ -0,0 +1,41 @@
+package com.baeldung.transactionalandasync;
+
+import jakarta.transaction.Transactional;
+import lombok.AllArgsConstructor;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+
+@Service
+@AllArgsConstructor
+@Transactional
+public class AccountService {
+
+ private final AccountRepository accountRepository;
+
+ @Async
+ public void transferAsync(Long depositorId, Long favoredId, BigDecimal amount) {
+ transfer(depositorId, favoredId, amount);
+
+ printReceipt();
+ }
+
+ @Transactional
+ public void transfer(Long depositorId, Long favoredId, BigDecimal amount) {
+ Account depositorAccount = accountRepository.findById(depositorId)
+ .orElseThrow(IllegalArgumentException::new);
+ Account favoredAccount = accountRepository.findById(favoredId)
+ .orElseThrow(IllegalArgumentException::new);
+
+ depositorAccount.setBalance(depositorAccount.getBalance().subtract(amount));
+ favoredAccount.setBalance(favoredAccount.getBalance().add(amount));
+
+ accountRepository.save(depositorAccount);
+ accountRepository.save(favoredAccount);
+ }
+
+ public void printReceipt() {
+ // logic to print the receipt
+ }
+}
diff --git a/spring-core-2/src/main/java/com/baeldung/concurrentrequest/ConcurrentRequestApplication.java b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/BankAccountApplication.java
similarity index 55%
rename from spring-core-2/src/main/java/com/baeldung/concurrentrequest/ConcurrentRequestApplication.java
rename to persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/BankAccountApplication.java
index 21d031555b..403a098df8 100644
--- a/spring-core-2/src/main/java/com/baeldung/concurrentrequest/ConcurrentRequestApplication.java
+++ b/persistence-modules/spring-boot-persistence-4/src/main/java/com/baeldung/transactionalandasync/BankAccountApplication.java
@@ -1,11 +1,12 @@
-package com.baeldung.concurrentrequest;
+package com.baeldung.transactionalandasync;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
-public class ConcurrentRequestApplication {
+public class BankAccountApplication {
public static void main(String[] args) {
- SpringApplication.run(ConcurrentRequestApplication.class, args);
+ SpringApplication.run(BankAccountApplication.class, args);
}
+
}
diff --git a/persistence-modules/spring-boot-persistence-mongodb-4/README.md b/persistence-modules/spring-boot-persistence-mongodb-4/README.md
new file mode 100644
index 0000000000..b6922eb10d
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/README.md
@@ -0,0 +1,5 @@
+# Relevant Articles
+
+- [ZonedDateTime with Spring Data MongoDB](https://www.baeldung.com/spring-data-mongodb-zoneddatetime)
+- [A Guide to @DBRef in MongoDB](https://www.baeldung.com/spring-mongodb-dbref-annotation)
+- More articles: [[<--prev]](../spring-boot-persistence-mongodb-3)
diff --git a/persistence-modules/spring-boot-persistence-mongodb-4/pom.xml b/persistence-modules/spring-boot-persistence-mongodb-4/pom.xml
new file mode 100644
index 0000000000..ae387c5709
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/pom.xml
@@ -0,0 +1,34 @@
+
+
+ 4.0.0
+ spring-boot-persistence-mongodb-4
+ spring-boot-persistence-mongodb-4
+ This is simple boot application for Spring boot persistence mongodb test
+
+
+ com.baeldung
+ parent-boot-2
+ 0.0.1-SNAPSHOT
+ ../../parent-boot-2
+
+
+
+
+ org.springframework.boot
+ spring-boot-starter-web
+
+
+
+ org.springframework.boot
+ spring-boot-starter-data-mongodb
+
+
+ de.flapdoodle.embed
+ de.flapdoodle.embed.mongo
+ test
+
+
+
+
\ No newline at end of file
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/DbRefApplication.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/DbRefApplication.java
similarity index 100%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/DbRefApplication.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/DbRefApplication.java
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java
index 58641e1258..b0c6bebd53 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/DbRefTester.java
@@ -1,5 +1,6 @@
package com.baeldung.mongodb.dbref;
+import com.baeldung.mongodb.dbref.repository.PersonRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -7,8 +8,6 @@ import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;
-import com.baeldung.mongodb.dbref.repository.PersonRepository;
-
@Component
public class DbRefTester implements ApplicationRunner {
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/model/Person.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/model/Person.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/model/Person.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/model/Person.java
index 7b7826e716..93f372d8ef 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/model/Person.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/model/Person.java
@@ -1,11 +1,11 @@
package com.baeldung.mongodb.dbref.model;
-import java.util.List;
-
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.DBRef;
import org.springframework.data.mongodb.core.mapping.Document;
+import java.util.List;
+
@Document(collection = "Person")
public class Person {
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/model/Pet.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/model/Pet.java
similarity index 100%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/model/Pet.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/model/Pet.java
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java
index 2ef5a9dbd6..7eebf8869b 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/mongodb/dbref/repository/PersonRepository.java
@@ -1,8 +1,7 @@
package com.baeldung.mongodb.dbref.repository;
-import org.springframework.data.mongodb.repository.MongoRepository;
-
import com.baeldung.mongodb.dbref.model.Person;
+import org.springframework.data.mongodb.repository.MongoRepository;
public interface PersonRepository extends MongoRepository {
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java
index 4eb3872e34..cf2d24c630 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/config/MongoConfig.java
@@ -1,15 +1,14 @@
package com.baeldung.zoneddatetime.config;
-import java.util.ArrayList;
-import java.util.List;
-
+import com.baeldung.zoneddatetime.converter.ZonedDateTimeReadConverter;
+import com.baeldung.zoneddatetime.converter.ZonedDateTimeWriteConverter;
import org.springframework.core.convert.converter.Converter;
import org.springframework.data.mongodb.config.AbstractMongoClientConfiguration;
import org.springframework.data.mongodb.core.convert.MongoCustomConversions;
import org.springframework.data.mongodb.repository.config.EnableMongoRepositories;
-import com.baeldung.zoneddatetime.converter.ZonedDateTimeReadConverter;
-import com.baeldung.zoneddatetime.converter.ZonedDateTimeWriteConverter;
+import java.util.ArrayList;
+import java.util.List;
@EnableMongoRepositories(basePackages = { "com.baeldung" })
public class MongoConfig extends AbstractMongoClientConfiguration {
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeReadConverter.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeReadConverter.java
similarity index 100%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeReadConverter.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeReadConverter.java
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeWriteConverter.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeWriteConverter.java
similarity index 100%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeWriteConverter.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/converter/ZonedDateTimeWriteConverter.java
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/model/Action.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/model/Action.java
similarity index 100%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/model/Action.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/model/Action.java
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java
similarity index 94%
rename from persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java
index e214c4b3c4..8fc33a6b6e 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/java/com/baeldung/zoneddatetime/repository/ActionRepository.java
@@ -1,7 +1,6 @@
package com.baeldung.zoneddatetime.repository;
+import com.baeldung.zoneddatetime.model.Action;
import org.springframework.data.mongodb.repository.MongoRepository;
-import com.baeldung.zoneddatetime.model.Action;
-
public interface ActionRepository extends MongoRepository { }
\ No newline at end of file
diff --git a/persistence-modules/spring-boot-persistence-mongodb-4/src/main/resources/application.properties b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/resources/application.properties
new file mode 100644
index 0000000000..b1c7e18ea3
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/main/resources/application.properties
@@ -0,0 +1 @@
+spring.application.name=spring-boot-persistence-mongodb-4
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java
index c357c0283c..8668bf9404 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/mongodb/dbref/DbRefIntegrationTest.java
@@ -1,11 +1,11 @@
package com.baeldung.mongodb.dbref;
-import static org.assertj.core.api.Assertions.assertThat;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-import java.util.ArrayList;
-import java.util.List;
-
+import com.baeldung.mongodb.dbref.model.Person;
+import com.baeldung.mongodb.dbref.model.Pet;
+import com.baeldung.mongodb.dbref.repository.PersonRepository;
+import com.mongodb.BasicDBObjectBuilder;
+import com.mongodb.DBObject;
+import com.mongodb.DBRef;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
@@ -14,12 +14,11 @@ import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.junit4.SpringRunner;
-import com.baeldung.mongodb.dbref.model.Person;
-import com.baeldung.mongodb.dbref.model.Pet;
-import com.baeldung.mongodb.dbref.repository.PersonRepository;
-import com.mongodb.BasicDBObjectBuilder;
-import com.mongodb.DBObject;
-import com.mongodb.DBRef;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertEquals;
@RunWith(SpringRunner.class)
@SpringBootTest
diff --git a/persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java
similarity index 99%
rename from persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java
rename to persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java
index 3a241418ca..09ff1d9375 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/java/com/baeldung/zoneddatetime/ActionRepositoryLiveTest.java
@@ -1,5 +1,8 @@
package com.baeldung.zoneddatetime;
+import com.baeldung.zoneddatetime.config.MongoConfig;
+import com.baeldung.zoneddatetime.model.Action;
+import com.baeldung.zoneddatetime.repository.ActionRepository;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
@@ -10,10 +13,6 @@ import org.springframework.data.mongodb.core.MongoOperations;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
-import com.baeldung.zoneddatetime.config.MongoConfig;
-import com.baeldung.zoneddatetime.model.Action;
-import com.baeldung.zoneddatetime.repository.ActionRepository;
-
import java.time.ZoneOffset;
import java.time.ZonedDateTime;
diff --git a/persistence-modules/spring-boot-persistence-mongodb-4/src/test/resources/application.properties b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/resources/application.properties
new file mode 100644
index 0000000000..a5b5fb9804
--- /dev/null
+++ b/persistence-modules/spring-boot-persistence-mongodb-4/src/test/resources/application.properties
@@ -0,0 +1 @@
+spring.mongodb.embedded.version=4.4.9
\ No newline at end of file
diff --git a/persistence-modules/spring-boot-persistence-mongodb/README.md b/persistence-modules/spring-boot-persistence-mongodb/README.md
index 5453eb0052..867b31c639 100644
--- a/persistence-modules/spring-boot-persistence-mongodb/README.md
+++ b/persistence-modules/spring-boot-persistence-mongodb/README.md
@@ -4,8 +4,6 @@
- [Spring Boot Integration Testing with Embedded MongoDB](http://www.baeldung.com/spring-boot-embedded-mongodb)
- [Upload and Retrieve Files Using MongoDB and Spring Boot](https://www.baeldung.com/spring-boot-mongodb-upload-file)
- [GridFS in Spring Data MongoDB](http://www.baeldung.com/spring-data-mongodb-gridfs)
-- [ZonedDateTime with Spring Data MongoDB](https://www.baeldung.com/spring-data-mongodb-zoneddatetime)
-- [A Guide to @DBRef in MongoDB](https://www.baeldung.com/spring-mongodb-dbref-annotation)
- [Import Data to MongoDB From JSON File Using Java](https://www.baeldung.com/java-import-json-mongodb)
- [Spring Data MongoDB – Configure Connection](https://www.baeldung.com/spring-data-mongodb-connection)
- More articles: [[next-->]](../spring-boot-persistence-mongodb-2)
diff --git a/persistence-modules/spring-boot-persistence/pom.xml b/persistence-modules/spring-boot-persistence/pom.xml
index 39edc01170..a816732e52 100644
--- a/persistence-modules/spring-boot-persistence/pom.xml
+++ b/persistence-modules/spring-boot-persistence/pom.xml
@@ -70,7 +70,6 @@
- 2.23.0
2.0.1.Final
8.2.0
com.baeldung.boot.Application
diff --git a/persistence-modules/spring-data-dynamodb/pom.xml b/persistence-modules/spring-data-dynamodb/pom.xml
index 5252aa5481..5d31f13518 100644
--- a/persistence-modules/spring-data-dynamodb/pom.xml
+++ b/persistence-modules/spring-data-dynamodb/pom.xml
@@ -136,6 +136,12 @@
so
test