This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a commit to branch ignite-14972
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-14972 by this push:
new 3be08e4ad wip cleanup
3be08e4ad is described below
commit 3be08e4add1f5667e2ff63e8b9f0327af6f1f36a
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Mon May 30 22:46:19 2022 +0300
wip cleanup
---
.../apache/ignite/client/fakes/FakeSession.java | 34 ++++++++++------------
1 file changed, 15 insertions(+), 19 deletions(-)
diff --git
a/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
b/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
index 613bce94e..cabae6555 100644
---
a/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
+++
b/modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
@@ -72,21 +72,19 @@ public class FakeSession implements Session {
/** {@inheritDoc} */
@Override
public ResultSet execute(@Nullable Transaction transaction, String query,
@Nullable Object... arguments) {
- // TODO: Wrap AsyncResultSet.
- // return sync(executeAsync(transaction, query, arguments));
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public ResultSet execute(@Nullable Transaction transaction, Statement
statement, @Nullable Object... arguments) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public CompletableFuture<AsyncResultSet> executeAsync(@Nullable
Transaction transaction, String query, @Nullable Object... arguments) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@@ -103,61 +101,61 @@ public class FakeSession implements Session {
/** {@inheritDoc} */
@Override
public ReactiveResultSet executeReactive(@Nullable Transaction
transaction, String query, @Nullable Object... arguments) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public ReactiveResultSet executeReactive(@Nullable Transaction
transaction, Statement statement, @Nullable Object... arguments) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public int[] executeBatch(@Nullable Transaction transaction, String
dmlQuery, BatchedArguments batch) {
- return new int[0];
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public int[] executeBatch(@Nullable Transaction transaction, Statement
dmlStatement, BatchedArguments batch) {
- return new int[0];
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public CompletableFuture<int[]> executeBatchAsync(@Nullable Transaction
transaction, String query, BatchedArguments batch) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public CompletableFuture<int[]> executeBatchAsync(@Nullable Transaction
transaction, Statement statement, BatchedArguments batch) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public Publisher<Integer> executeBatchReactive(@Nullable Transaction
transaction, String query, BatchedArguments batch) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public Publisher<Integer> executeBatchReactive(@Nullable Transaction
transaction, Statement statement, BatchedArguments batch) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public void executeScript(String query, @Nullable Object... arguments) {
-
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@Override
public CompletableFuture<Void> executeScriptAsync(String query, @Nullable
Object... arguments) {
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */
@@ -193,15 +191,13 @@ public class FakeSession implements Session {
/** {@inheritDoc} */
@Override
public CompletableFuture<Void> closeAsync() {
- // TODO: Cancel/close all active futures.
- return null;
+ return CompletableFuture.completedFuture(null);
}
/** {@inheritDoc} */
@Override
public Publisher<Void> closeReactive() {
- // TODO: Future to Publisher.
- return null;
+ throw new UnsupportedOperationException();
}
/** {@inheritDoc} */