Skip to content

Commit

Permalink
feat: update document api
Browse files Browse the repository at this point in the history
Signed-off-by: Otavio Santana <otaviopolianasantana@gmail.com>
  • Loading branch information
otaviojava committed Mar 4, 2024
1 parent bcc8a96 commit acf8e51
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -166,7 +166,7 @@ void shouldFindByName(){
CriteriaCondition condition = query.condition().orElseThrow();
SoftAssertions.assertSoftly(soft -> {
soft.assertThat(condition.condition()).isEqualTo(Condition.EQUALS);
soft.assertThat(condition.document().get(String.class)).isEqualTo("Ada");
soft.assertThat(condition.element().get(String.class)).isEqualTo("Ada");
});

}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ void shouldFindAllEntities() {
Stream<Person> allPersons = personRepository.findAll();

assertNotNull(allPersons);
verify(template, times(1)).select(any(DocumentQuery.class));
verify(template, times(1)).select(any(SelectQuery.class));
}

@Test
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -77,9 +77,9 @@ public List<String> apply(MethodMetadata metadata) {
" new org.eclipse.jnosql.communication.query.method.DeleteByMethodQueryProvider()");
lines.add("org.eclipse.jnosql.communication.query.DeleteQuery delete = supplier.apply(\"" +
metadata.getMethodName() + "\", metadata.name())");
lines.add("org.eclipse.jnosql.communication.document.DocumentObserverParser parser = " + SPACE +
"org.eclipse.jnosql.mapping.document.query.RepositoryDocumentObserverParser.of(metadata)");
lines.add("org.eclipse.jnosql.communication.document.DocumentDeleteQueryParams queryParams = " + SPACE +
lines.add("org.eclipse.jnosql.communication.semistructured.CommunicationObserverParser parser = " + SPACE +
"org.eclipse.jnosql.mapping.semistructured.query.RepositorySemistructuredObserverParser.of(metadata)");
lines.add("org.eclipse.jnosql.communication.semistructured.DeleteQueryParams queryParams = " + SPACE +
"DELETE_PARSER.apply(delete, parser)");
lines.add("org.eclipse.jnosql.communication.Params params = queryParams.params()");
for (Parameter parameter : metadata.getParameters()) {
Expand Down Expand Up @@ -122,17 +122,17 @@ private static void feedSelectQuery(MethodMetadata metadata, List<String> lines)
"new org.eclipse.jnosql.communication.query.method.SelectMethodQueryProvider()");
lines.add("org.eclipse.jnosql.communication.query.SelectQuery selectQuery = " + SPACE +
"supplier.apply(\"" + metadata.getMethodName() + "\", metadata.name())");
lines.add("org.eclipse.jnosql.communication.document.DocumentObserverParser parser = " + SPACE +
"org.eclipse.jnosql.mapping.document.query.RepositoryDocumentObserverParser.of(metadata)");
lines.add("org.eclipse.jnosql.communication.document.DocumentQueryParams queryParams = " + SPACE +
lines.add("org.eclipse.jnosql.communication.semistructured.CommunicationObserverParser parser = " + SPACE +
"org.eclipse.jnosql.mapping.semistructured.query.RepositorySemistructuredObserverParser.of(metadata)");
lines.add("org.eclipse.jnosql.communication.semistructured.QueryParams queryParams = " + SPACE +
"SELECT_PARSER.apply(selectQuery, parser)");
if (metadata.hasSpecialParameter()) {
lines.add("org.eclipse.jnosql.communication.document.DocumentQuery query = " + SPACE +
" org.eclipse.jnosql.mapping.document.query.DynamicQuery.of(new Object[]{" +
lines.add("SelectQuery query = " + SPACE +
" org.eclipse.jnosql.mapping.semistructured.query.DynamicQuery.of(new Object[]{" +
metadata.getSpecialParameter() +
"}, " + SPACE + "queryParams.query()).get()");
} else {
lines.add("org.eclipse.jnosql.communication.document.DocumentQuery query = queryParams.query()");
lines.add("SelectQuery query = queryParams.query()");
}
lines.add("org.eclipse.jnosql.communication.Params params = queryParams.params()");
for (Parameter parameter : metadata.getQueryParams()) {
Expand Down

0 comments on commit acf8e51

Please sign in to comment.