This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-16962
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from a66fb35fb Styles.
add aaf48298b IGNITE-16964 SQL API: Implement async SQL API (#817)
add fd4fb47b2 fix style
add afb026eca IGNITE-16700 Muted testBalance
add 8e22afb9e IGNITE-17011 [Native Persistence 3.0] Porting
FilePageStoreManager from 2.0 (#815)
add 95025fe90 IGNITE-14972 Java thin: Implement SQL API (#837)
add 9d44fdcc1 Merge branch 'main' into ignite-16962
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/ignite/sql/ResultSet.java | 2 +-
.../main/java/org/apache/ignite/sql/Statement.java | 16 +-
.../apache/ignite/sql/async/AsyncResultSet.java | 19 +-
.../ignite/sql/reactive/ReactiveResultSet.java | 2 +-
.../ignite/internal/client/proto/ClientOp.java | 9 +
.../ignite/client/handler/ItClientHandlerTest.java | 3 +-
.../ignite/client/handler/ClientHandlerModule.java | 12 +-
.../handler/ClientInboundMessageHandler.java | 21 +-
.../client/handler/ClientResourceRegistry.java | 2 +-
.../handler/requests/sql/ClientSqlCommon.java} | 46 +-
.../ClientSqlCursorCloseRequest.java} | 13 +-
.../sql/ClientSqlCursorNextPageRequest.java | 68 +++
.../requests/sql/ClientSqlExecuteRequest.java | 164 ++++++++
.../apache/ignite/client/ClientOperationType.java | 13 +-
.../apache/ignite/internal/client/ClientUtils.java | 9 +
.../ignite/internal/client/TcpIgniteClient.java | 7 +-
.../internal/client/sql/ClientAsyncResultSet.java | 196 +++++++++
.../internal/client/sql/ClientColumnMetadata.java} | 62 ++-
.../client/sql/ClientResultSetMetadata.java} | 36 +-
.../ignite/internal/client/sql/ClientSession.java | 307 ++++++++++++++
.../internal/client/sql/ClientSessionBuilder.java | 113 +++++
.../ClientTransactions.java => sql/ClientSql.java} | 38 +-
.../ignite/internal/client/sql/ClientSqlRow.java} | 150 +++----
.../internal/client/sql/ClientStatement.java | 173 ++++++++
.../client/sql/ClientStatementBuilder.java | 150 +++++++
.../org/apache/ignite/client/ClientSqlTest.java | 104 +++++
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 3 +-
.../ignite/client/fakes/FakeAsyncResultSet.java | 172 ++++++++
.../ignite/client/fakes/FakeColumnMetadata.java} | 32 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 2 +-
.../client/fakes/FakeIgniteQueryProcessor.java | 6 +
.../apache/ignite/client/fakes/FakeIgniteSql.java} | 43 +-
.../apache/ignite/client/fakes/FakeSession.java | 208 +++++++++
.../ignite/client/fakes/FakeSessionBuilder.java | 105 +++++
modules/core/pom.xml | 6 +
.../ignite/internal/thread/IgniteThread.java | 22 +-
.../ignite/internal/util/CollectionUtils.java | 29 +-
.../apache/ignite/internal/util/IgniteUtils.java | 24 ++
.../internal/testframework/IgniteTestUtils.java | 83 ++++
.../ignite/internal/util/IgniteUtilsTest.java | 34 ++
.../persistence/PageReadWriteManager.java | 8 +-
.../persistence/checkpoint/Checkpointer.java | 2 +-
.../persistence/store/FilePageStore.java | 14 +
.../persistence/store/FilePageStoreManager.java | 335 +++++++++++++++
.../persistence/store/GroupPageStoreHolder.java} | 43 +-
.../persistence/store/GroupPageStoreHolderMap.java | 116 +++++
.../store/LongOperationAsyncExecutor.java | 118 ++++++
.../store/PageReadWriteManagerImpl.java | 107 +++++
.../persistence/TestPageReadWriteManager.java | 5 +-
.../store/FilePageStoreManagerTest.java | 252 +++++++++++
.../store/GroupPageStoreHolderMapTest.java | 257 ++++++++++++
.../store/GroupPageStoreHolderTest.java | 62 +++
.../store/LongOperationAsyncExecutorTest.java | 264 ++++++++++++
.../store/PageReadWriteManagerImplTest.java | 84 ++++
.../runner/app/client/ItThinClientSqlTest.java | 185 ++++++++
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 466 +++++++++++++++++++++
.../org/apache/ignite/internal/app/IgniteImpl.java | 11 +-
.../internal/sql/api/AsyncResultSetImpl.java | 439 +++++++++++++++++++
.../internal/sql/api/ColumnMetadataImpl.java} | 39 +-
.../internal/sql/api/IgniteSqlException.java} | 15 +-
.../IgniteSqlImpl.java} | 46 +-
.../internal/sql/api/SessionBuilderImpl.java | 122 ++++++
.../ignite/internal/sql/api/SessionImpl.java | 297 +++++++++++++
.../internal/sql/api/StatementBuilderImpl.java | 117 ++++++
.../ignite/internal/sql/api/StatementImpl.java | 88 ++++
.../ignite/internal/sql/engine/QueryProcessor.java | 17 +-
.../{AsyncSqlCursor.java => QueryTimeout.java} | 29 +-
.../internal/sql/engine/SqlQueryProcessor.java | 82 +++-
.../sql/engine/exec/ExecutionServiceImpl.java | 6 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 81 +++-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 6 +-
.../internal/sql/engine/IgniteSqlApiTest.java | 24 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 8 +-
.../ignite/internal/table/TxAbstractTest.java | 1 +
76 files changed, 5891 insertions(+), 365 deletions(-)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/event/ClientMessageUtils.java
=>
client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCommon.java}
(51%)
copy
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/{tx/ClientTransactionCommitRequest.java
=> sql/ClientSqlCursorCloseRequest.java} (80%)
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlCursorNextPageRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/sql/ClientSqlExecuteRequest.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientAsyncResultSet.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/definition/ColumnDefinitionImpl.java
=>
client/src/main/java/org/apache/ignite/internal/client/sql/ClientColumnMetadata.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ResultSetMetadataImpl.java
=>
client/src/main/java/org/apache/ignite/internal/client/sql/ClientResultSetMetadata.java}
(56%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSession.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientSessionBuilder.java
copy
modules/client/src/main/java/org/apache/ignite/internal/client/{tx/ClientTransactions.java
=> sql/ClientSql.java} (57%)
copy
modules/{table/src/test/java/org/apache/ignite/internal/table/impl/TestTupleBuilder.java
=>
client/src/main/java/org/apache/ignite/internal/client/sql/ClientSqlRow.java}
(59%)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatement.java
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientStatementBuilder.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/ClientSqlTest.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeAsyncResultSet.java
copy
modules/{schema/src/main/java/org/apache/ignite/internal/schema/definition/AbstractSchemaObject.java
=>
client/src/test/java/org/apache/ignite/client/fakes/FakeColumnMetadata.java}
(66%)
copy
modules/{page-memory/src/main/java/org/apache/ignite/internal/pagememory/evict/PageEvictionTrackerNoOp.java
=> client/src/test/java/org/apache/ignite/client/fakes/FakeIgniteSql.java}
(53%)
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSession.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/fakes/FakeSessionBuilder.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/store/FilePageStoreManager.java
copy
modules/{core/src/test/java/org/apache/ignite/internal/util/IgniteRandom.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/store/GroupPageStoreHolder.java}
(53%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/store/GroupPageStoreHolderMap.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/store/LongOperationAsyncExecutor.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/store/PageReadWriteManagerImpl.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/store/FilePageStoreManagerTest.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/store/GroupPageStoreHolderMapTest.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/store/GroupPageStoreHolderTest.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/store/LongOperationAsyncExecutorTest.java
create mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/store/PageReadWriteManagerImplTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientSqlTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItSqlAsynchronousApiTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/AsyncResultSetImpl.java
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/TableDataRowAdapter.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/api/ColumnMetadataImpl.java}
(57%)
copy modules/{api/src/main/java/org/apache/ignite/lang/IgniteException.java =>
sql-engine/src/main/java/org/apache/ignite/internal/sql/api/IgniteSqlException.java}
(82%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/{engine/util/TransformingIterator.java
=> api/IgniteSqlImpl.java} (52%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionBuilderImpl.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/SessionImpl.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/StatementBuilderImpl.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/api/StatementImpl.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{AsyncSqlCursor.java
=> QueryTimeout.java} (58%)
