Skip to content

Commit 9d19e25

Browse files
vietjvietj
committed
Extract internal an API capable of hooking a back-end implementation of the client (e.g. vertx-jdbc-client).
1 parent 0ef129d commit 9d19e25

File tree

176 files changed

+402
-354
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

176 files changed

+402
-354
lines changed

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/DB2ConnectionFactory.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
import io.vertx.core.spi.metrics.VertxMetrics;
2727
import io.vertx.db2client.DB2ConnectOptions;
2828
import io.vertx.sqlclient.SqlConnection;
29-
import io.vertx.sqlclient.impl.Connection;
29+
import io.vertx.sqlclient.internal.Connection;
3030
import io.vertx.sqlclient.impl.ConnectionFactoryBase;
3131

3232
import java.util.Map;

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/DB2ConnectionImpl.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,8 +23,8 @@
2323
import io.vertx.db2client.DB2Connection;
2424
import io.vertx.db2client.impl.command.PingCommand;
2525
import io.vertx.db2client.spi.DB2Driver;
26-
import io.vertx.sqlclient.impl.Connection;
27-
import io.vertx.sqlclient.impl.SqlConnectionBase;
26+
import io.vertx.sqlclient.internal.Connection;
27+
import io.vertx.sqlclient.internal.SqlConnectionBase;
2828
import io.vertx.sqlclient.spi.ConnectionFactory;
2929

3030
public class DB2ConnectionImpl extends SqlConnectionBase<DB2ConnectionImpl> implements DB2Connection {

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/DB2RowImpl.java‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,6 @@
1515
*/
1616
package io.vertx.db2client.impl;
1717

18-
import java.math.BigDecimal;
1918
import java.sql.RowId;
2019
import java.time.Duration;
2120
import java.time.LocalDate;
@@ -29,11 +28,9 @@
2928

3029
import io.vertx.core.buffer.Buffer;
3130
import io.vertx.db2client.impl.drda.DB2RowId;
32-
import io.vertx.sqlclient.Row;
3331
import io.vertx.sqlclient.data.Numeric;
34-
import io.vertx.sqlclient.impl.ArrayTuple;
3532
import io.vertx.sqlclient.impl.RowBase;
36-
import io.vertx.sqlclient.impl.RowDesc;
33+
import io.vertx.sqlclient.internal.RowDesc;
3734

3835
public class DB2RowImpl extends RowBase {
3936

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/DB2SocketConnection.java‎

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,10 +27,11 @@
2727
import io.vertx.db2client.impl.command.InitialHandshakeCommand;
2828
import io.vertx.db2client.impl.drda.ConnectionMetaData;
2929
import io.vertx.sqlclient.SqlConnectOptions;
30-
import io.vertx.sqlclient.impl.Connection;
31-
import io.vertx.sqlclient.impl.QueryResultHandler;
30+
import io.vertx.sqlclient.internal.Connection;
31+
import io.vertx.sqlclient.internal.QueryResultHandler;
3232
import io.vertx.sqlclient.impl.SocketConnectionBase;
3333
import io.vertx.sqlclient.impl.command.*;
34+
import io.vertx.sqlclient.internal.command.*;
3435
import io.vertx.sqlclient.spi.DatabaseMetadata;
3536

3637
import java.util.Map;

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/CloseConnectionCommandCodec.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
import io.netty.buffer.ByteBuf;
1919
import io.vertx.db2client.impl.drda.DRDAQueryRequest;
2020
import io.vertx.db2client.impl.drda.DRDAQueryResponse;
21-
import io.vertx.sqlclient.impl.command.CloseConnectionCommand;
21+
import io.vertx.sqlclient.internal.command.CloseConnectionCommand;
2222

2323
class CloseConnectionCommandCodec extends CommandCodec<Void, CloseConnectionCommand> {
2424

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/CloseCursorCommandCodec.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,8 @@
2121
import io.vertx.db2client.impl.codec.DB2PreparedStatement.QueryInstance;
2222
import io.vertx.db2client.impl.drda.DRDAQueryRequest;
2323
import io.vertx.db2client.impl.drda.DRDAQueryResponse;
24-
import io.vertx.sqlclient.impl.command.CloseCursorCommand;
25-
import io.vertx.sqlclient.impl.command.CommandResponse;
24+
import io.vertx.sqlclient.internal.command.CloseCursorCommand;
25+
import io.vertx.sqlclient.internal.command.CommandResponse;
2626

2727
class CloseCursorCommandCodec extends CommandCodec<Void, CloseCursorCommand> {
2828

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/CloseStatementCommandCodec.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@
1616
package io.vertx.db2client.impl.codec;
1717

1818
import io.netty.buffer.ByteBuf;
19-
import io.vertx.sqlclient.impl.command.CloseStatementCommand;
20-
import io.vertx.sqlclient.impl.command.CommandResponse;
19+
import io.vertx.sqlclient.internal.command.CloseStatementCommand;
20+
import io.vertx.sqlclient.internal.command.CommandResponse;
2121

2222
class CloseStatementCommandCodec extends CommandCodec<Void, CloseStatementCommand> {
2323

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/CommandCodec.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@
1717

1818
import io.netty.buffer.ByteBuf;
1919
import io.vertx.core.Handler;
20-
import io.vertx.sqlclient.impl.command.CommandBase;
21-
import io.vertx.sqlclient.impl.command.CommandResponse;
20+
import io.vertx.sqlclient.internal.command.CommandBase;
21+
import io.vertx.sqlclient.internal.command.CommandResponse;
2222

2323
abstract class CommandCodec<R, C extends CommandBase<R>> {
2424

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/DB2Decoder.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import io.vertx.core.internal.logging.Logger;
2626
import io.vertx.core.internal.logging.LoggerFactory;
2727
import io.vertx.db2client.DB2Exception;
28-
import io.vertx.sqlclient.impl.command.CommandResponse;
28+
import io.vertx.sqlclient.internal.command.CommandResponse;
2929

3030
class DB2Decoder extends ByteToMessageDecoder {
3131

‎vertx-db2-client/src/main/java/io/vertx/db2client/impl/codec/DB2Encoder.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -25,14 +25,14 @@
2525
import io.vertx.db2client.impl.DB2SocketConnection;
2626
import io.vertx.db2client.impl.command.InitialHandshakeCommand;
2727
import io.vertx.db2client.impl.command.PingCommand;
28-
import io.vertx.sqlclient.impl.command.CloseConnectionCommand;
29-
import io.vertx.sqlclient.impl.command.CloseCursorCommand;
30-
import io.vertx.sqlclient.impl.command.CloseStatementCommand;
31-
import io.vertx.sqlclient.impl.command.CommandBase;
32-
import io.vertx.sqlclient.impl.command.CommandResponse;
33-
import io.vertx.sqlclient.impl.command.ExtendedQueryCommand;
34-
import io.vertx.sqlclient.impl.command.PrepareStatementCommand;
35-
import io.vertx.sqlclient.impl.command.SimpleQueryCommand;
28+
import io.vertx.sqlclient.internal.command.CloseConnectionCommand;
29+
import io.vertx.sqlclient.internal.command.CloseCursorCommand;
30+
import io.vertx.sqlclient.internal.command.CloseStatementCommand;
31+
import io.vertx.sqlclient.internal.command.CommandBase;
32+
import io.vertx.sqlclient.internal.command.CommandResponse;
33+
import io.vertx.sqlclient.internal.command.ExtendedQueryCommand;
34+
import io.vertx.sqlclient.internal.command.PrepareStatementCommand;
35+
import io.vertx.sqlclient.internal.command.SimpleQueryCommand;
3636

3737
class DB2Encoder extends ChannelOutboundHandlerAdapter {
3838

0 commit comments

Comments
 (0)