The custom Helidon SE OCI clients documented here are deprecated. It is recommended that you use the OCI Java SDK directly, in particular the Async clients. For more information see:

• OCI Database Documentation

• OCI Database Javadoc

• Helidon SE OCI ATP Example

Helidon integration with Oracle Cloud Infrastructure is still experimental and not intended for production use. APIs and features have not yet been fully tested and are subject to change.

To enable OCI Autonomous Transaction Processing add the following dependency to your project’s pom.xml (see Managing Dependencies).

        <dependency>
            <groupId>io.helidon.integrations.oci</groupId>
            <artifactId>helidon-integrations-oci-atp</artifactId>
        </dependency>

In order to use the OCI Autonomous Transaction Processing integration, the following setup should be made:

Config ociConfig = config.get("oci");

OciAutonomousDbRx ociAutonomousDb = OciAutonomousDbRx.create(ociConfig);

Current configuration requires ~/.oci/config to be available in the home folder. This configuration file can be downloaded from OCI.

Routing should be added to the WebServer, in our case pointing to /atp:

        WebServer.builder()
                .config(config.get("server"))
                .routing(Routing.builder()
                                .register("/atp", new AtpService(autonomousDbRx, config)))
                .build();

Additionally, in application.yaml OCI properties should be specified:

oci:
  atp:
    ocid: "<ocid of your ATP database>"
    walletPassword: "<password to encrypt the keys inside the wallet>"

The exact values are available from OCI console.

In the Service we must specify the mapping for operations with the database and their handlers:

@Override
public void update(Routing.Rules rules) {
    rules.get("/wallet", this::generateWallet);
}

Generate Wallet

    private void generateWallet(ServerRequest req, ServerResponse res) {
        autonomousDbRx.generateWallet(GenerateAutonomousDatabaseWallet.Request.builder()) 
                .flatMapOptional(ApiOptionalResponse::entity)
                .map(GenerateAutonomousDatabaseWallet.Response::walletArchive) 
                .ifEmpty(() -> LOGGER.severe("Unable to obtain wallet!"))
                .flatMapSingle(this::createDbClient) 
                .flatMap(dbClient -> dbClient.execute(exec -> exec.query("SELECT 'Hello world!!' FROM DUAL")))
                .first()
                .map(dbRow -> dbRow.column(1).as(String.class)) 
                .ifEmpty(() -> res.status(404).send())
                .onError(res::send)
                .forSingle(res::send);
    }