Database Documentation

spring:
  datasource:
    acs:
      jdbc-url: ${MYSQL_JDBC_URL:jdbc:mysql://${MYSQL_HOST:${DB_HOST:localhost}}:${MYSQL_PORT:3306}/${MYSQL_SCHEMA:ftacs}?allowPublicKeyRetrieval=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false&serverTimezone=UTC}
      username: ${MYSQL_USER:${DB_USERNAME:ftacs}}
      password: ${MYSQL_PASSWORD:ftacs}
      driver-class-name: ${MYSQL_DRIVER_CLASS_NAME:com.mysql.cj.jdbc.Driver}
      maximum-pool-size: ${DB_MAX_POOL_SIZE:10}
      minimum-idle: ${DB_MIN_IDLE:5}
      connection-timeout: ${DB_CONNECTION_TIMEOUT_MS:30000}

package com.friendly.northboundapi.config.db;

import com.friendly.apicommon.db.DatabaseType;
import com.friendly.apicommon.db.DbConfig;
import com.zaxxer.hikari.HikariDataSource;
import jakarta.persistence.EntityManagerFactory;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.FactoryBean;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;
import org.springframework.context.annotation.FilterType;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import org.springframework.core.env.Environment;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;

import java.util.HashMap;

@DependsOn("dbConfig")
@Order(Ordered.HIGHEST_PRECEDENCE + 1)
@Configuration
@EnableJpaRepositories(
        basePackages = {"com.friendly"},
        entityManagerFactoryRef = "acsEntityManager",
        transactionManagerRef = "acsTransactionManager",
        includeFilters = @ComponentScan.Filter(
                type = FilterType.CUSTOM,
                classes = AcsSchemaFilter.class)
)
@Slf4j
@RequiredArgsConstructor
public class JpaAcsConfig {

    @NonNull
    private final Environment env;


    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.acs")
    public HikariDataSource acsDataSource() {
        HikariDataSource ds = new HikariDataSource();
        if (DbConfig.getDbType().equals(DatabaseType.Oracle)) {
            ds.setConnectionInitSql("ALTER SESSION SET TIME_ZONE='UTC'");
        }
        return ds;
    }

    @Bean
    public FactoryBean<EntityManagerFactory> acsEntityManager() {
        final LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(acsDataSource());
        em.setPackagesToScan("com.friendly");

        final HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        HashMap<String, Object> properties = new HashMap<>();

        properties.put("hibernate.hbm2ddl.auto", env.getProperty("spring.jpa.hibernate.ddl-auto"));
        properties.put("hibernate.dialect", DbConfig.getDbType().equals(DatabaseType.Oracle)
                ? env.getProperty("oracle.dialect") : env.getProperty("mysql.dialect"));
        properties.put("hibernate.enable_lazy_load_no_trans",
                env.getProperty("spring.jpa.properties.hibernate.enable_lazy_load_no_trans", "true"));
        properties.put("jpa.open-in-view", env.getProperty("spring.jpa.open-in-view", "true"));
        if (DbConfig.getDbType().equals(DatabaseType.Oracle)) {
            properties.put("hibernate.jdbc.time_zone", "UTC");
        }
        em.setJpaPropertyMap(properties);
        log.info("ACS DB properties: {}", properties);
        return em;
    }

    @Bean
    public PlatformTransactionManager acsTransactionManager(
            @Qualifier("acsEntityManager") EntityManagerFactory entityManager) {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(entityManager);
        return transactionManager;
    }
}