#79 - Add benchmark for typical EntityReader.
This commit is contained in:
Mark Paluch
43
benchmark/commons/pom.xml
Normal file
43
benchmark/commons/pom.xml
Normal file
@@ -0,0 +1,43 @@
|
||||
<?xml version="1.0" encoding="UTF-8"?>
|
||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
||||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
|
||||
|
||||
<modelVersion>4.0.0</modelVersion>
|
||||
|
||||
<parent>
|
||||
<groupId>org.springframework.data</groupId>
|
||||
<artifactId>spring-data-benchmark-parent</artifactId>
|
||||
<version>2.1.0.BUILD-SNAPSHOT</version>
|
||||
</parent>
|
||||
|
||||
<artifactId>spring-data-benchmark-commons</artifactId>
|
||||
|
||||
<name>Spring Data Benchmarks - Commons Microbenchmarks</name>
|
||||
|
||||
<dependencies>
|
||||
|
||||
<dependency>
|
||||
<groupId>${project.groupId}</groupId>
|
||||
<artifactId>spring-data-benchmark-support</artifactId>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>${project.groupId}</groupId>
|
||||
<artifactId>spring-data-commons</artifactId>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.jetbrains.kotlin</groupId>
|
||||
<artifactId>kotlin-stdlib-jdk8</artifactId>
|
||||
<version>${kotlin}</version>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
<groupId>org.jetbrains.kotlin</groupId>
|
||||
<artifactId>kotlin-reflect</artifactId>
|
||||
<version>${kotlin}</version>
|
||||
</dependency>
|
||||
|
||||
</dependencies>
|
||||
|
||||
</project>
|
||||
@@ -0,0 +1,282 @@
|
||||
/*
|
||||
* Copyright 2018 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.springframework.data.microbenchmark.commons.convert;
|
||||
|
||||
import lombok.Data;
|
||||
|
||||
import java.util.Collections;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
|
||||
import org.openjdk.jmh.annotations.Benchmark;
|
||||
import org.springframework.core.convert.ConversionService;
|
||||
import org.springframework.core.convert.support.DefaultConversionService;
|
||||
import org.springframework.data.annotation.AccessType;
|
||||
import org.springframework.data.annotation.AccessType.Type;
|
||||
import org.springframework.data.convert.CustomConversions;
|
||||
import org.springframework.data.convert.CustomConversions.StoreConversions;
|
||||
import org.springframework.data.convert.EntityInstantiator;
|
||||
import org.springframework.data.convert.EntityInstantiators;
|
||||
import org.springframework.data.mapping.Association;
|
||||
import org.springframework.data.mapping.PersistentEntity;
|
||||
import org.springframework.data.mapping.PersistentProperty;
|
||||
import org.springframework.data.mapping.PersistentPropertyAccessor;
|
||||
import org.springframework.data.mapping.PreferredConstructor.Parameter;
|
||||
import org.springframework.data.mapping.context.AbstractMappingContext;
|
||||
import org.springframework.data.mapping.context.MappingContext;
|
||||
import org.springframework.data.mapping.model.AnnotationBasedPersistentProperty;
|
||||
import org.springframework.data.mapping.model.BasicPersistentEntity;
|
||||
import org.springframework.data.mapping.model.ConvertingPropertyAccessor;
|
||||
import org.springframework.data.mapping.model.ParameterValueProvider;
|
||||
import org.springframework.data.mapping.model.Property;
|
||||
import org.springframework.data.mapping.model.PropertyValueProvider;
|
||||
import org.springframework.data.mapping.model.SimpleTypeHolder;
|
||||
import org.springframework.data.microbenchmark.common.AbstractMicrobenchmark;
|
||||
import org.springframework.data.util.TypeInformation;
|
||||
|
||||
/**
|
||||
* Benchmark for a typical converter that reads entities.
|
||||
*
|
||||
* @author Mark Paluch
|
||||
*/
|
||||
public class TypicalEntityReaderBenchmark extends AbstractMicrobenchmark {
|
||||
|
||||
private final MyMappingContext context = new MyMappingContext();
|
||||
private final EntityInstantiators instantiators = new EntityInstantiators();
|
||||
private final ConversionService conversionService = DefaultConversionService.getSharedInstance();
|
||||
private final CustomConversions customConversions = new CustomConversions(StoreConversions.NONE,
|
||||
Collections.emptyList());
|
||||
|
||||
private final Map<String, Object> simpleEntityData = new HashMap<>();
|
||||
|
||||
/**
|
||||
* Prepare and pre-initialize to remove initialization overhead from measurement.
|
||||
*/
|
||||
public TypicalEntityReaderBenchmark() {
|
||||
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(SimpleEntity.class));
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(SimpleAccessibleEntityPropertyAccess.class));
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(SimpleAccessibleEntityFieldAccess.class));
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(SimpleEntityWithConstructor.class));
|
||||
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(MyDataClass.class));
|
||||
instantiators.getInstantiatorFor(context.getRequiredPersistentEntity(MyDataClassWithDefaulting.class));
|
||||
|
||||
simpleEntityData.put("firstname", "Walter");
|
||||
simpleEntityData.put("lastname", "White");
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object simpleEntityReflectivePropertyAccess() {
|
||||
return read(simpleEntityData, SimpleEntity.class, false);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object simpleEntityReflectivePropertyAccessWithCustomConversionRegistry() {
|
||||
return read(simpleEntityData, SimpleEntity.class, true);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object simpleEntityGeneratedPropertyAccess() {
|
||||
return read(simpleEntityData, SimpleAccessibleEntityFieldAccess.class, false);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object simpleEntityGeneratedFieldAccess() {
|
||||
return read(simpleEntityData, SimpleAccessibleEntityFieldAccess.class, false);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object simpleEntityConstructorArgsCreation() {
|
||||
return read(simpleEntityData, SimpleEntityWithConstructor.class, true);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object kotlinDataClass() {
|
||||
return read(simpleEntityData, MyDataClass.class, false);
|
||||
}
|
||||
|
||||
@Benchmark
|
||||
public Object kotlinDataClassWithDefaulting() {
|
||||
return read(simpleEntityData, MyDataClassWithDefaulting.class, false);
|
||||
}
|
||||
|
||||
static class SimpleEntity {
|
||||
|
||||
String firstname;
|
||||
String lastname;
|
||||
}
|
||||
|
||||
@AccessType(Type.PROPERTY)
|
||||
@Data
|
||||
public static class SimpleAccessibleEntityPropertyAccess {
|
||||
|
||||
String firstname;
|
||||
String lastname;
|
||||
}
|
||||
|
||||
@Data
|
||||
public static class SimpleAccessibleEntityFieldAccess {
|
||||
|
||||
public String firstname;
|
||||
public String lastname;
|
||||
}
|
||||
|
||||
static class SimpleEntityWithConstructor {
|
||||
|
||||
final String firstname;
|
||||
final String lastname;
|
||||
|
||||
public SimpleEntityWithConstructor(String firstname, String lastname) {
|
||||
this.firstname = firstname;
|
||||
this.lastname = lastname;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Typical code used to read entities in {@link org.springframework.data.convert.EntityReader}.
|
||||
*
|
||||
* @param data
|
||||
* @param classToRead
|
||||
* @param queryCustomConversions {@literal true} to call {@link CustomConversions#hasCustomReadTarget(Class, Class)}.
|
||||
* @return
|
||||
*/
|
||||
@SuppressWarnings("unchecked")
|
||||
private Object read(Map<String, Object> data, Class<?> classToRead, boolean queryCustomConversions) {
|
||||
|
||||
if (queryCustomConversions) {
|
||||
customConversions.hasCustomReadTarget(Map.class, classToRead);
|
||||
}
|
||||
|
||||
MyPersistentEntity<?> persistentEntity = context.getRequiredPersistentEntity(classToRead);
|
||||
|
||||
PropertyValueProvider<MyPersistentProperty> valueProvider = new PropertyValueProvider<MyPersistentProperty>() {
|
||||
|
||||
@Override
|
||||
public <T> T getPropertyValue(MyPersistentProperty property) {
|
||||
return (T) getValue(data, property.getName(), property.getType(), queryCustomConversions);
|
||||
}
|
||||
};
|
||||
|
||||
ParameterValueProvider<MyPersistentProperty> provider = new ParameterValueProvider<MyPersistentProperty>() {
|
||||
@Override
|
||||
public <T> T getParameterValue(Parameter<T, MyPersistentProperty> parameter) {
|
||||
return (T) getValue(data, parameter.getName(), parameter.getType().getType(), queryCustomConversions);
|
||||
}
|
||||
};
|
||||
|
||||
EntityInstantiator instantiator = instantiators.getInstantiatorFor(persistentEntity);
|
||||
Object instance = instantiator.createInstance(persistentEntity, provider);
|
||||
|
||||
PersistentPropertyAccessor<?> accessor = new ConvertingPropertyAccessor<>(
|
||||
persistentEntity.getPropertyAccessor(instance), conversionService);
|
||||
|
||||
readProperties(data, persistentEntity, valueProvider, accessor);
|
||||
|
||||
return accessor.getBean();
|
||||
}
|
||||
|
||||
private void readProperties(Map<String, Object> data, MyPersistentEntity<?> persistentEntity,
|
||||
PropertyValueProvider<MyPersistentProperty> valueProvider, PersistentPropertyAccessor<?> accessor) {
|
||||
|
||||
for (MyPersistentProperty prop : persistentEntity) {
|
||||
|
||||
if (prop.isAssociation() && !persistentEntity.isConstructorArgument(prop)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
// We skip the id property since it was already set
|
||||
|
||||
if (persistentEntity.isIdProperty(prop)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
if (persistentEntity.isConstructorArgument(prop) || !data.containsKey(persistentEntity.getName())) {
|
||||
continue;
|
||||
}
|
||||
|
||||
accessor.setProperty(prop, valueProvider.getPropertyValue(prop));
|
||||
}
|
||||
}
|
||||
|
||||
private Object getValue(Map<String, Object> data, String name, Class<?> type, boolean queryCustomConversions) {
|
||||
|
||||
Object value = data.get(name);
|
||||
|
||||
if (queryCustomConversions && value != null) {
|
||||
customConversions.hasCustomReadTarget(value.getClass(), type);
|
||||
}
|
||||
|
||||
return value;
|
||||
}
|
||||
|
||||
/**
|
||||
* Minimal {@link MappingContext}.
|
||||
*/
|
||||
static class MyMappingContext extends AbstractMappingContext<MyPersistentEntity<?>, MyPersistentProperty> {
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.mapping.context.AbstractMappingContext#createPersistentEntity(org.springframework.data.util.TypeInformation)
|
||||
*/
|
||||
@Override
|
||||
protected <T> MyPersistentEntity<?> createPersistentEntity(TypeInformation<T> typeInformation) {
|
||||
return new MyPersistentEntity<T>(typeInformation);
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.mapping.context.AbstractMappingContext#createPersistentProperty(org.springframework.data.mapping.model.Property, org.springframework.data.mapping.model.MutablePersistentEntity, org.springframework.data.mapping.model.SimpleTypeHolder)
|
||||
*/
|
||||
@Override
|
||||
protected MyPersistentProperty createPersistentProperty(Property property, MyPersistentEntity<?> owner,
|
||||
SimpleTypeHolder simpleTypeHolder) {
|
||||
return new MyPersistentProperty(property, owner, simpleTypeHolder);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Minimal {@link PersistentProperty}.
|
||||
*/
|
||||
static class MyPersistentProperty extends AnnotationBasedPersistentProperty<MyPersistentProperty> {
|
||||
|
||||
MyPersistentProperty(Property property, PersistentEntity<?, MyPersistentProperty> owner,
|
||||
SimpleTypeHolder simpleTypeHolder) {
|
||||
super(property, owner, simpleTypeHolder);
|
||||
}
|
||||
|
||||
/*
|
||||
* (non-Javadoc)
|
||||
* @see org.springframework.data.mapping.model.AbstractPersistentProperty#createAssociation()
|
||||
*/
|
||||
@Override
|
||||
protected Association<MyPersistentProperty> createAssociation() {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Minimal {@link PersistentEntity}.
|
||||
*
|
||||
* @param <T>
|
||||
*/
|
||||
static class MyPersistentEntity<T> extends BasicPersistentEntity<T, MyPersistentProperty> {
|
||||
|
||||
MyPersistentEntity(TypeInformation<T> information) {
|
||||
super(information);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,23 @@
|
||||
/*
|
||||
* Copyright 2018 the original author or authors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package org.springframework.data.microbenchmark.commons.convert
|
||||
|
||||
/**
|
||||
* @author Mark Paluch
|
||||
*/
|
||||
data class MyDataClass(val firstname: String, val lastname: String)
|
||||
|
||||
data class MyDataClassWithDefaulting(val firstname: String, val lastname: String, val foo: Int = 42)
|
||||
@@ -19,6 +19,7 @@
|
||||
|
||||
<modules>
|
||||
<module>support</module>
|
||||
<module>commons</module>
|
||||
<module>mongodb</module>
|
||||
</modules>
|
||||
|
||||
|
||||
Reference in New Issue
Block a user