Coverage Summary for Class: TestBatchNormalUpdateDateTimeArrays (org.umlg.sqlg.test.batch)
| Class |
Class, %
|
Method, %
|
Branch, %
|
Line, %
|
| TestBatchNormalUpdateDateTimeArrays |
100%
(1/1)
|
100%
(15/15)
|
57.1%
(8/14)
|
100%
(183/183)
|
package org.umlg.sqlg.test.batch;
import org.apache.tinkerpop.gremlin.structure.T;
import org.apache.tinkerpop.gremlin.structure.Vertex;
import org.junit.*;
import org.umlg.sqlg.structure.SqlgGraph;
import org.umlg.sqlg.test.BaseTest;
import java.time.*;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.List;
/**
* Date: 2017/01/26
* Time: 12:22 PM
*/
public class TestBatchNormalUpdateDateTimeArrays extends BaseTest {
@BeforeClass
public static void beforeClass() {
BaseTest.beforeClass();
if (isPostgres()) {
configuration.addProperty("distributed", true);
}
}
@Before
public void beforeTest() {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsBatchMode());
}
@Test
public void testUpdateLocalDateTimeArray() throws InterruptedException {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsLocalDateTimeArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
LocalDateTime[] localDateTimeArray = new LocalDateTime[]{LocalDateTime.now().truncatedTo(ChronoUnit.SECONDS), LocalDateTime.now().truncatedTo(ChronoUnit.SECONDS)};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "localDateTimeArray1", localDateTimeArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "localDateTimeArray2", localDateTimeArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "localDateTimeArray3", localDateTimeArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
LocalDateTime[] localDateTimeArrayAgain = new LocalDateTime[]{
LocalDateTime.now().plusDays(1).truncatedTo(ChronoUnit.SECONDS),
LocalDateTime.now().plusDays(2).truncatedTo(ChronoUnit.SECONDS)
};
a1.property("localDateTimeArray1", localDateTimeArrayAgain);
a2.property("localDateTimeArray2", localDateTimeArrayAgain);
a3.property("localDateTimeArray3", localDateTimeArrayAgain);
this.sqlgGraph.tx().commit();
testUpdateLocalDateTimeArray_assert(this.sqlgGraph, a1, a2, a3, localDateTimeArrayAgain);
if (this.sqlgGraph1 != null) {
Thread.sleep(SLEEP_TIME);
testUpdateLocalDateTimeArray_assert(this.sqlgGraph1, a1, a2, a3, localDateTimeArrayAgain);
}
}
private void testUpdateLocalDateTimeArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, LocalDateTime[] localDateTimeArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
Assert.assertArrayEquals(localDateTimeArrayAgain, a1.value("localDateTimeArray1"));
Assert.assertNull(a1.property("localDateTimeArray2").value());
Assert.assertNull(a1.property("localDateTimeArray3").value());
Assert.assertNull(a2.property("localDateTimeArray1").value());
Assert.assertArrayEquals(localDateTimeArrayAgain, a2.value("localDateTimeArray2"));
Assert.assertNull(a2.property("localDateTimeArray3").value());
Assert.assertNull(a3.property("localDateTimeArray1").value());
Assert.assertNull(a3.property("localDateTimeArray2").value());
Assert.assertArrayEquals(localDateTimeArrayAgain, a3.value("localDateTimeArray3"));
}
@Test
public void testUpdateLocalDateArray() throws InterruptedException {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsLocalDateArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
LocalDate[] localDateArray = new LocalDate[]{LocalDate.now(), LocalDate.now()};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "localDateArray1", localDateArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "localDateArray2", localDateArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "localDateArray3", localDateArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
LocalDate[] localDateArrayAgain = new LocalDate[]{LocalDate.now().plusDays(1), LocalDate.now().plusDays(2)};
a1.property("localDateArray1", localDateArrayAgain);
a2.property("localDateArray2", localDateArrayAgain);
a3.property("localDateArray3", localDateArrayAgain);
this.sqlgGraph.tx().commit();
testUpdateLocalDateArray_assert(this.sqlgGraph, a1, a2, a3, localDateArrayAgain);
if (this.sqlgGraph1 != null) {
Thread.sleep(SLEEP_TIME);
testUpdateLocalDateArray_assert(this.sqlgGraph1, a1, a2, a3, localDateArrayAgain);
}
}
private void testUpdateLocalDateArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, LocalDate[] localDateArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
Assert.assertArrayEquals(localDateArrayAgain, a1.value("localDateArray1"));
Assert.assertNull(a1.property("localDateArray2").value());
Assert.assertNull(a1.property("localDateArray3").value());
Assert.assertNull(a2.property("localDateArray1").value());
Assert.assertArrayEquals(localDateArrayAgain, a2.value("localDateArray2"));
Assert.assertNull(a2.property("localDateArray3").value());
Assert.assertNull(a3.property("localDateArray1").value());
Assert.assertNull(a3.property("localDateArray2").value());
Assert.assertArrayEquals(localDateArrayAgain, a3.value("localDateArray3"));
}
@Test
public void testUpdateLocalTimeArray() {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsLocalTimeArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
LocalTime[] localTimeArray = new LocalTime[]{LocalTime.now(), LocalTime.now()};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "localTimeArray1", localTimeArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "localTimeArray2", localTimeArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "localTimeArray3", localTimeArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
LocalTime[] localTimeArrayAgain = new LocalTime[]{LocalTime.now().plusHours(1), LocalTime.now().plusHours(2)};
a1.property("localTimeArray1", localTimeArrayAgain);
a2.property("localTimeArray2", localTimeArrayAgain);
a3.property("localTimeArray3", localTimeArrayAgain);
this.sqlgGraph.tx().commit();
testUpdateLocalTimeArray_assert(this.sqlgGraph, a1, a2, a3, localTimeArrayAgain);
}
private void testUpdateLocalTimeArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, LocalTime[] localTimeArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
List<LocalTime> localTimes1 = new ArrayList<>();
for (LocalTime localTime : localTimeArrayAgain) {
localTimes1.add(localTime.minusNanos(localTime.getNano()));
}
Assert.assertArrayEquals(localTimes1.toArray(), a1.value("localTimeArray1"));
Assert.assertNull(a1.property("localTimeArray2").value());
Assert.assertNull(a1.property("localTimeArray3").value());
Assert.assertNull(a2.property("localTimeArray1").value());
Assert.assertArrayEquals(localTimes1.toArray(), a2.value("localTimeArray2"));
Assert.assertNull(a2.property("localTimeArray3").value());
Assert.assertNull(a3.property("localTimeArray1").value());
Assert.assertNull(a3.property("localTimeArray2").value());
Assert.assertArrayEquals(localTimes1.toArray(), a3.value("localTimeArray3"));
}
@Test
public void testUpdateZonedDateTimeArray() throws InterruptedException {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsZonedDateTimeArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
ZonedDateTime[] zonedDateTimeArray = new ZonedDateTime[]{ZonedDateTime.now(), ZonedDateTime.now().truncatedTo(ChronoUnit.SECONDS).truncatedTo(ChronoUnit.SECONDS)};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "zonedDateTimeArray1", zonedDateTimeArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "zonedDateTimeArray2", zonedDateTimeArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "zonedDateTimeArray3", zonedDateTimeArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
ZonedDateTime[] zonedDateTimeArrayAgain = new ZonedDateTime[]{
ZonedDateTime.now().plusHours(1).truncatedTo(ChronoUnit.SECONDS),
ZonedDateTime.now().plusHours(2).truncatedTo(ChronoUnit.SECONDS)
};
a1.property("zonedDateTimeArray1", zonedDateTimeArrayAgain);
a2.property("zonedDateTimeArray2", zonedDateTimeArrayAgain);
a3.property("zonedDateTimeArray3", zonedDateTimeArrayAgain);
this.sqlgGraph.tx().commit();
testUpdateZonedDateTimeArray_assert(this.sqlgGraph, a1, a2, a3, zonedDateTimeArrayAgain);
if (this.sqlgGraph1 != null) {
Thread.sleep(SLEEP_TIME);
testUpdateZonedDateTimeArray_assert(this.sqlgGraph1, a1, a2, a3, zonedDateTimeArrayAgain);
}
}
private void testUpdateZonedDateTimeArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, ZonedDateTime[] zonedDateTimeArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
Assert.assertArrayEquals(zonedDateTimeArrayAgain, a1.value("zonedDateTimeArray1"));
Assert.assertNull(a1.property("zonedDateTimeArray2").value());
Assert.assertNull(a1.property("zonedDateTimeArray3").value());
Assert.assertNull(a2.property("zonedDateTimeArray1").value());
Assert.assertArrayEquals(zonedDateTimeArrayAgain, a2.value("zonedDateTimeArray2"));
Assert.assertNull(a2.property("zonedDateTimeArray3").value());
Assert.assertNull(a3.property("zonedDateTimeArray1").value());
Assert.assertNull(a3.property("zonedDateTimeArray2").value());
Assert.assertArrayEquals(zonedDateTimeArrayAgain, a3.value("zonedDateTimeArray3"));
}
@Test
public void testUpdateDurationArray() throws InterruptedException {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsDurationArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
Duration[] durationArray = new Duration[]{Duration.ofDays(1), Duration.ofDays(1)};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "durationArray1", durationArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "durationArray2", durationArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "durationArray3", durationArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
Duration[] durationArrayAgain = new Duration[]{Duration.ofDays(3), Duration.ofDays(4)};
a1.property("durationArray1", durationArrayAgain);
a2.property("durationArray2", durationArrayAgain);
a3.property("durationArray3", durationArrayAgain);
this.sqlgGraph.tx().commit();
testUpdateDurationArray_assert(this.sqlgGraph, a1, a2, a3, durationArrayAgain);
if (this.sqlgGraph1 != null) {
Thread.sleep(SLEEP_TIME);
testUpdateDurationArray_assert(this.sqlgGraph1, a1, a2, a3, durationArrayAgain);
}
}
private void testUpdateDurationArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, Duration[] durationArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
Assert.assertArrayEquals(durationArrayAgain, a1.value("durationArray1"));
Assert.assertNull(a1.property("durationArray2").value());
Assert.assertNull(a1.property("durationArray3").value());
Assert.assertNull(a2.property("durationArray1").value());
Assert.assertArrayEquals(durationArrayAgain, a2.value("durationArray2"));
Assert.assertNull(a2.property("durationArray3").value());
Assert.assertNull(a3.property("durationArray1").value());
Assert.assertNull(a3.property("durationArray2").value());
Assert.assertArrayEquals(durationArrayAgain, a3.value("durationArray3"));
}
@Test
public void testUpdatePeriodArray() throws InterruptedException {
Assume.assumeTrue(this.sqlgGraph.getSqlDialect().supportsPeriodArrayValues());
this.sqlgGraph.tx().normalBatchModeOn();
Period[] periodArray = new Period[]{Period.of(1, 1, 1), Period.of(1, 1, 1)};
Vertex a1 = this.sqlgGraph.addVertex(T.label, "A", "periodArray1", periodArray);
Vertex a2 = this.sqlgGraph.addVertex(T.label, "A", "periodArray2", periodArray);
Vertex a3 = this.sqlgGraph.addVertex(T.label, "A", "periodArray3", periodArray);
this.sqlgGraph.tx().commit();
this.sqlgGraph.tx().normalBatchModeOn();
Period[] periodArrayAgain = new Period[]{Period.of(2, 2, 2), Period.of(4, 4, 4)};
a1.property("periodArray1", periodArrayAgain);
a2.property("periodArray2", periodArrayAgain);
a3.property("periodArray3", periodArrayAgain);
this.sqlgGraph.tx().commit();
testUpdatePeriodArray_assert(this.sqlgGraph, a1, a2, a3, periodArrayAgain);
if (this.sqlgGraph1 != null) {
Thread.sleep(SLEEP_TIME);
testUpdatePeriodArray_assert(this.sqlgGraph1, a1, a2, a3, periodArrayAgain);
}
}
private void testUpdatePeriodArray_assert(SqlgGraph sqlgGraph, Vertex a1, Vertex a2, Vertex a3, Period[] periodArrayAgain) {
a1 = sqlgGraph.traversal().V(a1.id()).next();
a2 = sqlgGraph.traversal().V(a2.id()).next();
a3 = sqlgGraph.traversal().V(a3.id()).next();
Assert.assertArrayEquals(periodArrayAgain, a1.value("periodArray1"));
Assert.assertNull(a1.property("periodArray2").value());
Assert.assertNull(a1.property("periodArray3").value());
Assert.assertNull(a2.property("periodArray1").value());
Assert.assertArrayEquals(periodArrayAgain, a2.value("periodArray2"));
Assert.assertNull(a2.property("periodArray3").value());
Assert.assertNull(a3.property("periodArray1").value());
Assert.assertNull(a3.property("periodArray2").value());
Assert.assertArrayEquals(periodArrayAgain, a3.value("periodArray3"));
}
}