[Moteur CQ] Je souhaite gérer des collections comme Stream ou .Net LINQ même dans Java 7.

Contexte

• Dans un environnement hérité, Java 8 ne peut pas être utilisé et Stream ne peut pas être utilisé en raison d'un middleware.
• Lors du formatage de la collection, l'instruction for est utilisée.

J'ai donc recherché Java7 capable d'effectuer des opérations de collecte intelligentes telles que Stream et LinQ. (Si vous connaissez un autre moyen d'éviter de tourner la déclaration for, veuillez me le faire savoir)

À propos de CQ Engine

Awesome Java: Great Java Framework Library Software Il a été introduit dans l'article ci-dessus.

CQEngine Dépôt officiel Github: CQengin

• CQEngine semble être une bibliothèque qui fournit des opérations de collecte ultra-rapides en définissant un index pour un modèle.
• Cette fois, nous vérifierons s'il peut être utilisé avec Java 7 au lieu de Stream
• L'index n'est pas vérifié car il s'écarte du sujet

License La licence de "CQ Engine" est "Apache License 2.0".

Comment écrire une opération de collecte dans CQEngine

Utilisation de la requête

• mérite
• Peut être de type sécurisé
• Meilleure lisibilité que tourner avec une instruction for
• Il semble qu'il sera plus rapide que Java 8 Stream en définissant Index * [question] Différence de performances dans Query vs collection standard lambda
• Inaptitude
• POJO ne peut pas être utilisé tel quel
• Apprendre à définir l'attribut semble coûter de l'argent
• Nécessite une méthode de description pour CQ Engine

// already defined Attribute in Car Class
// search brand-new AAACar
uery<Car> query1 =	and(
						endsWith(Car.NAME, "AAACar"),
						equal(Car.DISCREPRION, "brandNew")
					);
ResultSet<car> resultSet = cars.retrieve(query1));

Utilisation des dialectes CQN

• mérite
• Applicable à POJO
• Meilleure lisibilité que tourner avec une phrase pour ...?
• Inaptitude
• Pas de type sûr
• Nécessite une méthode de description pour CQ Engine *

import static com.googlecode.cqengine.codegen.AttributeBytecodeGenerator.*;

// generate Attribute
CQNParser<Car> parser = CQNParser.forPojoWithAttributes(Car.class, createAttributes(Car.class));
// search brand-new AAACar
ResultSet<Car> results = parser.retrieve(cars,
								"and("
									+ "equal(\"name\",\"AAACar\"),"
									+ "equal(\"discription\", \"brandNew\")"
								+ " )");

Utilisation des dialectes SQL

• mérite
• Applicable à POJO
• Peut être utilisé par toute personne qui comprend SQL (il peut y avoir des règles légèrement différentes)
• Inaptitude
• Pas de type sûr

// generate Attribute
SQLParser<Car> parser = SQLParser.forPojoWithAttributes(Car.class, createAttributes(Car.class));

// search brand-new AAACar
ResultSet<Car> results = parser.retrieve(cars,
								"SELECT * FROM cars " +
								"WHERE (" +
									" name = 'AAACar' " +
									" AND discription = 'brandNew')"
								);

for (Car car : results ) {
	System.out.println(car.toString());
}

Vérification

Maven ~~ La dernière version pour le moment est incluse ~~ Insérez "2.12.4" qui peut être utilisé avec Java 7.

<dependency>
  <groupId>com.googlecode.cqengine</groupId>
  <artifactId>cqengine</artifactId>
  <version>2.12.4</version>
</dependency>

En regardant les notes de publication, il semble que Java 7 et les versions antérieures soient exclus de la Ver3. CQEngine Release Notes

Préparation des données pour la comparaison

Préparer un modèle pour la collection

J'ai fait une voiture. * @Data est décrit car lombok est utilisé.

@Data
public class Car {
	private int carId;
	private String name;
	private String discription;
	private List<String> features;
}

Comparaison

Java pour instruction

// create car collection
Set<Car> cars = new HashSet<>();
cars.add( Car.builder().carId(0).name("AAACar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );
cars.add( Car.builder().carId(1).name("BBBCar").discription("used").features( Arrays.asList("spare tyre", "radio")).build() );
cars.add( Car.builder().carId(2).name("CCCCar").discription("used").features( Arrays.asList("radio", "sunroof")).build() );
cars.add( Car.builder().carId(3).name("DDDCar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );
cars.add( Car.builder().carId(4).name("AAACar").discription("used").features( Arrays.asList("radio", "sunroof")).build() );
cars.add( Car.builder().carId(5).name("BBBCar").discription("brandNew").features( Arrays.asList("spare tyre", "radio")).build() );
cars.add( Car.builder().carId(6).name("CCCCar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );
cars.add( Car.builder().carId(7).name("DDDCar").discription("used").features( Arrays.asList("radio", "sunroof")).build() );
cars.add( Car.builder().carId(8).name("AAACar").discription("used").features( Arrays.asList("spare tyre", "sunroof")).build() );
cars.add( Car.builder().carId(9).name("BBBCar").discription("used").features( Arrays.asList("spare tyre", "radio")).build() );
cars.add( Car.builder().carId(10).name("CCCCar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );

// search brand-new AAACar
Set<Car> results = new HashSet<>();
for (Car car : cars) {
	if ( Objects.equals(car.getName(), "AAACar")
			&& Objects.equals(car.getDiscription(), "brandNew") ) {
		results.add(car);
	}
}

for (Car car : results ) {
	System.out.println(car.toString()); // => Car(carId=0, name=AAACar, discription=brandNew, features=[spare tyre, sunroof])
}

Utiliser CQN (CQ Engine Native)

Puisqu'il est destiné à être utilisé comme un substitut à Stream, nous le vérifierons avec une politique de ne pas ajouter d'attribut à POJO. Essayez d'utiliser la notation CQN sans attribut. Generate attributes from private class fields Il semble difficile d'obtenir le champ privé de POJO, j'ai donc défini le paramètre pour utiliser getter dans createAttributes.

// generate Attribute
CQNParser<Car> parser = CQNParser.forPojoWithAttributes(Car.class, createAttributes(Car.class, MemberFilters.GETTER_METHODS_ONLY));

// create car collection
IndexedCollection<Car> cars = new ConcurrentIndexedCollection<>();
cars.add( Car.builder().carId(0).name("AAACar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );
//(réduction)
cars.add( Car.builder().carId(10).name("CCCCar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );

// search brand-new AAACar
ResultSet<Car> results = parser.retrieve(cars,
								"and("
									+ "equal(\"getName\",\"AAACar\"),"
									+ "equal(\"getDiscription\", \"brandNew\")"
								+ " )");

for (Car car : results ) {
	System.out.println(car.toString());   // => Car(carId=0, name=AAACar, discription=brandNew, features=[spare tyre, sunroof])
}

Flux Java 8

// create car collection
Set<Car> cars = new HashSet<>();
cars.add( Car.builder().carId(0).name("AAACar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );
//(réduction)
cars.add( Car.builder().carId(10).name("CCCCar").discription("brandNew").features( Arrays.asList("spare tyre", "sunroof")).build() );

// search brand-new AAACar
Set<Car> results =  cars.stream()
						.filter(car -> Objects.equals(car.getName(), "AAACar")
								&& Objects.equals(car.getDiscription(), "brandNew") )
						.collect(Collectors.toSet());

for (Car car : results ) {
	System.out.println(car.toString());
}

Comment utiliser CQ Engine avec Java 7 ou une version antérieure

Étant donné que Java7 n'est pas pris en charge pour CQEngine Ver3 et supérieur, l'erreur suivante se produit.

 Unsupported major.minor version 52.0

Conclusion

• Si vous ne vous souciez pas de la sécurité des types, la lisibilité peut être améliorée.
• Il est nécessaire d'ajouter quelques efforts pour l'utiliser pour le type safe (définir l'attribut dans POJO)
• La dernière version ne peut pas être utilisée avec Java 7
• Je ne l'ai pas trouvé si attrayant en termes de l'utiliser comme un substitut à Stream en Java7 (ce n'était pas à l'origine une telle bibliothèque). N'oubliez pas en tant que candidat lorsque vous souhaitez traiter une grande quantité de données à grande vitesse

Utilisez Stream plus simplement avec Java7-

Lightweight-Stream-API-I want to use Stream API with Java 6 and 7 Cela semble être une bibliothèque qui peut être utilisée comme Stream tel quel Lors de la migration vers Java8, cette bibliothèque est utilisée avant la migration et le code après la migration est Java8 Stream. Je pensais que je devais faire attention à ne pas entrer dans une situation chaotique Cette fois, j'ai décidé d'étudier du point de vue de savoir si CQ Engine peut dépasser la bibliothèque standard pour Java 8 et versions ultérieures. Donc, à l'avenir, j'aimerais évaluer les performances de CQ Engine dans le traitement de grandes quantités de données.

Utiliser avec une grande quantité de données

(J'écrirai dans un autre article) Il est difficile de préparer les données, alors recherchez une API qui peut obtenir beaucoup de données. Peut être utilisé par des particuliers! Liste des API recommandées