Merge pull request #6871 from eugenp/fix-spring-data-jpa

Fix spring data jpa
This commit is contained in:
Loredana Crusoveanu 2019-04-30 22:51:11 +03:00 committed by GitHub
commit b3c89bbf13
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
97 changed files with 541 additions and 372 deletions

View File

@ -89,5 +89,9 @@
<scope>test</scope>
</dependency>
</dependencies>
<properties>
<start-class>com.baeldung.boot.Application</start-class>
</properties>
</project>

View File

@ -1,10 +1,11 @@
package com.baeldung;
package com.baeldung.boot;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import com.baeldung.dao.repositories.impl.ExtendedRepositoryImpl;
import com.baeldung.boot.daos.impl.ExtendedRepositoryImpl;
import com.baeldung.multipledb.MultipleDbApplication;
@SpringBootApplication
@EnableJpaRepositories(repositoryBaseClass = ExtendedRepositoryImpl.class)

View File

@ -0,0 +1,21 @@
package com.baeldung.boot.config;
import com.baeldung.boot.services.IBarService;
import com.baeldung.boot.services.impl.BarSpringDataJpaService;
import org.springframework.context.annotation.*;
import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.transaction.annotation.EnableTransactionManagement;
@Configuration
@Profile("!tc")
@EnableTransactionManagement
@EnableJpaAuditing
public class PersistenceConfiguration {
@Bean
public IBarService barSpringDataJpaService() {
return new BarSpringDataJpaService();
}
}

View File

@ -1,10 +1,11 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.Article;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import com.baeldung.boot.domain.Article;
import java.util.Date;
import java.util.List;

View File

@ -1,8 +1,8 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.Item;
import com.baeldung.boot.domain.Item;
@Repository
public interface CustomItemRepository {

View File

@ -1,8 +1,8 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.ItemType;
import com.baeldung.boot.domain.ItemType;
@Repository
public interface CustomItemTypeRepository {

View File

@ -1,8 +1,8 @@
package com.baeldung.batchinserts.repository;
package com.baeldung.boot.daos;
import org.springframework.data.repository.CrudRepository;
import com.baeldung.batchinserts.model.Customer;
import com.baeldung.boot.domain.Customer;
/**
* JPA CrudRepository interface

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import java.io.Serializable;
import java.util.List;

View File

@ -1,6 +1,6 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.Student;
import com.baeldung.boot.domain.Student;
public interface ExtendedStudentRepository extends ExtendedRepository<Student, Long> {
}

View File

@ -1,8 +1,9 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.Bar;
import org.springframework.data.repository.CrudRepository;
import com.baeldung.boot.domain.Bar;
import java.io.Serializable;
public interface IBarCrudRepository extends CrudRepository<Bar, Serializable> {

View File

@ -1,10 +1,11 @@
package com.baeldung.dao;
package com.baeldung.boot.daos;
import com.baeldung.domain.Foo;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import com.baeldung.boot.domain.Foo;
public interface IFooDao extends JpaRepository<Foo, Long> {
@Query("SELECT f FROM Foo f WHERE LOWER(f.name) = LOWER(:name)")

View File

@ -1,7 +1,8 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.MerchandiseEntity;
import org.springframework.data.repository.CrudRepository;
import com.baeldung.boot.domain.MerchandiseEntity;
public interface InventoryRepository extends CrudRepository<MerchandiseEntity, Long> {
}

View File

@ -1,9 +1,9 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.ItemType;
import com.baeldung.boot.domain.ItemType;
@Repository
public interface ItemTypeRepository extends JpaRepository<ItemType, Long>, CustomItemTypeRepository, CustomItemRepository {

View File

@ -1,9 +1,9 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.Location;
import com.baeldung.boot.domain.Location;
@Repository
public interface LocationRepository extends JpaRepository<Location, Long> {

View File

@ -1,10 +1,10 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import java.util.Optional;
import org.springframework.data.repository.Repository;
import com.baeldung.domain.Location;
import com.baeldung.boot.domain.Location;
@org.springframework.stereotype.Repository
public interface ReadOnlyLocationRepository extends Repository<Location, Long> {

View File

@ -1,11 +1,11 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import java.util.List;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.Store;
import com.baeldung.boot.domain.Store;
@Repository
public interface StoreRepository extends JpaRepository<Store, Long> {

View File

@ -1,12 +1,12 @@
package com.baeldung.dao.repositories.impl;
package com.baeldung.boot.daos.impl;
import javax.persistence.EntityManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import com.baeldung.dao.repositories.CustomItemRepository;
import com.baeldung.domain.Item;
import com.baeldung.boot.daos.CustomItemRepository;
import com.baeldung.boot.domain.Item;
@Repository
public class CustomItemRepositoryImpl implements CustomItemRepository {

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories.impl;
package com.baeldung.boot.daos.impl;
import javax.persistence.EntityManager;
@ -7,8 +7,8 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import com.baeldung.domain.ItemType;
import com.baeldung.dao.repositories.CustomItemTypeRepository;
import com.baeldung.boot.daos.CustomItemTypeRepository;
import com.baeldung.boot.domain.ItemType;
@Repository
public class CustomItemTypeRepositoryImpl implements CustomItemTypeRepository {

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories.impl;
package com.baeldung.boot.daos.impl;
import java.io.Serializable;
import java.util.List;
@ -10,10 +10,11 @@ import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Root;
import javax.transaction.Transactional;
import com.baeldung.dao.repositories.ExtendedRepository;
import org.springframework.data.jpa.repository.support.JpaEntityInformation;
import org.springframework.data.jpa.repository.support.SimpleJpaRepository;
import com.baeldung.boot.daos.ExtendedRepository;
public class ExtendedRepositoryImpl<T, ID extends Serializable> extends SimpleJpaRepository<T, ID> implements ExtendedRepository<T, ID> {
private EntityManager entityManager;

View File

@ -1,8 +1,9 @@
package com.baeldung.dao.repositories.impl;
package com.baeldung.boot.daos.impl;
import com.baeldung.domain.Person;
import org.springframework.stereotype.Repository;
import com.baeldung.boot.domain.Person;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import javax.transaction.Transactional;

View File

@ -1,8 +1,9 @@
package com.baeldung.dao.repositories.user;
package com.baeldung.boot.daos.user;
import com.baeldung.domain.user.Possession;
import org.springframework.data.jpa.repository.JpaRepository;
import com.baeldung.boot.domain.Possession;
public interface PossessionRepository extends JpaRepository<Possession, Long> {
}

View File

@ -1,6 +1,5 @@
package com.baeldung.dao.repositories.user;
package com.baeldung.boot.daos.user;
import com.baeldung.domain.user.User;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
@ -9,6 +8,8 @@ import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.query.Param;
import com.baeldung.boot.domain.User;
import java.time.LocalDate;
import java.util.Collection;
import java.util.List;
@ -18,11 +19,11 @@ public interface UserRepository extends JpaRepository<User, Integer> , UserRepos
Stream<User> findAllByName(String name);
@Query("select u from User u where u.email like '%@gmail.com'")
List<User> findUsersWithGmailAddress();
@Query("SELECT u FROM User u WHERE u.status = 1")
Collection<User> findAllActiveUsers();
@Query("select u from User u where u.email like '%@gmail.com'")
List<User> findUsersWithGmailAddress();
@Query(value = "SELECT * FROM Users u WHERE u.status = 1", nativeQuery = true)
Collection<User> findAllActiveUsersNative();
@ -74,14 +75,14 @@ public interface UserRepository extends JpaRepository<User, Integer> , UserRepos
@Query(value = "INSERT INTO Users (name, age, email, status, active) VALUES (:name, :age, :email, :status, :active)", nativeQuery = true)
@Modifying
void insertUser(@Param("name") String name, @Param("age") Integer age, @Param("email") String email, @Param("status") Integer status, @Param("active") boolean active);
@Modifying
@Query(value = "UPDATE Users u SET status = ? WHERE u.name = ?", nativeQuery = true)
int updateUserSetStatusForNameNativePostgres(Integer status, String name);
@Query(value = "SELECT u FROM User u WHERE u.name IN :names")
List<User> findUserByNameList(@Param("names") Collection<String> names);
List<User> findUserByNameList(@Param("names") Collection<String> names);
void deleteAllByCreationDateAfter(LocalDate date);
@Modifying(clearAutomatically = true, flushAutomatically = true)
@ -89,11 +90,10 @@ public interface UserRepository extends JpaRepository<User, Integer> , UserRepos
void deactivateUsersNotLoggedInSince(@Param("date") LocalDate date);
@Modifying(clearAutomatically = true, flushAutomatically = true)
@Query("delete from User u where u.active = false")
@Query("delete User u where u.active = false")
int deleteDeactivatedUsers();
@Modifying(clearAutomatically = true, flushAutomatically = true)
@Query(value = "alter table Users add column deleted int(1) not null default 0", nativeQuery = true)
@Query(value = "alter table USERS.USERS add column deleted int(1) not null default 0", nativeQuery = true)
void addDeletedColumn();
}

View File

@ -1,14 +1,14 @@
package com.baeldung.dao.repositories.user;
package com.baeldung.boot.daos.user;
import java.util.Collection;
import java.util.List;
import java.util.Set;
import java.util.function.Predicate;
import com.baeldung.domain.user.User;
import com.baeldung.boot.domain.User;
public interface UserRepositoryCustom {
List<User> findUserByEmails(Set<String> emails);
List<User> findAllUsersByPredicates(Collection<Predicate<User>> predicates);
}

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories.user;
package com.baeldung.boot.daos.user;
import java.util.ArrayList;
import java.util.Collection;
@ -15,7 +15,7 @@ import javax.persistence.criteria.Path;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import com.baeldung.domain.user.User;
import com.baeldung.boot.domain.User;
public class UserRepositoryCustomImpl implements UserRepositoryCustom {
@ -42,7 +42,7 @@ public class UserRepositoryCustomImpl implements UserRepositoryCustom {
return entityManager.createQuery(query)
.getResultList();
}
@Override
public List<User> findAllUsersByPredicates(Collection<java.util.function.Predicate<User>> predicates) {
List<User> allUsers = entityManager.createQuery("select u from User u", User.class).getResultList();

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import javax.persistence.Entity;
import javax.persistence.Id;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import java.util.ArrayList;
import java.util.Collection;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import org.springframework.data.repository.CrudRepository;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import org.springframework.data.repository.CrudRepository;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import org.springframework.data.repository.CrudRepository;

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import org.springframework.boot.SpringBootConfiguration;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;

View File

@ -0,0 +1,8 @@
/**
*
*/
package com.baeldung.boot.ddd.event;
class DomainEvent {
}

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import javax.transaction.Transactional;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.*;
import java.util.Date;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import com.google.common.collect.Sets;
import org.hibernate.annotations.OrderBy;

View File

@ -1,4 +1,4 @@
package com.baeldung.batchinserts.model;
package com.baeldung.boot.domain;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import org.hibernate.envers.Audited;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import java.math.BigDecimal;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import java.util.ArrayList;
import java.util.List;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.Embeddable;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import java.util.ArrayList;
import java.util.List;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.Entity;
import javax.persistence.Id;

View File

@ -1,6 +1,7 @@
package com.baeldung.domain.user;
package com.baeldung.boot.domain;
import javax.persistence.*;
import com.baeldung.boot.domain.Possession;
@Entity
@Table

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.Embeddable;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import java.util.ArrayList;
import java.util.List;

View File

@ -1,4 +1,4 @@
package com.baeldung.domain;
package com.baeldung.boot.domain;
import javax.persistence.ElementCollection;
import javax.persistence.Entity;

View File

@ -1,6 +1,7 @@
package com.baeldung.domain.user;
package com.baeldung.boot.domain;
import javax.persistence.*;
import java.time.LocalDate;
import java.util.List;
import java.util.Objects;
@ -27,7 +28,7 @@ public class User {
super();
}
public User(String name, LocalDate creationDate, String email, Integer status) {
public User(String name, LocalDate creationDate,String email, Integer status) {
this.name = name;
this.creationDate = creationDate;
this.email = email;
@ -51,10 +52,6 @@ public class User {
this.name = name;
}
public LocalDate getCreationDate() {
return creationDate;
}
public String getEmail() {
return email;
}
@ -78,6 +75,10 @@ public class User {
public void setAge(final int age) {
this.age = age;
}
public LocalDate getCreationDate() {
return creationDate;
}
public List<Possession> getPossessionList() {
return possessionList;
@ -93,7 +94,7 @@ public class User {
builder.append("User [name=").append(name).append(", id=").append(id).append("]");
return builder.toString();
}
@Override
public boolean equals(Object o) {
if (this == o) return true;
@ -127,4 +128,5 @@ public class User {
public void setActive(boolean active) {
this.active = active;
}
}

View File

@ -1,4 +1,4 @@
package com.baeldung.passenger;
package com.baeldung.boot.passenger;
import javax.persistence.Basic;
import javax.persistence.Column;

View File

@ -1,4 +1,4 @@
package com.baeldung.passenger;
package com.baeldung.boot.passenger;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.repository.JpaRepository;

View File

@ -1,4 +1,4 @@
package com.baeldung.passenger;
package com.baeldung.boot.passenger;
import org.springframework.stereotype.Repository;

View File

@ -0,0 +1,7 @@
package com.baeldung.boot.services;
import com.baeldung.boot.domain.Bar;
public interface IBarService extends IOperations<Bar> {
//
}

View File

@ -1,9 +1,10 @@
package com.baeldung.services;
package com.baeldung.boot.services;
import com.baeldung.domain.Foo;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import com.baeldung.boot.domain.Foo;
public interface IFooService extends IOperations<Foo> {
Foo retrieveByName(String name);

View File

@ -1,4 +1,4 @@
package com.baeldung.services;
package com.baeldung.boot.services;
import org.springframework.data.domain.Page;

View File

@ -1,6 +1,6 @@
package com.baeldung.services.impl;
package com.baeldung.boot.services.impl;
import com.baeldung.services.IOperations;
import com.baeldung.boot.services.IOperations;
import com.google.common.collect.Lists;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;

View File

@ -1,6 +1,6 @@
package com.baeldung.services.impl;
package com.baeldung.boot.services.impl;
import com.baeldung.services.IOperations;
import com.baeldung.boot.services.IOperations;
import com.google.common.collect.Lists;
import org.springframework.data.repository.CrudRepository;
import org.springframework.transaction.annotation.Transactional;

View File

@ -1,8 +1,9 @@
package com.baeldung.services.impl;
package com.baeldung.boot.services.impl;
import com.baeldung.boot.daos.IBarCrudRepository;
import com.baeldung.boot.domain.Bar;
import com.baeldung.boot.services.IBarService;
import com.baeldung.domain.Bar;
import com.baeldung.dao.repositories.IBarCrudRepository;
import com.baeldung.services.IBarService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.repository.CrudRepository;

View File

@ -1,9 +1,10 @@
package com.baeldung.services.impl;
package com.baeldung.boot.services.impl;
import com.google.common.collect.Lists;
import com.baeldung.dao.IFooDao;
import com.baeldung.domain.Foo;
import com.baeldung.services.IFooService;
import com.baeldung.boot.daos.IFooDao;
import com.baeldung.boot.domain.Foo;
import com.baeldung.boot.services.IFooService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;

View File

@ -1,4 +1,4 @@
package com.baeldung.batchinserts;
package com.baeldung.boot.web.controllers;
import java.net.URISyntaxException;
import java.util.Arrays;
@ -9,8 +9,8 @@ import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;
import com.baeldung.batchinserts.model.Customer;
import com.baeldung.batchinserts.repository.CustomerRepository;
import com.baeldung.boot.daos.CustomerRepository;
import com.baeldung.boot.domain.Customer;
/**
* A simple controller to test the JPA CrudRepository operations

View File

@ -1,97 +0,0 @@
package com.baeldung.config;
import com.baeldung.dao.repositories.impl.ExtendedRepositoryImpl;
import com.baeldung.services.IBarService;
import com.baeldung.services.impl.BarSpringDataJpaService;
import com.google.common.base.Preconditions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.*;
import org.springframework.core.env.Environment;
import org.springframework.dao.annotation.PersistenceExceptionTranslationPostProcessor;
import org.springframework.data.jpa.repository.config.EnableJpaAuditing;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.sql.DataSource;
import java.util.Properties;
@Configuration
@ComponentScan({ "com.baeldung.dao", "com.baeldung.services" })
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = { "com.baeldung.dao" }, repositoryBaseClass = ExtendedRepositoryImpl.class)
@EnableJpaAuditing
@PropertySource("classpath:persistence.properties")
@Profile("!tc")
public class PersistenceConfiguration {
@Autowired
private Environment env;
public PersistenceConfiguration() {
super();
}
@Bean
public LocalContainerEntityManagerFactoryBean entityManagerFactory() {
final LocalContainerEntityManagerFactoryBean emf = new LocalContainerEntityManagerFactoryBean();
emf.setDataSource(dataSource());
emf.setPackagesToScan("com.baeldung.domain");
final JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
emf.setJpaVendorAdapter(vendorAdapter);
emf.setJpaProperties(hibernateProperties());
return emf;
}
@Bean
public DataSource dataSource() {
final DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName(Preconditions.checkNotNull(env.getProperty("jdbc.driverClassName")));
dataSource.setUrl(Preconditions.checkNotNull(env.getProperty("jdbc.url")));
dataSource.setUsername(Preconditions.checkNotNull(env.getProperty("jdbc.user")));
dataSource.setPassword(Preconditions.checkNotNull(env.getProperty("jdbc.pass")));
return dataSource;
}
@Bean
public PlatformTransactionManager transactionManager() {
final JpaTransactionManager transactionManager = new JpaTransactionManager();
transactionManager.setEntityManagerFactory(entityManagerFactory().getObject());
return transactionManager;
}
@Bean
public PersistenceExceptionTranslationPostProcessor exceptionTranslation() {
return new PersistenceExceptionTranslationPostProcessor();
}
@Bean
public IBarService barSpringDataJpaService() {
return new BarSpringDataJpaService();
}
private final Properties hibernateProperties() {
final Properties hibernateProperties = new Properties();
hibernateProperties.setProperty("hibernate.hbm2ddl.auto", env.getProperty("hibernate.hbm2ddl.auto"));
hibernateProperties.setProperty("hibernate.dialect", env.getProperty("hibernate.dialect"));
hibernateProperties.setProperty("hibernate.show_sql", "true");
// hibernateProperties.setProperty("hibernate.format_sql", "true");
// hibernateProperties.setProperty("hibernate.globally_quoted_identifiers", "true");
// Envers properties
hibernateProperties.setProperty("org.hibernate.envers.audit_table_suffix",
env.getProperty("envers.audit_table_suffix"));
return hibernateProperties;
}
}

View File

@ -1,13 +0,0 @@
package com.baeldung.dao.repositories.product;
import com.baeldung.domain.product.Product;
import java.util.List;
import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.PagingAndSortingRepository;
public interface ProductRepository extends PagingAndSortingRepository<Product, Integer> {
List<Product> findAllByPrice(double price, Pageable pageable);
}

View File

@ -1,8 +0,0 @@
/**
*
*/
package com.baeldung.ddd.event;
class DomainEvent {
}

View File

@ -0,0 +1,14 @@
package com.baeldung.multipledb;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class MultipleDbApplication {
public static void main(String[] args) {
SpringApplication.run(MultipleDbApplication.class, args);
}
}

View File

@ -1,4 +1,4 @@
package com.baeldung.config;
package com.baeldung.multipledb;
import com.google.common.base.Preconditions;
import org.springframework.beans.factory.annotation.Autowired;
@ -19,7 +19,7 @@ import java.util.HashMap;
@Configuration
@PropertySource({"classpath:persistence-multiple-db.properties"})
@EnableJpaRepositories(basePackages = "com.baeldung.dao.repositories.product", entityManagerFactoryRef = "productEntityManager", transactionManagerRef = "productTransactionManager")
@EnableJpaRepositories(basePackages = "com.baeldung.multipledb.dao.product", entityManagerFactoryRef = "productEntityManager", transactionManagerRef = "productTransactionManager")
@Profile("!tc")
public class PersistenceProductConfiguration {
@Autowired
@ -35,7 +35,7 @@ public class PersistenceProductConfiguration {
public LocalContainerEntityManagerFactoryBean productEntityManager() {
final LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
em.setDataSource(productDataSource());
em.setPackagesToScan("com.baeldung.domain.product");
em.setPackagesToScan("com.baeldung.multipledb.model.product");
final HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
em.setJpaVendorAdapter(vendorAdapter);

View File

@ -1,4 +1,4 @@
package com.baeldung.config;
package com.baeldung.multipledb;
import com.google.common.base.Preconditions;
import org.springframework.beans.factory.annotation.Autowired;
@ -16,7 +16,7 @@ import java.util.HashMap;
@Configuration
@PropertySource({"classpath:persistence-multiple-db.properties"})
@EnableJpaRepositories(basePackages = "com.baeldung.dao.repositories.user", entityManagerFactoryRef = "userEntityManager", transactionManagerRef = "userTransactionManager")
@EnableJpaRepositories(basePackages = "com.baeldung.multipledb.dao.user", entityManagerFactoryRef = "userEntityManager", transactionManagerRef = "userTransactionManager")
@Profile("!tc")
public class PersistenceUserConfiguration {
@Autowired
@ -31,9 +31,10 @@ public class PersistenceUserConfiguration {
@Primary
@Bean
public LocalContainerEntityManagerFactoryBean userEntityManager() {
System.out.println("loading config");
final LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
em.setDataSource(userDataSource());
em.setPackagesToScan("com.baeldung.domain.user");
em.setPackagesToScan("com.baeldung.multipledb.model.user");
final HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
em.setJpaVendorAdapter(vendorAdapter);

View File

@ -0,0 +1,13 @@
package com.baeldung.multipledb.dao.product;
import java.util.List;
import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.PagingAndSortingRepository;
import com.baeldung.multipledb.model.product.ProductMultipleDB;
public interface ProductRepository extends PagingAndSortingRepository<ProductMultipleDB, Integer> {
List<ProductMultipleDB> findAllByPrice(double price, Pageable pageable);
}

View File

@ -0,0 +1,9 @@
package com.baeldung.multipledb.dao.user;
import org.springframework.data.jpa.repository.JpaRepository;
import com.baeldung.multipledb.model.user.PossessionMultipleDB;
public interface PossessionRepository extends JpaRepository<PossessionMultipleDB, Long> {
}

View File

@ -0,0 +1,8 @@
package com.baeldung.multipledb.dao.user;
import org.springframework.data.jpa.repository.JpaRepository;
import com.baeldung.multipledb.model.user.UserMultipleDB;
public interface UserRepository extends JpaRepository<UserMultipleDB, Integer> {
}

View File

@ -1,4 +1,4 @@
package com.baeldung.domain.product;
package com.baeldung.multipledb.model.product;
import javax.persistence.Entity;
import javax.persistence.Id;
@ -6,7 +6,7 @@ import javax.persistence.Table;
@Entity
@Table(schema = "products")
public class Product {
public class ProductMultipleDB {
@Id
private int id;
@ -15,19 +15,19 @@ public class Product {
private double price;
public Product() {
public ProductMultipleDB() {
super();
}
private Product(int id, String name, double price) {
private ProductMultipleDB(int id, String name, double price) {
super();
this.id = id;
this.name = name;
this.price = price;
}
public static Product from(int id, String name, double price) {
return new Product(id, name, price);
public static ProductMultipleDB from(int id, String name, double price) {
return new ProductMultipleDB(id, name, price);
}
public int getId() {

View File

@ -0,0 +1,82 @@
package com.baeldung.multipledb.model.user;
import javax.persistence.*;
@Entity
@Table
public class PossessionMultipleDB {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private long id;
private String name;
public PossessionMultipleDB() {
super();
}
public PossessionMultipleDB(final String name) {
super();
this.name = name;
}
public long getId() {
return id;
}
public void setId(final int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(final String name) {
this.name = name;
}
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = (prime * result) + (int) (id ^ (id >>> 32));
result = (prime * result) + ((name == null) ? 0 : name.hashCode());
return result;
}
@Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (obj == null) {
return false;
}
if (getClass() != obj.getClass()) {
return false;
}
final PossessionMultipleDB other = (PossessionMultipleDB) obj;
if (id != other.id) {
return false;
}
if (name == null) {
if (other.name != null) {
return false;
}
} else if (!name.equals(other.name)) {
return false;
}
return true;
}
@Override
public String toString() {
final StringBuilder builder = new StringBuilder();
builder.append("Possesion [id=").append(id).append(", name=").append(name).append("]");
return builder.toString();
}
}

View File

@ -0,0 +1,88 @@
package com.baeldung.multipledb.model.user;
import javax.persistence.*;
import java.util.List;
@Entity
@Table(name = "users")
public class UserMultipleDB {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private int id;
private String name;
private int age;
@Column(unique = true, nullable = false)
private String email;
private Integer status;
@OneToMany
List<PossessionMultipleDB> possessionList;
public UserMultipleDB() {
super();
}
public UserMultipleDB(String name, String email, Integer status) {
this.name = name;
this.email = email;
this.status = status;
}
public int getId() {
return id;
}
public void setId(final int id) {
this.id = id;
}
public String getName() {
return name;
}
public void setName(final String name) {
this.name = name;
}
public String getEmail() {
return email;
}
public void setEmail(final String email) {
this.email = email;
}
public Integer getStatus() {
return status;
}
public void setStatus(Integer status) {
this.status = status;
}
public int getAge() {
return age;
}
public void setAge(final int age) {
this.age = age;
}
public List<PossessionMultipleDB> getPossessionList() {
return possessionList;
}
public void setPossessionList(List<PossessionMultipleDB> possessionList) {
this.possessionList = possessionList;
}
@Override
public String toString() {
final StringBuilder builder = new StringBuilder();
builder.append("User [name=").append(name).append(", id=").append(id).append("]");
return builder.toString();
}
}

View File

@ -1,7 +0,0 @@
package com.baeldung.services;
import com.baeldung.domain.Bar;
public interface IBarService extends IOperations<Bar> {
//
}

View File

@ -1,22 +1,6 @@
# spring.datasource.x
spring.datasource.driver-class-name=org.h2.Driver
spring.datasource.url=jdbc:h2:mem:db;DB_CLOSE_DELAY=-1
spring.datasource.username=sa
spring.datasource.password=sa
# hibernate.X
hibernate.dialect=org.hibernate.dialect.H2Dialect
hibernate.show_sql=true
hibernate.hbm2ddl.auto=create-drop
hibernate.cache.use_second_level_cache=true
hibernate.cache.use_query_cache=true
hibernate.cache.region.factory_class=org.hibernate.cache.ehcache.EhCacheRegionFactory
spring.datasource.data=import_entities.sql
spring.main.allow-bean-definition-overriding=true
spring.jpa.properties.hibernate.jdbc.batch_size=4
spring.jpa.properties.hibernate.order_inserts=true
spring.jpa.properties.hibernate.order_updates=true
spring.jpa.properties.hibernate.generate_statistics=true
spring.jpa.properties.hibernate.generate_statistics=true

View File

@ -12,5 +12,3 @@ hibernate.cache.use_second_level_cache=true
hibernate.cache.use_query_cache=true
hibernate.cache.region.factory_class=org.hibernate.cache.ehcache.EhCacheRegionFactory
# envers.X
envers.audit_table_suffix=_audit_log

View File

@ -9,21 +9,17 @@ import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.servlet.AutoConfigureMockMvc;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.web.servlet.MockMvc;
import org.springframework.test.web.servlet.setup.MockMvcBuilders;
import com.baeldung.batchinserts.CustomerController;
import com.baeldung.batchinserts.repository.CustomerRepository;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.config.PersistenceUserConfiguration;
import com.baeldung.boot.Application;
import com.baeldung.boot.daos.CustomerRepository;
import com.baeldung.boot.web.controllers.CustomerController;
@RunWith(SpringRunner.class)
@SpringBootTest
@SpringBootTest(classes=Application.class)
@AutoConfigureMockMvc
@ContextConfiguration(classes = { PersistenceConfiguration.class, PersistenceProductConfiguration.class, PersistenceUserConfiguration.class })
public class BatchInsertIntegrationTest {
@Autowired

View File

@ -1,13 +1,16 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.daos.ArticleRepository;
import com.baeldung.boot.domain.Article;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.config.PersistenceUserConfiguration;
import com.baeldung.domain.Article;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.orm.jpa.DataJpaTest;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.context.annotation.Import;
import org.springframework.test.context.junit4.SpringRunner;
import java.text.SimpleDateFormat;
@ -18,7 +21,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
@RunWith(SpringRunner.class)
@DataJpaTest(excludeAutoConfiguration = {PersistenceConfiguration.class, PersistenceUserConfiguration.class, PersistenceProductConfiguration.class})
@DataJpaTest(properties="spring.datasource.data=classpath:import_entities.sql")
public class ArticleRepositoryIntegrationTest {
@Autowired

View File

@ -1,7 +1,10 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.daos.ExtendedStudentRepository;
import com.baeldung.boot.domain.Student;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.domain.Student;
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
@ -15,7 +18,7 @@ import java.util.List;
import static org.assertj.core.api.Assertions.assertThat;
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = {PersistenceConfiguration.class})
@ContextConfiguration(classes = {Application.class})
@DirtiesContext
public class ExtendedStudentRepositoryIntegrationTest {
@Resource

View File

@ -1,11 +1,15 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.daos.InventoryRepository;
import com.baeldung.boot.domain.MerchandiseEntity;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.domain.MerchandiseEntity;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.orm.jpa.DataJpaTest;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import java.math.BigDecimal;
@ -15,7 +19,7 @@ import static org.junit.Assert.assertNotEquals;
import static org.junit.Assert.assertNotNull;
@RunWith(SpringRunner.class)
@DataJpaTest(excludeAutoConfiguration = {PersistenceConfiguration.class})
@SpringBootTest(classes=Application.class)
public class InventoryRepositoryIntegrationTest {
private static final String ORIGINAL_TITLE = "Pair of Pants";

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import static junit.framework.TestCase.assertEquals;
import static junit.framework.TestCase.assertFalse;
@ -13,18 +13,24 @@ import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.orm.jpa.DataJpaTest;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.config.PersistenceUserConfiguration;
import com.baeldung.domain.Item;
import com.baeldung.domain.ItemType;
import com.baeldung.domain.Location;
import com.baeldung.domain.Store;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.daos.ItemTypeRepository;
import com.baeldung.boot.daos.LocationRepository;
import com.baeldung.boot.daos.ReadOnlyLocationRepository;
import com.baeldung.boot.daos.StoreRepository;
import com.baeldung.boot.domain.Item;
import com.baeldung.boot.domain.ItemType;
import com.baeldung.boot.domain.Location;
import com.baeldung.boot.domain.Store;
import com.baeldung.multipledb.PersistenceProductConfiguration;
import com.baeldung.multipledb.PersistenceUserConfiguration;
@RunWith(SpringRunner.class)
@DataJpaTest(excludeAutoConfiguration = { PersistenceConfiguration.class, PersistenceUserConfiguration.class, PersistenceProductConfiguration.class })
@DataJpaTest(properties="spring.datasource.data=classpath:import_entities.sql")
public class JpaRepositoriesIntegrationTest {
@Autowired
private LocationRepository locationRepository;

View File

@ -1,7 +1,8 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.boot.daos.impl.PersonInsertRepository;
import com.baeldung.boot.domain.Person;
import com.baeldung.dao.repositories.impl.PersonInsertRepository;
import com.baeldung.domain.Person;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,7 +1,5 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.dao.repositories.user.UserRepository;
import com.baeldung.domain.user.User;
import org.junit.After;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
@ -12,6 +10,9 @@ import org.springframework.data.jpa.domain.JpaSort;
import org.springframework.data.mapping.PropertyReferenceException;
import org.springframework.transaction.annotation.Transactional;
import com.baeldung.boot.daos.user.UserRepository;
import com.baeldung.boot.domain.User;
import javax.persistence.EntityManager;
import javax.persistence.Query;
import java.time.LocalDate;

View File

@ -1,7 +1,7 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.domain.user.User;
import com.baeldung.boot.Application;
import com.baeldung.boot.domain.User;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
@ -17,7 +17,7 @@ import static org.assertj.core.api.Assertions.assertThat;
* Created by adam.
*/
@RunWith(SpringRunner.class)
@SpringBootTest(classes = PersistenceConfiguration.class)
@SpringBootTest(classes = Application.class)
@DirtiesContext
public class UserRepositoryIntegrationTest extends UserRepositoryCommon {

View File

@ -1,6 +1,7 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.user.User;
import com.baeldung.boot.Application;
import com.baeldung.boot.domain.User;
import com.baeldung.util.BaeldungPostgresqlContainer;
import org.junit.ClassRule;
import org.junit.Test;
@ -19,7 +20,7 @@ import static org.assertj.core.api.Assertions.assertThat;
* Created by adam.
*/
@RunWith(SpringRunner.class)
@SpringBootTest
@SpringBootTest(classes = Application.class)
@ActiveProfiles({"tc", "tc-auto"})
public class UserRepositoryTCAutoIntegrationTest extends UserRepositoryCommon {

View File

@ -1,6 +1,7 @@
package com.baeldung.dao.repositories;
package com.baeldung.boot.daos;
import com.baeldung.domain.user.User;
import com.baeldung.boot.Application;
import com.baeldung.boot.domain.User;
import org.junit.ClassRule;
import org.junit.Test;
import org.junit.runner.RunWith;
@ -19,7 +20,7 @@ import java.time.LocalDate;
import static org.assertj.core.api.Assertions.assertThat;
@RunWith(SpringRunner.class)
@SpringBootTest
@SpringBootTest(classes = Application.class)
@ActiveProfiles("tc")
@ContextConfiguration(initializers = {UserRepositoryTCIntegrationTest.Initializer.class})
public class UserRepositoryTCIntegrationTest extends UserRepositoryCommon {

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.times;
@ -15,6 +15,10 @@ import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
import com.baeldung.boot.ddd.event.Aggregate2;
import com.baeldung.boot.ddd.event.Aggregate2Repository;
import com.baeldung.boot.ddd.event.DomainEvent;
@SpringJUnitConfig
@SpringBootTest
class Aggregate2EventsIntegrationTest {

View File

@ -1,7 +1,7 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.times;
@ -14,6 +14,10 @@ import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
import com.baeldung.boot.ddd.event.Aggregate3;
import com.baeldung.boot.ddd.event.Aggregate3Repository;
import com.baeldung.boot.ddd.event.DomainEvent;
@SpringJUnitConfig
@SpringBootTest
class Aggregate3EventsIntegrationTest {

View File

@ -1,4 +1,4 @@
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.times;
@ -16,6 +16,11 @@ import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.annotation.Bean;
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
import com.baeldung.boot.ddd.event.Aggregate;
import com.baeldung.boot.ddd.event.AggregateRepository;
import com.baeldung.boot.ddd.event.DomainEvent;
import com.baeldung.boot.ddd.event.DomainService;
@SpringJUnitConfig
@SpringBootTest
class AggregateEventsIntegrationTest {

View File

@ -1,10 +1,12 @@
/**
*
*/
package com.baeldung.ddd.event;
package com.baeldung.boot.ddd.event;
import org.springframework.transaction.event.TransactionalEventListener;
import com.baeldung.boot.ddd.event.DomainEvent;
interface TestEventHandler {
@TransactionalEventListener
void handleEvent(DomainEvent event);

View File

@ -1,4 +1,4 @@
package com.baeldung.passenger;
package com.baeldung.boot.passenger;
import org.junit.Before;
import org.junit.Test;
@ -12,6 +12,9 @@ import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.test.context.junit4.SpringRunner;
import com.baeldung.boot.passenger.Passenger;
import com.baeldung.boot.passenger.PassengerRepository;
import javax.persistence.EntityManager;
import javax.persistence.PersistenceContext;
import java.util.List;
@ -23,6 +26,7 @@ import static org.hamcrest.core.IsNot.not;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
@DataJpaTest
@RunWith(SpringRunner.class)
public class PassengerRepositoryIntegrationTest {

View File

@ -1,6 +1,7 @@
package com.baeldung.services;
package com.baeldung.boot.services;
import com.baeldung.domain.Foo;
import com.baeldung.boot.domain.Foo;
import com.baeldung.boot.services.IOperations;
import com.baeldung.util.IDUtil;
import org.hamcrest.Matchers;
import org.junit.Ignore;

View File

@ -1,11 +1,16 @@
package com.baeldung.services;
package com.baeldung.boot.services;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.domain.Foo;
import com.baeldung.boot.services.IFooService;
import com.baeldung.boot.services.IOperations;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.domain.Foo;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.dao.InvalidDataAccessApiUsageException;
import org.springframework.test.context.ContextConfiguration;
@ -16,7 +21,7 @@ import static org.apache.commons.lang3.RandomStringUtils.randomAlphabetic;
import static org.junit.Assert.assertNotNull;
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = {PersistenceConfiguration.class}, loader = AnnotationConfigContextLoader.class)
@SpringBootTest(classes=Application.class)
public class FooServicePersistenceIntegrationTest extends AbstractServicePersistenceIntegrationTest<Foo> {
@Autowired

View File

@ -1,4 +1,4 @@
package com.baeldung.services;
package com.baeldung.boot.services;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
@ -16,16 +16,19 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.security.test.context.support.WithMockUser;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.context.support.AnnotationConfigContextLoader;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.domain.Bar;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.boot.domain.Bar;
import com.baeldung.boot.services.IBarService;
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = { PersistenceConfiguration.class }, loader = AnnotationConfigContextLoader.class)
@SpringBootTest(classes=Application.class)
public class SpringDataJPABarAuditIntegrationTest {
private static Logger logger = LoggerFactory.getLogger(SpringDataJPABarAuditIntegrationTest.class);

View File

@ -1,4 +1,4 @@
package com.baeldung.services;
package com.baeldung.multipledb;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
@ -10,26 +10,23 @@ import java.util.Optional;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.dao.DataIntegrityViolationException;
import org.springframework.test.annotation.DirtiesContext;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.Transactional;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.config.PersistenceUserConfiguration;
import com.baeldung.dao.repositories.product.ProductRepository;
import com.baeldung.dao.repositories.user.PossessionRepository;
import com.baeldung.dao.repositories.user.UserRepository;
import com.baeldung.domain.product.Product;
import com.baeldung.domain.user.Possession;
import com.baeldung.domain.user.User;
import com.baeldung.multipledb.dao.product.ProductRepository;
import com.baeldung.multipledb.dao.user.PossessionRepository;
import com.baeldung.multipledb.dao.user.UserRepository;
import com.baeldung.multipledb.model.product.ProductMultipleDB;
import com.baeldung.multipledb.model.user.PossessionMultipleDB;
import com.baeldung.multipledb.model.user.UserMultipleDB;
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = { PersistenceUserConfiguration.class, PersistenceProductConfiguration.class })
@SpringBootTest(classes=MultipleDbApplication.class)
@EnableTransactionManagement
@DirtiesContext
public class JpaMultipleDBIntegrationTest {
@Autowired
@ -46,15 +43,15 @@ public class JpaMultipleDBIntegrationTest {
@Test
@Transactional("userTransactionManager")
public void whenCreatingUser_thenCreated() {
User user = new User();
UserMultipleDB user = new UserMultipleDB();
user.setName("John");
user.setEmail("john@test.com");
user.setAge(20);
Possession p = new Possession("sample");
PossessionMultipleDB p = new PossessionMultipleDB("sample");
p = possessionRepository.save(p);
user.setPossessionList(Collections.singletonList(p));
user = userRepository.save(user);
final Optional<User> result = userRepository.findById(user.getId());
final Optional<UserMultipleDB> result = userRepository.findById(user.getId());
assertTrue(result.isPresent());
System.out.println(result.get().getPossessionList());
assertEquals(1, result.get().getPossessionList().size());
@ -63,14 +60,14 @@ public class JpaMultipleDBIntegrationTest {
@Test
@Transactional("userTransactionManager")
public void whenCreatingUsersWithSameEmail_thenRollback() {
User user1 = new User();
UserMultipleDB user1 = new UserMultipleDB();
user1.setName("John");
user1.setEmail("john@test.com");
user1.setAge(20);
user1 = userRepository.save(user1);
assertTrue(userRepository.findById(user1.getId()).isPresent());
User user2 = new User();
UserMultipleDB user2 = new UserMultipleDB();
user2.setName("Tom");
user2.setEmail("john@test.com");
user2.setAge(10);
@ -88,7 +85,7 @@ public class JpaMultipleDBIntegrationTest {
@Test
@Transactional("productTransactionManager")
public void whenCreatingProduct_thenCreated() {
Product product = new Product();
ProductMultipleDB product = new ProductMultipleDB();
product.setName("Book");
product.setId(2);
product.setPrice(20);

View File

@ -1,4 +1,4 @@
package com.baeldung.dao.repositories.product;
package com.baeldung.multipledb;
import static org.hamcrest.Matchers.equalTo;
import static org.hamcrest.Matchers.hasSize;
@ -13,6 +13,7 @@ import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
@ -22,11 +23,12 @@ import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import org.springframework.transaction.annotation.Transactional;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.domain.product.Product;
import com.baeldung.multipledb.PersistenceProductConfiguration;
import com.baeldung.multipledb.dao.product.ProductRepository;
import com.baeldung.multipledb.model.product.ProductMultipleDB;
@RunWith(SpringRunner.class)
@ContextConfiguration(classes = { PersistenceProductConfiguration.class })
@SpringBootTest(classes=MultipleDbApplication.class)
@EnableTransactionManagement
public class ProductRepositoryIntegrationTest {
@ -36,22 +38,22 @@ public class ProductRepositoryIntegrationTest {
@Before
@Transactional("productTransactionManager")
public void setUp() {
productRepository.save(Product.from(1001, "Book", 21));
productRepository.save(Product.from(1002, "Coffee", 10));
productRepository.save(Product.from(1003, "Jeans", 30));
productRepository.save(Product.from(1004, "Shirt", 32));
productRepository.save(Product.from(1005, "Bacon", 10));
productRepository.save(ProductMultipleDB.from(1001, "Book", 21));
productRepository.save(ProductMultipleDB.from(1002, "Coffee", 10));
productRepository.save(ProductMultipleDB.from(1003, "Jeans", 30));
productRepository.save(ProductMultipleDB.from(1004, "Shirt", 32));
productRepository.save(ProductMultipleDB.from(1005, "Bacon", 10));
}
@Test
public void whenRequestingFirstPageOfSizeTwo_ThenReturnFirstPage() {
Pageable pageRequest = PageRequest.of(0, 2);
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(2));
assertTrue(result.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.allMatch(id -> Arrays.asList(1001, 1002)
.contains(id)));
}
@ -60,11 +62,11 @@ public class ProductRepositoryIntegrationTest {
public void whenRequestingSecondPageOfSizeTwo_ThenReturnSecondPage() {
Pageable pageRequest = PageRequest.of(1, 2);
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(2));
assertTrue(result.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.allMatch(id -> Arrays.asList(1003, 1004)
.contains(id)));
}
@ -73,11 +75,11 @@ public class ProductRepositoryIntegrationTest {
public void whenRequestingLastPage_ThenReturnLastPageWithRemData() {
Pageable pageRequest = PageRequest.of(2, 2);
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(1));
assertTrue(result.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.allMatch(id -> Arrays.asList(1005)
.contains(id)));
}
@ -86,12 +88,12 @@ public class ProductRepositoryIntegrationTest {
public void whenSortingByNameAscAndPaging_ThenReturnSortedPagedResult() {
Pageable pageRequest = PageRequest.of(0, 3, Sort.by("name"));
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(3));
assertThat(result.getContent()
.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.collect(Collectors.toList()), equalTo(Arrays.asList(1005, 1001, 1002)));
}
@ -101,12 +103,12 @@ public class ProductRepositoryIntegrationTest {
Pageable pageRequest = PageRequest.of(0, 3, Sort.by("price")
.descending());
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(3));
assertThat(result.getContent()
.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.collect(Collectors.toList()), equalTo(Arrays.asList(1004, 1003, 1001)));
}
@ -117,12 +119,12 @@ public class ProductRepositoryIntegrationTest {
.descending()
.and(Sort.by("name")));
Page<Product> result = productRepository.findAll(pageRequest);
Page<ProductMultipleDB> result = productRepository.findAll(pageRequest);
assertThat(result.getContent(), hasSize(5));
assertThat(result.getContent()
.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.collect(Collectors.toList()), equalTo(Arrays.asList(1004, 1003, 1001, 1005, 1002)));
}
@ -131,11 +133,11 @@ public class ProductRepositoryIntegrationTest {
public void whenRequestingFirstPageOfSizeTwoUsingCustomMethod_ThenReturnFirstPage() {
Pageable pageRequest = PageRequest.of(0, 2);
List<Product> result = productRepository.findAllByPrice(10, pageRequest);
List<ProductMultipleDB> result = productRepository.findAllByPrice(10, pageRequest);
assertThat(result, hasSize(2));
assertTrue(result.stream()
.map(Product::getId)
.map(ProductMultipleDB::getId)
.allMatch(id -> Arrays.asList(1002, 1005)
.contains(id)));
}

View File

@ -5,7 +5,7 @@ import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import com.baeldung.Application;
import com.baeldung.boot.Application;
@RunWith(SpringRunner.class)
@SpringBootTest(classes = Application.class)

View File

@ -6,10 +6,10 @@ import org.springframework.boot.test.autoconfigure.orm.jpa.DataJpaTest;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import com.baeldung.Application;
import com.baeldung.config.PersistenceConfiguration;
import com.baeldung.config.PersistenceProductConfiguration;
import com.baeldung.config.PersistenceUserConfiguration;
import com.baeldung.boot.Application;
import com.baeldung.boot.config.PersistenceConfiguration;
import com.baeldung.multipledb.PersistenceProductConfiguration;
import com.baeldung.multipledb.PersistenceUserConfiguration;
@RunWith(SpringRunner.class)
@DataJpaTest(excludeAutoConfiguration = {