feat(spring-oracle-example): implement CRUD operations with JdbcClient and initialize database

Author: igorcampos-dev

spring-oracle-example/compose.yaml

@@ -9,11 +9,11 @@ services:
     environment:
       SPRING_PROFILES_ACTIVE: default
       SERVER_PORT: 8080
-      SPRING_DATASOURCE_URL: jdbc:oracle:thin:@oracle-db:1521/XEPDB1
-      SPRING_DATASOURCE_USERNAME: TEST_SCHEMA
-      SPRING_DATASOURCE_PASSWORD: Ag101Pwd123
+      SPRING_DATASOURCE_URL: jdbc:oracle:thin:@oracle-db:1521
+      SPRING_DATASOURCE_USERNAME: developer
+      SPRING_DATASOURCE_PASSWORD: developer
       SPRING_DATASOURCE_DRIVER: oracle.jdbc.OracleDriver
-      SPRING_JPA_HIBERNATE_DDL_AUTO: update
+      SPRING_JPA_HIBERNATE_DDL_AUTO: none
       SPRING_JPA_SHOW_SQL: true
       SPRING_HIBERNATE_DIALECT: org.hibernate.dialect.OracleDialect
     ports:
@@ -28,4 +28,5 @@ services:
       ORACLE_PASSWORD: "Admin123"
     shm_size: 1g
     volumes:
-      - ./docker/oracle:/docker-entrypoint-initdb.d
+      - ./docker/oracle:/docker-entrypoint-initdb.d
+      - ./src/main/resources/sql:/docker-entrypoint-initdb.d

spring-oracle-example/docker/oracle/init.sql

@@ -23,6 +23,7 @@
         <lombok.version>1.18.42</lombok.version>
         <oracle.database.version>23.9.0.25.07</oracle.database.version>
         <maven.compiler.plugin.version>3.14.1</maven.compiler.plugin.version>
+        <instancio.version>5.5.1</instancio.version>
 	</properties>
 
 	<dependencies>
@@ -53,6 +54,12 @@
             <version>${lombok.version}</version>
 		</dependency>
 
+        <dependency>
+            <groupId>org.instancio</groupId>
+            <artifactId>instancio-core</artifactId>
+            <version>${instancio.version}</version>
+        </dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

spring-oracle-example/pom.xml

@@ -0,0 +1,35 @@
+package com.io.example.config;
+
+import javax.sql.DataSource;
+
+import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.jdbc.core.simple.JdbcClient;
+
+@Configuration
+public class DatabaseConfig {
+
+    @Bean
+    @Primary
+    @ConfigurationProperties("spring.datasource")
+    public DataSourceProperties dataSourceProperties() {
+        return new DataSourceProperties();
+    }
+
+    @Bean
+    @Primary
+    public DataSource dataSource(DataSourceProperties properties) {
+        return properties.initializeDataSourceBuilder()
+                         .build();
+    }
+
+    @Bean
+    @Primary
+    public JdbcClient jdbcClient(DataSource dataSource) {
+        return JdbcClient.create(dataSource);
+    }
+
+}

spring-oracle-example/src/main/java/com/io/example/config/DatabaseConfig.java

@@ -0,0 +1,99 @@
+package com.io.example.dao;
+
+import com.io.example.dto.JdbcClientCrudExampleDto;
+import com.io.example.exception.JdbcClientCrudExampleException;
+import lombok.RequiredArgsConstructor;
+import org.springframework.jdbc.core.simple.JdbcClient;
+import org.springframework.stereotype.Component;
+import java.util.List;
+
+@Component
+@RequiredArgsConstructor
+public class JdbcClientCrudExampleDao {
+
+    private final JdbcClient jdbc;
+
+    public void create(JdbcClientCrudExampleDto record) {
+        try {
+            jdbc.sql("""
+                    INSERT INTO developer.records_example (id, name, value)
+                    VALUES (?, ?, ?)
+                    """)
+                    .param(record.getId())
+                    .param(record.getName())
+                    .param(record.getValue())
+                    .update();
+        } catch (Exception e) {
+            throw new JdbcClientCrudExampleException("Failed to insert record: " + record, e);
+        }
+    }
+
+    public List<JdbcClientCrudExampleDto> findAll() {
+        try {
+            return jdbc.sql("""
+                    SELECT id, name, value, created_at
+                    FROM developer.records_example
+                    """)
+                    .query(JdbcClientCrudExampleDto.class)
+                    .list();
+        } catch (Exception e) {
+            throw new JdbcClientCrudExampleException("Failed to retrieve all records", e);
+        }
+    }
+
+    public JdbcClientCrudExampleDto findById(Long id) {
+        try {
+            return jdbc.sql("""
+                    SELECT id, name, value, created_at
+                    FROM developer.records_example
+                    WHERE id = ?
+                    """)
+                    .param(id)
+                    .query(JdbcClientCrudExampleDto.class)
+                    .optional()
+                    .orElseThrow(() -> new JdbcClientCrudExampleException("No record found for id = " + id));
+        } catch (Exception e) {
+            throw new JdbcClientCrudExampleException("Failed to retrieve record for id = " + id, e);
+        }
+    }
+
+    public void update(Long id, String name, String value) {
+        try {
+            int affected = jdbc.sql("""
+                    UPDATE developer.records_example
+                    SET name = ?, value = ?
+                    WHERE id = ?
+                    """)
+                    .param(name)
+                    .param(value)
+                    .param(id)
+                    .update();
+
+            if (affected == 0) {
+                throw new JdbcClientCrudExampleException("No record found to update for id = " + id);
+            }
+
+        } catch (Exception e) {
+            throw new JdbcClientCrudExampleException("Failed to update record with id = " + id, e);
+        }
+    }
+
+    public void delete(Long id) {
+        try {
+            int affected = jdbc.sql("""
+                    DELETE FROM developer.records_example
+                    WHERE id = ?
+                    """)
+                    .param(id)
+                    .update();
+
+            if (affected == 0) {
+                throw new JdbcClientCrudExampleException("No record found to delete for id = " + id);
+            }
+
+        } catch (Exception e) {
+            throw new JdbcClientCrudExampleException("Failed to delete record with id = " + id, e);
+        }
+    }
+
+}

spring-oracle-example/src/main/java/com/io/example/dao/JdbcClientCrudExampleDao.java

@@ -0,0 +1,20 @@
+package com.io.example.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import java.time.LocalDateTime;
+
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class JdbcClientCrudExampleDto {
+
+    private Long id;
+    private String name;
+    private String value;
+    private LocalDateTime createdAt;
+
+}

spring-oracle-example/src/main/java/com/io/example/dto/JdbcClientCrudExampleDto.java

@@ -0,0 +1,13 @@
+package com.io.example.exception;
+
+public class JdbcClientCrudExampleException extends RuntimeException {
+
+    public JdbcClientCrudExampleException(String message) {
+        super(message);
+    }
+
+    public JdbcClientCrudExampleException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+}

spring-oracle-example/src/main/java/com/io/example/entity/TestEntity.java

@@ -0,0 +1,43 @@
+package com.io.example.init;
+
+import com.io.example.dao.JdbcClientCrudExampleDao;
+import com.io.example.dto.JdbcClientCrudExampleDto;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class JdbcClientCrudExampleInit implements CommandLineRunner {
+
+    private final JdbcClientCrudExampleDao dao;
+
+    @Override
+    public void run(String... args) {
+
+        var entity = JdbcClientCrudExampleDto.builder()
+                .id(1L)
+                .name("Test Name")
+                .value("Some value")
+                .build();
+
+        dao.create(entity);
+        log.info("Inserted: {}", entity);
+
+        JdbcClientCrudExampleDto fetched = dao.findById(1L);
+        log.info("Fetched: {}", fetched);
+
+        fetched.setName("Updated Name");
+        fetched.setValue("Updated value");
+
+        dao.update(fetched.getId(), fetched.getName(), fetched.getValue());
+        log.info("Updated: {}", fetched);
+
+        dao.delete(1L);
+        log.info("Deleted entity with id 1");
+
+    }
+
+}

spring-oracle-example/src/main/java/com/io/example/exception/JdbcClientCrudExampleException.java

@@ -3,14 +3,14 @@ spring:
     name: spring-oracle-example-dev
 
   datasource:
-    url: ${SPRING_DATASOURCE_URL:jdbc:oracle:thin:@localhost:1521/XEPDB1}
-    username: ${SPRING_DATASOURCE_USERNAME:TEST_SCHEMA}
-    password: ${SPRING_DATASOURCE_PASSWORD:Ag101Pwd123}
+    url: ${SPRING_DATASOURCE_URL:jdbc:oracle:thin:@localhost:1521}
+    username: ${SPRING_DATASOURCE_USERNAME:developer}
+    password: ${SPRING_DATASOURCE_PASSWORD:developer}
     driver-class-name: ${SPRING_DATASOURCE_DRIVER:oracle.jdbc.OracleDriver}
 
   jpa:
     hibernate:
-      ddl-auto: ${SPRING_JPA_HIBERNATE_DDL_AUTO:update}
+      ddl-auto: ${SPRING_JPA_HIBERNATE_DDL_AUTO:none}
     show-sql: ${SPRING_JPA_SHOW_SQL:true}
     properties:
       hibernate: