Skip to content

Commit 1929dc2

Browse files
author
mpv1989
committed
Update view api
1 parent 10880d8 commit 1929dc2

File tree

5 files changed

+30
-39
lines changed

5 files changed

+30
-39
lines changed

src/main/java/com/arangodb/internal/velocypack/VPackDriverModule.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,11 @@
3737
import com.arangodb.entity.ViewType;
3838
import com.arangodb.entity.arangosearch.ArangoSearchProperties;
3939
import com.arangodb.entity.arangosearch.ArangoSearchPropertiesEntity;
40-
import com.arangodb.entity.arangosearch.ConsolidationPolicy;
4140
import com.arangodb.entity.arangosearch.ConsolidateType;
41+
import com.arangodb.entity.arangosearch.ConsolidationPolicy;
4242
import com.arangodb.internal.velocystream.internal.AuthenticationRequest;
4343
import com.arangodb.model.TraversalOptions;
44+
import com.arangodb.model.arangosearch.ArangoSearchPropertiesOptions;
4445
import com.arangodb.velocypack.VPackFieldNamingStrategy;
4546
import com.arangodb.velocypack.VPackModule;
4647
import com.arangodb.velocypack.VPackParserModule;
@@ -77,6 +78,8 @@ public String translateName(final Field field) {
7778
context.registerSerializer(Permissions.class, VPackSerializers.PERMISSIONS);
7879
context.registerSerializer(ReplicationFactor.class, VPackSerializers.REPLICATION_FACTOR);
7980
context.registerSerializer(ViewType.class, VPackSerializers.VIEW_TYPE);
81+
context.registerSerializer(ArangoSearchPropertiesOptions.class,
82+
VPackSerializers.ARANGO_SEARCH_PROPERTIES_OPTIONS);
8083
context.registerSerializer(ArangoSearchProperties.class, VPackSerializers.ARANGO_SEARCH_PROPERTIES);
8184
context.registerSerializer(ConsolidateType.class, VPackSerializers.CONSOLIDATE_TYPE);
8285

src/main/java/com/arangodb/internal/velocypack/VPackSerializers.java

Lines changed: 14 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
import com.arangodb.internal.velocystream.internal.AuthenticationRequest;
4242
import com.arangodb.model.TraversalOptions;
4343
import com.arangodb.model.TraversalOptions.Order;
44+
import com.arangodb.model.arangosearch.ArangoSearchPropertiesOptions;
4445
import com.arangodb.velocypack.VPackBuilder;
4546
import com.arangodb.velocypack.VPackSerializationContext;
4647
import com.arangodb.velocypack.VPackSerializer;
@@ -208,17 +209,26 @@ public void serialize(
208209
}
209210
};
210211

212+
public static final VPackSerializer<ArangoSearchPropertiesOptions> ARANGO_SEARCH_PROPERTIES_OPTIONS = new VPackSerializer<ArangoSearchPropertiesOptions>() {
213+
@Override
214+
public void serialize(
215+
final VPackBuilder builder,
216+
final String attribute,
217+
final ArangoSearchPropertiesOptions value,
218+
final VPackSerializationContext context) throws VPackException {
219+
builder.add(ValueType.OBJECT);
220+
context.serialize(builder, attribute, value.getProperties());
221+
builder.close();
222+
}
223+
};
224+
211225
public static final VPackSerializer<ArangoSearchProperties> ARANGO_SEARCH_PROPERTIES = new VPackSerializer<ArangoSearchProperties>() {
212226
@Override
213227
public void serialize(
214228
final VPackBuilder builder,
215229
final String attribute,
216230
final ArangoSearchProperties value,
217231
final VPackSerializationContext context) throws VPackException {
218-
final boolean wrap = !attribute.startsWith("_");
219-
if (wrap) {
220-
builder.add("properties", ValueType.OBJECT);
221-
}
222232
final Long consolidationIntervalMsec = value.getConsolidationIntervalMsec();
223233
if (consolidationIntervalMsec != null) {
224234
builder.add("consolidationIntervalMsec", consolidationIntervalMsec);
@@ -259,9 +269,6 @@ public void serialize(
259269
}
260270
builder.close();
261271
}
262-
if (wrap) {
263-
builder.close();
264-
}
265272
}
266273
};
267274

src/main/java/com/arangodb/model/arangosearch/ArangoSearchPropertiesOptions.java

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,15 @@
3030
*/
3131
public class ArangoSearchPropertiesOptions {
3232

33-
private final ArangoSearchProperties _properties;
33+
private final ArangoSearchProperties properties;
3434

3535
public ArangoSearchPropertiesOptions() {
3636
super();
37-
_properties = new ArangoSearchProperties();
37+
properties = new ArangoSearchProperties();
38+
}
39+
40+
public ArangoSearchProperties getProperties() {
41+
return properties;
3842
}
3943

4044
/**
@@ -47,7 +51,7 @@ public ArangoSearchPropertiesOptions() {
4751
* @return options
4852
*/
4953
public ArangoSearchPropertiesOptions consolidationIntervalMsec(final Long consolidationIntervalMsec) {
50-
_properties.setConsolidationIntervalMsec(consolidationIntervalMsec);
54+
properties.setConsolidationIntervalMsec(consolidationIntervalMsec);
5155
return this;
5256
}
5357

@@ -61,7 +65,7 @@ public ArangoSearchPropertiesOptions consolidationIntervalMsec(final Long consol
6165
* @return options
6266
*/
6367
public ArangoSearchPropertiesOptions cleanupIntervalStep(final Long cleanupIntervalStep) {
64-
_properties.setCleanupIntervalStep(cleanupIntervalStep);
68+
properties.setCleanupIntervalStep(cleanupIntervalStep);
6569
return this;
6670
}
6771

@@ -71,7 +75,7 @@ public ArangoSearchPropertiesOptions cleanupIntervalStep(final Long cleanupInter
7175
* @return options
7276
*/
7377
public ArangoSearchPropertiesOptions consolidationPolicy(final ConsolidationPolicy consolidationPolicy) {
74-
_properties.setConsolidationPolicy(consolidationPolicy);
78+
properties.setConsolidationPolicy(consolidationPolicy);
7579
return this;
7680
}
7781

@@ -81,7 +85,7 @@ public ArangoSearchPropertiesOptions consolidationPolicy(final ConsolidationPoli
8185
* @return options
8286
*/
8387
public ArangoSearchPropertiesOptions link(final CollectionLink... links) {
84-
_properties.addLink(links);
88+
properties.addLink(links);
8589
return this;
8690
}
8791

src/test/java/com/arangodb/ArangoDatabaseTest.java

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,6 @@
5050
import com.arangodb.entity.AqlExecutionExplainEntity.ExecutionPlan;
5151
import com.arangodb.entity.AqlFunctionEntity;
5252
import com.arangodb.entity.AqlParseEntity;
53-
import com.arangodb.entity.AqlParseEntity.AstNode;
5453
import com.arangodb.entity.ArangoDBVersion;
5554
import com.arangodb.entity.ArangoDBVersion.License;
5655
import com.arangodb.entity.BaseDocument;
@@ -874,29 +873,6 @@ public void parseQuery() {
874873
assertThat(parse.getBindVars(), is(empty()));
875874
assertThat(parse.getCollections().size(), is(0));
876875
assertThat(parse.getAst().size(), is(1));
877-
final AstNode root = parse.getAst().iterator().next();
878-
assertThat(root.getType(), is("root"));
879-
assertThat(root.getName(), is(nullValue()));
880-
assertThat(root.getSubNodes(), is(notNullValue()));
881-
assertThat(root.getSubNodes().size(), is(2));
882-
final Iterator<AstNode> iterator = root.getSubNodes().iterator();
883-
final AstNode for_ = iterator.next();
884-
assertThat(for_.getType(), is("for"));
885-
assertThat(for_.getSubNodes(), is(notNullValue()));
886-
assertThat(for_.getSubNodes().size(), is(2));
887-
final Iterator<AstNode> iterator2 = for_.getSubNodes().iterator();
888-
final AstNode first = iterator2.next();
889-
assertThat(first.getType(), is("variable"));
890-
assertThat(first.getName(), is("i"));
891-
final AstNode second = iterator2.next();
892-
assertThat(second.getType(), is("range"));
893-
assertThat(second.getName(), is(nullValue()));
894-
final AstNode return_ = iterator.next();
895-
assertThat(return_.getType(), is("return"));
896-
assertThat(return_.getSubNodes(), is(notNullValue()));
897-
assertThat(return_.getSubNodes().size(), is(1));
898-
assertThat(return_.getSubNodes().iterator().next().getType(), is("reference"));
899-
assertThat(return_.getSubNodes().iterator().next().getName(), is("i"));
900876
}
901877

902878
@Test

src/test/java/com/arangodb/ArangoSearchTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,8 @@ public void createWithOptions() {
124124
return;
125125
}
126126
final String name = VIEW_NAME + "_createtest";
127-
final ViewEntity info = db.arangoSearch(name).create(new ArangoSearchCreateOptions());
127+
final ArangoSearchCreateOptions options = new ArangoSearchCreateOptions();
128+
final ViewEntity info = db.arangoSearch(name).create(options);
128129
assertThat(info, is(not(nullValue())));
129130
assertThat(info.getId(), is(not(nullValue())));
130131
assertThat(info.getName(), is(name));

0 commit comments

Comments
 (0)