Skip to content

Commit

Permalink
feat(tsubakuro): enhance blob/clob support
Browse files Browse the repository at this point in the history
  • Loading branch information
t-horikawa committed Jan 29, 2025
1 parent 5de1a97 commit 94bc289
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tsubakuro
Submodule tsubakuro updated 41 files
+4 −0 modules/common/build.gradle
+43 −0 modules/common/src/main/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/Wire.java
+19 −0 modules/common/src/main/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/impl/ChannelResponse.java
+1 −0 modules/common/src/main/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/impl/Link.java
+1 −1 modules/common/src/main/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/impl/ResponseBox.java
+36 −8 modules/common/src/main/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/impl/WireImpl.java
+49 −0 modules/common/src/main/java/com/tsurugidb/tsubakuro/common/BlobInfo.java
+59 −0 modules/common/src/main/java/com/tsurugidb/tsubakuro/common/impl/FileBlobInfo.java
+205 −0 modules/common/src/test/java/com/tsurugidb/tsubakuro/channel/common/connection/wire/impl/WireImplTest.java
+131 −0 modules/common/src/testFixtures/java/com/tsurugidb/tsubakuro/mock/MockLink.java
+50 −0 modules/common/src/testFixtures/java/com/tsurugidb/tsubakuro/mock/ResponseMessage.java
+1 −5 modules/ipc/src/main/java/com/tsurugidb/tsubakuro/channel/ipc/IpcLink.java
+7 −1 modules/proto/src/main/protos/jogasaki/proto/sql/request.proto
+24 −0 modules/proto/src/main/protos/tateyama/proto/framework/common.proto
+8 −1 modules/proto/src/main/protos/tateyama/proto/framework/request.proto
+9 −1 modules/proto/src/main/protos/tateyama/proto/framework/response.proto
+1 −0 modules/session/build.gradle
+37 −1 modules/session/src/main/java/com/tsurugidb/tsubakuro/common/Session.java
+22 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/common/impl/SessionImpl.java
+23 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/BlobReference.java
+23 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/ClobReference.java
+23 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/LargeObjectReference.java
+46 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/Parameters.java
+35 −1 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/RelationCursor.java
+22 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/SqlClient.java
+53 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/SqlService.java
+49 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/BlobReferenceForSql.java
+49 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/ClobReferenceForSql.java
+32 −1 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/ResultSetImpl.java
+26 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/SqlClientImpl.java
+147 −79 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/SqlServiceStub.java
+44 −2 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/TransactionImpl.java
+18 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/impl/ValueInputBackedRelationCursor.java
+39 −2 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/io/StreamBackedValueInput.java
+26 −1 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/io/ValueInput.java
+408 −0 modules/session/src/main/java/com/tsurugidb/tsubakuro/sql/util/SqlRequestUtils.java
+20 −0 modules/session/src/test/java/com/tsurugidb/tsubakuro/sql/impl/MockWire.java
+26 −39 modules/session/src/test/java/com/tsurugidb/tsubakuro/sql/impl/RequestHandler.java
+185 −0 modules/session/src/test/java/com/tsurugidb/tsubakuro/sql/impl/SqlServiceStubLobTest.java
+86 −3 modules/session/src/test/java/com/tsurugidb/tsubakuro/sql/impl/SqlServiceStubTest.java
+276 −0 modules/session/src/testFixtures/java/com/tsurugidb/tsubakuro/sql/util/SqlResponseUtils.java

1 comment on commit 94bc289

@t-horikawa
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please sign in to comment.