Skip to content
Snippets Groups Projects
Commit f4d29ea0 authored by Rustam Lotsmanenko (EPAM)'s avatar Rustam Lotsmanenko (EPAM)
Browse files

Revert "impl batch"

This reverts commit 87aa8bc4.
parent 87aa8bc4
No related branches found
No related tags found
No related merge requests found
Pipeline #284334 canceled
......@@ -21,7 +21,7 @@
<dependency>
<groupId>org.opengroup.osdu</groupId>
<artifactId>os-osm-core</artifactId>
<version>0.27.0-SNAPSHOT-BATCH</version>
<version>0.27.0-rc3</version>
<scope>provided</scope>
</dependency>
<dependency>
......
......@@ -31,7 +31,6 @@ import com.google.cloud.datastore.KeyFactory;
import com.google.cloud.datastore.ProjectionEntity;
import com.google.cloud.datastore.Query;
import com.google.cloud.datastore.QueryResults;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Objects;
......@@ -88,18 +87,6 @@ public class DsQueryRunner implements QueryRunner, TransactionProvider {
}
}
@Override
public <E> void create(Destination destination, E... input) throws TranslatorException {
List<SetQuery<E>> queries = Arrays.stream(input).map(i -> new SetQuery<>(i, destination)).toList();
DatastoreReaderWriter datastore = getDatastore(destination);
DsTranslator dsTranslator = translator.getObject();
FullEntity<?>[] entities = new FullEntity[queries.size()];
for (int i = 0; i < entities.length; i++) {
entities[i] = dsTranslator.externalizeEntity(queries.get(i));
}
datastore.add(entities);
}
private <OET> OET upsert(SetQuery<OET> query, boolean returnUpdated) {
final DatastoreReaderWriter datastore = getDatastore(query);
final DsTranslator dsTranslator = translator.getObject();
......@@ -112,18 +99,6 @@ public class DsQueryRunner implements QueryRunner, TransactionProvider {
}
}
@Override
public <E> void upsert(Destination destination, E... input) throws TranslatorException {
List<SetQuery<E>> queries = Arrays.stream(input).map(i -> new SetQuery<>(i, destination)).toList();
DatastoreReaderWriter datastore = getDatastore(destination);
DsTranslator dsTranslator = translator.getObject();
FullEntity<?>[] entities = new FullEntity[queries.size()];
for (int i = 0; i < entities.length; i++) {
entities[i] = dsTranslator.externalizeEntity(queries.get(i));
}
datastore.put(entities);
}
@Override
public <E> void create(SetQuery<E> query) throws TranslatorException {
create(query, false);
......
......@@ -29,7 +29,7 @@
<dependency>
<groupId>org.opengroup.osdu</groupId>
<artifactId>os-osm-test-core</artifactId>
<version>0.27.0-SNAPSHOT-BATCH</version>
<version>0.27.0-rc3</version>
</dependency>
</dependencies>
......
......@@ -42,7 +42,7 @@ class DsSchemaQueryIT extends SchemaTestBed {
@Test
void simpleSchemaUpsertTest() {
context.upsertAndGet(destination, gages.get(0));
context.upsertAndGet(gages.get(0), destination);
GetQuery<Schema> q = new GetQuery<>(Schema.class, destination,
eq("kind", gages.get(0).getKind()));
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment