Nikita Konev
5 years ago
committed by
Mark Paluch
4 changed files with 274 additions and 1 deletions
@ -0,0 +1,239 @@
@@ -0,0 +1,239 @@
|
||||
package org.springframework.data.jdbc.core.dialect; |
||||
|
||||
import com.fasterxml.jackson.core.JsonProcessingException; |
||||
import com.fasterxml.jackson.databind.ObjectMapper; |
||||
import lombok.AllArgsConstructor; |
||||
import lombok.Data; |
||||
import lombok.NoArgsConstructor; |
||||
import org.junit.jupiter.api.AfterAll; |
||||
import org.junit.jupiter.api.BeforeAll; |
||||
import org.junit.jupiter.api.Test; |
||||
import org.junit.jupiter.api.condition.EnabledIfSystemProperty; |
||||
import org.junit.jupiter.api.extension.ExtendWith; |
||||
import org.postgresql.util.PGobject; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.context.annotation.*; |
||||
import org.springframework.core.convert.converter.Converter; |
||||
import org.springframework.data.annotation.Id; |
||||
import org.springframework.data.convert.CustomConversions; |
||||
import org.springframework.data.convert.ReadingConverter; |
||||
import org.springframework.data.convert.WritingConverter; |
||||
import org.springframework.data.jdbc.core.convert.JdbcCustomConversions; |
||||
import org.springframework.data.jdbc.core.mapping.JdbcSimpleTypes; |
||||
import org.springframework.data.jdbc.repository.config.EnableJdbcRepositories; |
||||
import org.springframework.data.jdbc.testing.TestConfiguration; |
||||
import org.springframework.data.mapping.model.SimpleTypeHolder; |
||||
import org.springframework.data.relational.core.dialect.Dialect; |
||||
import org.springframework.data.relational.core.mapping.Table; |
||||
import org.springframework.data.repository.CrudRepository; |
||||
import org.springframework.test.context.ContextConfiguration; |
||||
import org.springframework.test.context.junit.jupiter.SpringExtension; |
||||
import org.springframework.transaction.annotation.Transactional; |
||||
|
||||
import java.io.ByteArrayOutputStream; |
||||
import java.io.PrintStream; |
||||
import java.sql.SQLException; |
||||
import java.util.ArrayList; |
||||
import java.util.List; |
||||
import java.util.Optional; |
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat; |
||||
|
||||
/** |
||||
* Tests for PostgreSQL Dialect. |
||||
* Start this test with -Dspring.profiles.active=postgres |
||||
* |
||||
* @author Nikita Konev |
||||
*/ |
||||
@EnabledIfSystemProperty(named = "spring.profiles.active", matches = "postgres") |
||||
@ContextConfiguration |
||||
@Transactional |
||||
@ExtendWith(SpringExtension.class) |
||||
public class PostgresDialectIntegrationTests { |
||||
|
||||
private static final ByteArrayOutputStream capturedOutContent = new ByteArrayOutputStream(); |
||||
private static PrintStream previousOutput; |
||||
|
||||
@Profile("postgres") |
||||
@Configuration |
||||
@Import(TestConfiguration.class) |
||||
@EnableJdbcRepositories(considerNestedRepositories = true, |
||||
includeFilters = @ComponentScan.Filter(value = CustomerRepository.class, type = FilterType.ASSIGNABLE_TYPE)) |
||||
static class Config { |
||||
|
||||
private final ObjectMapper objectMapper = new ObjectMapper(); |
||||
|
||||
@Bean |
||||
Class<?> testClass() { |
||||
return PostgresDialectIntegrationTests.class; |
||||
} |
||||
|
||||
@WritingConverter |
||||
static class PersonDataWritingConverter extends AbstractPostgresJsonWritingConverter<PersonData> { |
||||
|
||||
public PersonDataWritingConverter(ObjectMapper objectMapper) { |
||||
super(objectMapper, true); |
||||
} |
||||
} |
||||
|
||||
@ReadingConverter |
||||
static class PersonDataReadingConverter extends AbstractPostgresJsonReadingConverter<PersonData> { |
||||
public PersonDataReadingConverter(ObjectMapper objectMapper) { |
||||
super(objectMapper, PersonData.class); |
||||
} |
||||
} |
||||
|
||||
@WritingConverter |
||||
static class SessionDataWritingConverter extends AbstractPostgresJsonWritingConverter<SessionData> { |
||||
public SessionDataWritingConverter(ObjectMapper objectMapper) { |
||||
super(objectMapper, true); |
||||
} |
||||
} |
||||
|
||||
@ReadingConverter |
||||
static class SessionDataReadingConverter extends AbstractPostgresJsonReadingConverter<SessionData> { |
||||
public SessionDataReadingConverter(ObjectMapper objectMapper) { |
||||
super(objectMapper, SessionData.class); |
||||
} |
||||
} |
||||
|
||||
private List<Object> storeConverters(Dialect dialect) { |
||||
|
||||
List<Object> converters = new ArrayList<>(); |
||||
converters.addAll(dialect.getConverters()); |
||||
converters.addAll(JdbcCustomConversions.storeConverters()); |
||||
return converters; |
||||
} |
||||
|
||||
protected List<?> userConverters() { |
||||
final List<Converter> list = new ArrayList<>(); |
||||
list.add(new PersonDataWritingConverter(objectMapper)); |
||||
list.add(new PersonDataReadingConverter(objectMapper)); |
||||
list.add(new SessionDataWritingConverter(objectMapper)); |
||||
list.add(new SessionDataReadingConverter(objectMapper)); |
||||
return list; |
||||
} |
||||
|
||||
@Primary |
||||
@Bean |
||||
CustomConversions jdbcCustomConversions(Dialect dialect) { |
||||
SimpleTypeHolder simpleTypeHolder = new SimpleTypeHolder(dialect.simpleTypes(), JdbcSimpleTypes.HOLDER); |
||||
|
||||
return new JdbcCustomConversions(CustomConversions.StoreConversions.of(simpleTypeHolder, storeConverters(dialect)), |
||||
userConverters()); |
||||
} |
||||
|
||||
} |
||||
|
||||
@BeforeAll |
||||
public static void ba() { |
||||
previousOutput = System.out; |
||||
System.setOut(new PrintStream(capturedOutContent)); |
||||
} |
||||
|
||||
@AfterAll |
||||
public static void aa() { |
||||
System.setOut(previousOutput); |
||||
previousOutput = null; |
||||
} |
||||
|
||||
/** |
||||
* An abstract class for building your own converter for PostgerSQL's JSON[b]. |
||||
*/ |
||||
static class AbstractPostgresJsonReadingConverter<T> implements Converter<PGobject, T> { |
||||
private final ObjectMapper objectMapper; |
||||
private final Class<T> valueType; |
||||
|
||||
public AbstractPostgresJsonReadingConverter(ObjectMapper objectMapper, Class<T> valueType) { |
||||
this.objectMapper = objectMapper; |
||||
this.valueType = valueType; |
||||
} |
||||
|
||||
@Override |
||||
public T convert(PGobject pgObject) { |
||||
try { |
||||
final String source = pgObject.getValue(); |
||||
return objectMapper.readValue(source, valueType); |
||||
} catch (JsonProcessingException e) { |
||||
throw new RuntimeException("Unable to deserialize to json " + pgObject, e); |
||||
} |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* An abstract class for building your own converter for PostgerSQL's JSON[b]. |
||||
*/ |
||||
static class AbstractPostgresJsonWritingConverter<T> implements Converter<T, PGobject> { |
||||
private final ObjectMapper objectMapper; |
||||
private final boolean jsonb; |
||||
|
||||
public AbstractPostgresJsonWritingConverter(ObjectMapper objectMapper, boolean jsonb) { |
||||
this.objectMapper = objectMapper; |
||||
this.jsonb = jsonb; |
||||
} |
||||
|
||||
@Override |
||||
public PGobject convert(T source) { |
||||
try { |
||||
final PGobject pGobject = new PGobject(); |
||||
pGobject.setType(jsonb ? "jsonb" : "json"); |
||||
pGobject.setValue(objectMapper.writeValueAsString(source)); |
||||
return pGobject; |
||||
} catch (JsonProcessingException | SQLException e) { |
||||
throw new RuntimeException("Unable to serialize to json " + source, e); |
||||
} |
||||
} |
||||
} |
||||
|
||||
@Data |
||||
@AllArgsConstructor |
||||
@Table("customers") |
||||
public static class Customer { |
||||
|
||||
@Id |
||||
private Long id; |
||||
private String name; |
||||
private PersonData personData; |
||||
private SessionData sessionData; |
||||
} |
||||
|
||||
@Data |
||||
@NoArgsConstructor |
||||
@AllArgsConstructor |
||||
public static class PersonData { |
||||
private int age; |
||||
private String petName; |
||||
} |
||||
|
||||
@Data |
||||
@NoArgsConstructor |
||||
@AllArgsConstructor |
||||
public static class SessionData { |
||||
private String token; |
||||
private Long ttl; |
||||
} |
||||
|
||||
interface CustomerRepository extends CrudRepository<Customer, Long> { |
||||
|
||||
} |
||||
|
||||
@Autowired |
||||
CustomerRepository customerRepository; |
||||
|
||||
@Test |
||||
void testWarningShouldNotBeShown() { |
||||
final Customer saved = customerRepository.save(new Customer(null, "Adam Smith", new PersonData(30, "Casper"), null)); |
||||
assertThat(saved.getId()).isNotZero(); |
||||
final Optional<Customer> byId = customerRepository.findById(saved.getId()); |
||||
assertThat(byId.isPresent()).isTrue(); |
||||
final Customer foundCustomer = byId.get(); |
||||
assertThat(foundCustomer.getName()).isEqualTo("Adam Smith"); |
||||
assertThat(foundCustomer.getPersonData()).isNotNull(); |
||||
assertThat(foundCustomer.getPersonData().getAge()).isEqualTo(30); |
||||
assertThat(foundCustomer.getPersonData().getPetName()).isEqualTo("Casper"); |
||||
assertThat(foundCustomer.getSessionData()).isNull(); |
||||
|
||||
assertThat(capturedOutContent.toString()).doesNotContain("although it doesn't convert from a store-supported type"); |
||||
} |
||||
|
||||
} |
||||
@ -0,0 +1,8 @@
@@ -0,0 +1,8 @@
|
||||
DROP TABLE customers; |
||||
|
||||
CREATE TABLE customers ( |
||||
id BIGSERIAL PRIMARY KEY, |
||||
name TEXT NOT NULL, |
||||
person_data JSONB, |
||||
session_data JSONB |
||||
); |
||||
Loading…
Reference in new issue