Skip to content

Commit 88807e3

Browse files
authored
fix wrong calls in wrapper class (#1413)
1 parent 395655b commit 88807e3

File tree

9 files changed

+18
-17
lines changed

9 files changed

+18
-17
lines changed

wrapper/src/main/java/software/amazon/jdbc/C3P0PooledConnectionProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,6 @@
3636
import software.amazon.jdbc.util.Messages;
3737
import software.amazon.jdbc.util.PropertyUtils;
3838
import software.amazon.jdbc.util.SlidingExpirationCache;
39-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
4039

4140
public class C3P0PooledConnectionProvider implements PooledConnectionProvider, CanReleaseResources {
4241

wrapper/src/main/java/software/amazon/jdbc/DataSourceConnectionProvider.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,14 +32,12 @@
3232
import org.checkerframework.checker.nullness.qual.Nullable;
3333
import software.amazon.jdbc.dialect.Dialect;
3434
import software.amazon.jdbc.exceptions.SQLLoginException;
35-
import software.amazon.jdbc.targetdriverdialect.ConnectInfo;
3635
import software.amazon.jdbc.targetdriverdialect.TargetDriverDialect;
3736
import software.amazon.jdbc.util.Messages;
3837
import software.amazon.jdbc.util.PropertyUtils;
3938
import software.amazon.jdbc.util.RdsUtils;
4039
import software.amazon.jdbc.util.SqlState;
4140
import software.amazon.jdbc.util.WrapperUtils;
42-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
4341

4442
/**
4543
* This class is a basic implementation of {@link ConnectionProvider} interface. It creates and

wrapper/src/main/java/software/amazon/jdbc/DriverConnectionProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,6 @@
3535
import software.amazon.jdbc.util.Messages;
3636
import software.amazon.jdbc.util.PropertyUtils;
3737
import software.amazon.jdbc.util.RdsUtils;
38-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
3938

4039
/**
4140
* This class is a basic implementation of {@link ConnectionProvider} interface. It creates and
Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
* limitations under the License.
1515
*/
1616

17-
package software.amazon.jdbc.wrapper;
17+
package software.amazon.jdbc;
1818

1919
import java.sql.SQLException;
2020
import java.util.Comparator;
@@ -23,9 +23,6 @@
2323
import java.util.stream.Collectors;
2424
import org.checkerframework.checker.nullness.qual.NonNull;
2525
import org.checkerframework.checker.nullness.qual.Nullable;
26-
import software.amazon.jdbc.HostRole;
27-
import software.amazon.jdbc.HostSelector;
28-
import software.amazon.jdbc.HostSpec;
2926
import software.amazon.jdbc.hostavailability.HostAvailability;
3027
import software.amazon.jdbc.util.Messages;
3128

wrapper/src/main/java/software/amazon/jdbc/HikariPooledConnectionProvider.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,6 @@
4444
import software.amazon.jdbc.util.RdsUrlType;
4545
import software.amazon.jdbc.util.RdsUtils;
4646
import software.amazon.jdbc.util.SlidingExpirationCache;
47-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
4847

4948
public class HikariPooledConnectionProvider implements PooledConnectionProvider,
5049
CanReleaseResources {

wrapper/src/main/java/software/amazon/jdbc/plugin/limitless/LimitlessRouterServiceImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import java.util.logging.Logger;
2727
import org.checkerframework.checker.nullness.qual.NonNull;
2828
import software.amazon.jdbc.AwsWrapperProperty;
29+
import software.amazon.jdbc.HighestWeightHostSelector;
2930
import software.amazon.jdbc.HostRole;
3031
import software.amazon.jdbc.HostSpec;
3132
import software.amazon.jdbc.PluginService;
@@ -35,7 +36,6 @@
3536
import software.amazon.jdbc.util.Messages;
3637
import software.amazon.jdbc.util.SlidingExpirationCacheWithCleanupThread;
3738
import software.amazon.jdbc.util.Utils;
38-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
3939

4040
public class LimitlessRouterServiceImpl implements LimitlessRouterService {
4141
private static final Logger LOGGER =

wrapper/src/main/java/software/amazon/jdbc/wrapper/ArrayWrapper.java

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,8 @@ public Object getArray(Map<String, Class<?>> map) throws SQLException {
7575
this.pluginManager,
7676
this.array,
7777
"Array.getArray",
78-
() -> this.array.getArray());
78+
() -> this.array.getArray(map),
79+
map);
7980
}
8081

8182
@Override
@@ -86,7 +87,9 @@ public Object getArray(long index, int count) throws SQLException {
8687
this.pluginManager,
8788
this.array,
8889
"Array.getArray",
89-
() -> this.array.getArray());
90+
() -> this.array.getArray(index, count),
91+
index,
92+
count);
9093
}
9194

9295
@Override
@@ -97,7 +100,10 @@ public Object getArray(long index, int count, Map<String, Class<?>> map) throws
97100
this.pluginManager,
98101
this.array,
99102
"Array.getArray",
100-
() -> this.array.getArray());
103+
() -> this.array.getArray(index, count, map),
104+
index,
105+
count,
106+
map);
101107
}
102108

103109
@Override
@@ -119,7 +125,8 @@ public ResultSet getResultSet(Map<String, Class<?>> map) throws SQLException {
119125
this.pluginManager,
120126
this.array,
121127
"Array.getResultSet",
122-
() -> this.array.getResultSet());
128+
() -> this.array.getResultSet(map),
129+
map);
123130
}
124131

125132
@Override
@@ -130,7 +137,9 @@ public ResultSet getResultSet(long index, int count) throws SQLException {
130137
this.pluginManager,
131138
this.array,
132139
"Array.getResultSet",
133-
() -> this.array.getResultSet());
140+
() -> this.array.getResultSet(index, count),
141+
index,
142+
count);
134143
}
135144

136145
@Override

wrapper/src/test/java/software/amazon/jdbc/plugin/HighestWeightHostSelectorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,11 +26,11 @@
2626
import java.util.Properties;
2727
import org.junit.jupiter.api.BeforeEach;
2828
import org.junit.jupiter.api.Test;
29+
import software.amazon.jdbc.HighestWeightHostSelector;
2930
import software.amazon.jdbc.HostRole;
3031
import software.amazon.jdbc.HostSpec;
3132
import software.amazon.jdbc.HostSpecBuilder;
3233
import software.amazon.jdbc.hostavailability.SimpleHostAvailabilityStrategy;
33-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
3434

3535
public class HighestWeightHostSelectorTest {
3636

wrapper/src/test/java/software/amazon/jdbc/plugin/limitless/LimitlessRouterServiceImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838
import org.junit.jupiter.api.Test;
3939
import org.mockito.Mock;
4040
import org.mockito.MockitoAnnotations;
41+
import software.amazon.jdbc.HighestWeightHostSelector;
4142
import software.amazon.jdbc.HostListProvider;
4243
import software.amazon.jdbc.HostRole;
4344
import software.amazon.jdbc.HostSpec;
@@ -47,7 +48,6 @@
4748
import software.amazon.jdbc.RoundRobinHostSelector;
4849
import software.amazon.jdbc.hostavailability.HostAvailability;
4950
import software.amazon.jdbc.hostavailability.SimpleHostAvailabilityStrategy;
50-
import software.amazon.jdbc.wrapper.HighestWeightHostSelector;
5151

5252
public class LimitlessRouterServiceImplTest {
5353

0 commit comments

Comments
 (0)