Subversion Repositories SmartDukaan

package com.smartdukaan.cron.config;

import java.time.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.time.format.DateTimeFormatterBuilder;

import java.util.Properties;

import javax.sql.DataSource;

import org.apache.logging.log4j.LogManager;

import org.apache.logging.log4j.Logger;

import org.hibernate.SessionFactory;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.ComponentScan;

import org.springframework.context.annotation.Configuration;

import org.springframework.context.annotation.Primary;

import org.springframework.context.annotation.PropertySource;

import org.springframework.jdbc.datasource.DriverManagerDataSource;

import org.springframework.orm.hibernate5.HibernateTransactionManager;

import org.springframework.orm.hibernate5.LocalSessionFactoryBuilder;

import org.springframework.transaction.annotation.EnableTransactionManagement;

import com.fasterxml.jackson.databind.ObjectMapper;

import com.fasterxml.jackson.datatype.jdk8.Jdk8Module;

import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;

import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;

import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer;

import com.fasterxml.jackson.module.paramnames.ParameterNamesModule;

import com.google.gson.Gson;

import com.google.gson.GsonBuilder;

import com.spice.profitmandi.dao.convertor.LocalDateTimeJsonConverter;

import com.spice.profitmandi.dao.repository.dtr.Mongo;

@Configuration

@EnableTransactionManagement

@ComponentScan("com.spice.profitmandi.*")

@PropertySource("classpath:META-INF/env.properties")

public class DBConfig {

	private static final Logger LOGGER = LogManager.getLogger(DBConfig.class);

	private static final String HIBERNATE_DIALECT = "hibernate.dialect";

	private static final String HIBERNATE_SHOW_SQL = "hibernate.show_sql";

	private static final String HIBERNATE_FORMAT_SQL = "hibernate.format_sql";

	private static final String HIBERNATE_JDBC_BATCH_SIZE = "hibernate.jdbc.batch_size";

	private static final String HIBERNATE_C3P0_MIN_SIZE = "hibernate.c3p0.min_size";

	private static final String HIBERNATE_C3P0_MAX_SIZE = "hibernate.c3p0.max_size";

	private static final String HIBERNATE_C3P0_TIMEOUT = "hibernate.c3p0.timeout";

	private static final String HIBERNATE_C3P0_MAX_STATEMENTS = "hibernate.c3p0.max_statements";

	private static final String HIBERNATE_C3P0_IDLE_TEST_PERIOD = "hibernate.c3p0.idle_test_period";

	@Value("${hibernate.driver.class}")

	private String hibernateDriverClass;

	@Value("${hibernate.url}")

	private String hibernateUrl;

	@Value("${hibernate.user.name}")

	private String hibernateUserName;

	@Value("${hibernate.password}")

	private String hibernatePassword;

	@Value("${hibernate.dialect}")

	private String hibernateDialect;

	@Value("${hibernate.show_sql}")

	private String hibernateShowSql;

	@Value("${hibernate.format_sql}")

	private String hibernateFormatSql;

	@Value("${hibernate.jdbc.batch_size}")

	private String hibernateBatchSize;

	@Value("${hibernate.c3p0.min_size}")

	private String hibernateMinSize;

	@Value("${hibernate.c3p0.max_size}")

	private String hibernateMaxSize;

	@Value("${hibernate.c3p0.timeout}")

	private String hibernateTimeout;

	@Value("${hibernate.c3p0.max_statements}")

	private String hibernateMaxStatements;

	@Value("${hibernate.c3p0.idle_test_period}")

	private String hibernateIdleTestPeriod;

	@Value("${mongo.host}")

	private String mongoHost;

	@Value("${content.mongo.host}")

	private String contentMongoHost;

	@Primary

	@Bean(name = "dataSource")

	public DataSource dataSource() {

		DriverManagerDataSource dataSource = new DriverManagerDataSource();

		dataSource.setDriverClassName(hibernateDriverClass);

		dataSource.setUrl(hibernateUrl);

		dataSource.setUsername(hibernateUserName);

		dataSource.setPassword(hibernatePassword);

		LOGGER.info("DataSource returned {}", dataSource);

		return dataSource;

	}

	@Bean

	public ObjectMapper objectMapper() {

		DateTimeFormatter df = new DateTimeFormatterBuilder().parseCaseInsensitive()

				.append(DateTimeFormatter.ISO_LOCAL_DATE).optionalStart().appendLiteral('T').optionalEnd()

				.appendLiteral(' ').append(DateTimeFormatter.ISO_LOCAL_TIME).toFormatter();

		DateTimeFormatter sf = new DateTimeFormatterBuilder().parseCaseInsensitive()

				.append(DateTimeFormatter.ISO_LOCAL_DATE).appendLiteral('T').append(DateTimeFormatter.ISO_LOCAL_TIME)

				.toFormatter();

		LocalDateTimeSerializer serializer = new LocalDateTimeSerializer(sf);

		LocalDateTimeDeserializer deserializer = new LocalDateTimeDeserializer(df);

		JavaTimeModule jtm = new JavaTimeModule();

		jtm.addSerializer(LocalDateTime.class, serializer);

		jtm.addDeserializer(LocalDateTime.class, deserializer);

		ObjectMapper mapper = new ObjectMapper().registerModule(new ParameterNamesModule())

				.registerModule(new Jdk8Module()).registerModule(jtm); // new module, NOT JSR310Module

		return mapper;

	}

	@Bean

	public Properties getHibernateProperties() {

		Properties dbProperties = new Properties();

		dbProperties.put(HIBERNATE_DIALECT, hibernateDialect);

		dbProperties.put(HIBERNATE_SHOW_SQL, hibernateShowSql);

		dbProperties.put(HIBERNATE_FORMAT_SQL, hibernateFormatSql);

		dbProperties.put(HIBERNATE_JDBC_BATCH_SIZE, hibernateBatchSize);

		dbProperties.put(HIBERNATE_C3P0_MIN_SIZE, hibernateMinSize);

		dbProperties.put(HIBERNATE_C3P0_MAX_SIZE, hibernateMaxSize);

		dbProperties.put(HIBERNATE_C3P0_TIMEOUT, hibernateTimeout);

		dbProperties.put(HIBERNATE_C3P0_MAX_STATEMENTS, hibernateMaxStatements);

		dbProperties.put(HIBERNATE_C3P0_IDLE_TEST_PERIOD, hibernateIdleTestPeriod);

		return dbProperties;

	}

	@Primary

	@Autowired

	@Bean(name = "sessionFactory")

	public SessionFactory getSessionFactory(DataSource dataSource) {

		LocalSessionFactoryBuilder sessionBuilder = new LocalSessionFactoryBuilder(dataSource);

		sessionBuilder.addProperties(getHibernateProperties());

		sessionBuilder.scanPackages("com.spice.profitmandi.dao.*");

		return sessionBuilder.buildSessionFactory();

	}

	@Primary

	@Autowired

	@Bean(name = "transactionManager")

	public HibernateTransactionManager getTransactionManager(SessionFactory sessionFactory) {

		HibernateTransactionManager transactionManager = new HibernateTransactionManager(sessionFactory);

		return transactionManager;

	}

	@Bean

	public Mongo mongoClient(SessionFactory sessionFactory) {

		return new Mongo(mongoHost, contentMongoHost);

	}

	@Bean(name = "gson")

	public Gson gson() {

		Gson gson = new GsonBuilder().serializeNulls()

				.registerTypeAdapter(LocalDateTime.class, new LocalDateTimeJsonConverter()).create();

		return gson;

	}

}