Neptune unterstützt nicht mehrere gleichzeitige Abfragen in einer Transaktion

Obwohl der Bolt-Treiber selbst gleichzeitige Abfragen in einer Transaktion zulässt, unterstützt Neptune nicht mehrere Abfragen in einer gleichzeitig laufenden Transaktion. Stattdessen verlangt Neptune, dass mehrere Abfragen in einer Transaktion nacheinander ausgeführt werden und dass die Ergebnisse jeder Abfrage vollständig verarbeitet werden, bevor die nächste Abfrage initiiert wird.

Das folgende Beispiel zeigt, wie Bolt verwendet wird, um mehrere Abfragen nacheinander in einer Transaktion auszuführen, so dass die Ergebnisse jeder Abfrage vollständig verbraucht werden, bevor die nächste beginnt:

final String query = "MATCH (n) RETURN n";

try (Driver driver = getDriver(HOST_BOLT, getDefaultConfig())) {
  try (Session session = driver.session(readSessionConfig)) {
    try (Transaction trx = session.beginTransaction()) {
      final Result res_1 = trx.run(query);
      Assert.assertEquals(10000, res_1.list().size());
      final Result res_2 = trx.run(query);
      Assert.assertEquals(10000, res_2.list().size());
    }
  }
}