[CQ Engine] Ich möchte Sammlungen wie Stream oder .Net LINQ auch in Java 7 verarbeiten.

Hintergrund

• In einer älteren Umgebung kann Java 8 nicht verwendet werden und Stream kann aufgrund von Middleware nicht verwendet werden.
• Beim Formatieren der Sammlung wird die for-Anweisung verwendet.

Deshalb habe ich nach Java7 gesucht, das intelligente Erfassungsvorgänge wie Stream und LinQ ausführen kann. (Wenn Sie einen anderen Weg kennen, um das Umdrehen der for-Anweisung zu vermeiden, lassen Sie es mich bitte wissen.)

Über die CQ Engine

Awesome Java: Großartige Java Framework Library-Software Es wurde im obigen Artikel vorgestellt.

CQEngine Offizielles Repository Github: CQengin

• CQEngine scheint eine Bibliothek zu sein, die ultraschnelle Erfassungsvorgänge bietet, indem ein Index für ein Modell festgelegt wird.
• Dieses Mal werden wir überprüfen, ob es mit Java 7 anstelle von Stream verwendet werden kann
• Der Index wird nicht überprüft, da er vom Betreff abweicht

License Die Lizenz von "CQ Engine" lautet "Apache License 2.0".

So schreiben Sie eine Erfassungsoperation in CQEngine

Verwendung der Abfrage

• Verdienst
• Kann typsicher sein
• Höhere Lesbarkeit als beim Drehen mit einer for-Anweisung
• Es scheint, dass es schneller als Java 8 Stream sein wird, wenn Index festgelegt wird. * [Frage] Leistungsunterschied zwischen Abfrage und Standardauflistung Lambda
• Fehler
• POJO kann nicht so verwendet werden, wie es ist
• Das Festlegen des Attributs scheint Geld zu kosten
• Erfordert eine Beschreibungsmethode für 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));

Verwenden von CQN-Dialekten

• Verdienst
• Gilt für POJO
• Höhere Lesbarkeit als mit einem for-Satz drehen ...?
• Fehler
• Nicht sicher eingeben
• Erfordert eine Beschreibungsmethode für 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\")"
								+ " )");

SQL-Dialekte verwenden

• Verdienst
• Gilt für POJO
• Kann von jedem verwendet werden, der SQL versteht (es kann leicht abweichende Regeln geben)
• Fehler
• Nicht sicher eingeben

// 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());
}

Überprüfung

Maven ~~ Die aktuellste Version ist enthalten ~~ Fügen Sie "2.12.4" ein, das mit Java 7 verwendet werden kann.

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

In den Versionshinweisen scheint Java 7 und niedriger von Ver3 ausgeschlossen zu sein. CQEngine Release Notes

Daten zum Vergleich vorbereiten

Modell für die Sammlung vorbereiten

Ich habe ein Auto gemacht. * @Data wird beschrieben, weil Lombok verwendet wird.

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

Vergleich

Java für Anweisung

// 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])
}

Verwenden Sie CQN (CQ Engine Native)

Da es als Ersatz für Stream verwendet werden soll, überprüfen wir es mit der Richtlinie, POJO kein Attribut hinzuzufügen. Versuchen Sie, die CQN-Notation ohne Attribut zu verwenden. Generate attributes from private class fields Es scheint schwierig zu sein, das private Feld von POJO abzurufen, daher habe ich die Einstellung so festgelegt, dass in createAttributes getter verwendet wird.

// 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() );
//(Kürzung)
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])
}

Java 8 Stream

// 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() );
//(Kürzung)
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());
}

Verwendung von CQ Engine mit Java 7 oder niedriger

Da Java7 für CQEngine Ver3 und höher nicht unterstützt wird, tritt der folgende Fehler auf.

 Unsupported major.minor version 52.0

Fazit

• Wenn Sie sich nicht um die Typensicherheit kümmern, kann die Lesbarkeit verbessert werden.
• Es ist notwendig, einige Anstrengungen zu unternehmen, um es für type safe zu verwenden (Attribut in POJO festlegen).
• Die neueste Version kann nicht mit Java 7 verwendet werden
• Ich fand es nicht so attraktiv, es als Ersatz für Stream in Java7 zu verwenden (es war ursprünglich keine solche Bibliothek). Denken Sie als Kandidat daran, wenn Sie eine große Datenmenge mit hoher Geschwindigkeit verarbeiten möchten

Verwenden Sie Stream einfacher mit Java7-

Lightweight-Stream-API-Ich möchte die Stream-API mit Java 6 und 7 verwenden Dies scheint eine Bibliothek zu sein, die wie Stream verwendet werden kann Bei der Migration auf Java8 wird diese Bibliothek vor der Migration verwendet, und der Code nach der Migration lautet Java8 Stream. Ich dachte, ich müsste vorsichtig sein, um nicht in eine chaotische Situation zu geraten Dieses Mal habe ich mich entschlossen zu untersuchen, ob CQ Engine die Standardbibliothek für Java 8 und höher überschreiten kann. Daher möchte ich in Zukunft die Leistung von CQ Engine bei der Verarbeitung großer Datenmengen bewerten.

Verwendung mit einer großen Datenmenge

(Ich werde in einem anderen Artikel schreiben) Es ist schwierig, die Daten vorzubereiten. Suchen Sie daher nach einer API, die viele Daten abrufen kann. Kann von Einzelpersonen verwendet werden! Empfohlene API-Liste