Spring Boot mit Oracle AQ und Universal Connection Pool ⇐ Java

[Guest]

Ich verwende Oracle AQ mit Spring Boot wie folgt:
Gradle-Abhängigkeit:

Code: Select all

implementation "com.oracle.database.spring:oracle-spring-boot-starter-aqjms:23.4.0"

JmsConfiguration:

Code: Select all

    @Configuration
@EnableJms
public class JmsConfiguration {

@Bean
public ConnectionFactory connectionFactory(DataSource dataSource) {
return AQjmsFactory.getQueueConnectionFactory(dataSource);
}

Jetzt versuche ich, einige Eigenschaften für den Oracle Universal Connection Pool über application.yaml einzurichten basierend auf diesen Oracle-Dokumenten, aber Eigenschaften werden nicht angewendet :

Code: Select all

spring:
datasource:
url: jdbc:oracle:thin:@localhost:1521/ORCLPDB1
username: AQ_USER
password: your_password
oracleucp:
initial-pool-size: 5
min-pool-size: 10
max-pool-size: 30
connection-wait-timeout: 2
connection-factory-class-name: oracle.jdbc.pool.OracleDataSource
connection-pool-name: some_pool_name
type: oracle.ucp.jdbc.PoolDataSource

Wenn ich sie dagegen per Code einstelle, dann funktioniert es:

Code: Select all

import jakarta.jms.ConnectionFactory;
import jakarta.jms.JMSException;
import oracle.jakarta.jms.AQjmsFactory;
import oracle.ucp.jdbc.PoolDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;

import java.sql.SQLException;

@Configuration
@EnableJms
public class JmsConfiguration {

@Bean
public ConnectionFactory connectionFactory(PoolDataSource poolDataSource) throws JMSException, SQLException {
poolDataSource.setInitialPoolSize(5);
poolDataSource.setMinPoolSize(10);
poolDataSource.setMaxPoolSize(30);
poolDataSource.setConnectionWaitTimeout(3000);

return AQjmsFactory.getQueueConnectionFactory(poolDataSource);
}

Um zu sehen, ob die Einstellungen angewendet wurden oder nicht, verwende ich Folgendes:

Code: Select all

import oracle.ucp.jdbc.PoolDataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
import org.springframework.context.event.EventListener;

import java.sql.SQLException;
import java.util.List;

@SpringBootApplication
@ConfigurationPropertiesScan
public class RequestBufferingServiceApplication {

@Autowired
PoolDataSource poolDataSource;

public static void main(String[] args) {
SpringApplication.run(RequestBufferingServiceApplication.class, args);
}

@EventListener(ApplicationReadyEvent.class)
public void foo() throws SQLException {
System.out.println("------");
System.out.println("Init pool size: " + poolDataSource.getInitialPoolSize());
System.out.println("Min pool size: " + poolDataSource.getMinPoolSize());
System.out.println("Max pool size: " + poolDataSource.getMaxPoolSize());
System.out.println("ConnectionWaitTimeout: " + poolDataSource.getConnectionWaitTimeout());
System.out.println("------");
}
}

Wie wende ich Oracle UCP-Eigenschaften über application.yaml richtig an?
BEARBEITEN:
Ausgabe ohne Auswirkung von application.yaml:

Code: Select all

------
Init pool size: 0
Min pool size: 0
Max pool size: 2147483647
ConnectionWaitTimeout: 3
------

Ausgabe mit Auswirkung der Java-Konfiguration (gewünscht):

Code: Select all

------
Init pool size: 5
Min pool size: 10
Max pool size: 30
ConnectionWaitTimeout: 2
------

build.gradle:

Code: Select all

plugins {
id 'java'
id 'org.springframework.boot' version '3.3.3'
id 'io.spring.dependency-management' version '1.1.6'
id 'io.freefair.lombok' version '8.11'
id "io.qameta.allure-report"  version "2.11.2"
id 'org.sonarqube' version '5.0.0.4638'
id 'jacoco'
}

group = 'de.telekom.mff'

java {
toolchain {
languageVersion = JavaLanguageVersion.of(21)
}
}

bootJar {
archiveFileName = "request-buffering-service.${archiveExtension.get()}"
}

jar {
enabled = true
}

configurations {
compileOnly {
extendsFrom annotationProcessor
}
}

repositories {
mavenCentral()
}

ext {
versions = [
oracleSpringBootStarterAqjms: "23.4.0",
allureCucumber7Jvm          : "2.27.0",
testcontainers              : "1.20.1",
springCloud                 : "2023.0.3",
awaitility                  : "4.2.2",
xmlUnit                     : "2.10.0",
jsonUnitAssertj             : "3.2.2",
wiremock                    : "4.1.4"
]
}

dependencyManagement {
imports {
mavenBom "org.springframework.cloud:spring-cloud-dependencies:${versions.springCloud}"
}
}

dependencies {
implementation "org.springframework.boot:spring-boot-starter-web"
implementation "org.springframework.boot:spring-boot-starter-webflux"
implementation "org.springframework.boot:spring-boot-starter-log4j2"
implementation "org.springframework.boot:spring-boot-starter-actuator"
implementation "org.springframework:spring-aspects"
implementation "org.springframework.cloud:spring-cloud-starter-kubernetes-fabric8-config"
implementation "org.springframework.cloud:spring-cloud-kubernetes-fabric8-leader"
implementation "com.oracle.database.spring:oracle-spring-boot-starter-aqjms:${versions.oracleSpringBootStarterAqjms}"
testImplementation "org.springframework.boot:spring-boot-starter-test"
testImplementation "io.fabric8:kubernetes-server-mock"
testImplementation "org.springframework.cloud:spring-cloud-contract-wiremock:${versions.wiremock}"
testImplementation "org.testcontainers:oracle-free:${versions.testcontainers}"
testImplementation "org.testcontainers:junit-jupiter:${versions.testcontainers}"
testImplementation "org.awaitility:awaitility:${versions.awaitility}"
testImplementation "org.xmlunit:xmlunit-core:${versions.xmlUnit}"
testImplementation "io.qameta.allure:allure-cucumber7-jvm:${versions.allureCucumber7Jvm}"
testImplementation "net.javacrumbs.json-unit:json-unit-assertj:${versions.jsonUnitAssertj}"
testRuntimeOnly "org.junit.platform:junit-platform-launcher"
}

Spring Start-Debug-Protokoll (mit 23.4.0 aqjms Starter, wobei URL, Benutzer und Passwort für die Datenbank automatisch über application.yaml konfiguriert werden):

Negative Übereinstimmungen:
DataSourceAutoConfiguration:
Keine Übereinstimmung:
- @ConditionalOnClass hat die erforderliche Klasse nicht gefunden 'org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType'
(OnClassCondition)
DataSourceInitializationConfiguration:
Nicht übereinstimmend:
- @ConditionalOnClass nicht Finden Sie die erforderliche Klasse „org.springframework.jdbc.datasource.init.DatabasePopulator“
(OnClassCondition)
DataSourceTransactionManagerAutoConfiguration:
Nicht übereinstimmend:
- @ConditionalOnClass hat die erforderliche Klasse „org.springframework.jdbc.core.JdbcTemplate“ (OnClassCondition) nicht gefunden.
< /blockquote>