This is an automated email from the ASF dual-hosted git repository.
gongzhongqiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-mongodb.git
The following commit(s) were added to refs/heads/main by this push:
new 97ec9b4 [hotfix][test] Minimize test cases visibility (#39)
97ec9b4 is described below
commit 97ec9b4314cdae92d050c112cef2112aed421e4e
Author: Jiabao Sun <[email protected]>
AuthorDate: Tue Aug 6 15:39:13 2024 +0800
[hotfix][test] Minimize test cases visibility (#39)
---
.../flink/tests/util/mongodb/MongoE2ECase.java | 8 +++---
.../mongodb/common/utils/MongoSerdeUtilsTest.java | 4 +--
.../connector/mongodb/sink/MongoSinkITCase.java | 7 ++---
.../mongodb/sink/writer/MongoWriterITCase.java | 4 +--
.../mongodb/source/MongoSourceITCase.java | 7 ++---
.../MongoSourceEnumStateSerializerTest.java | 2 +-
.../table/MongoDynamicTableFactoryTest.java | 16 ++++++------
.../mongodb/table/MongoDynamicTableSinkITCase.java | 22 ++++++++--------
.../table/MongoDynamicTableSourceITCase.java | 2 +-
.../table/MongoPartitionedTableSinkITCase.java | 4 +--
.../table/MongoPrimaryKeyExtractorTest.java | 14 +++++-----
.../table/converter/MongoConvertersTest.java | 30 +++++++++++-----------
12 files changed, 61 insertions(+), 59 deletions(-)
diff --git
a/flink-connector-mongodb-e2e-tests/src/test/java/org/apache/flink/tests/util/mongodb/MongoE2ECase.java
b/flink-connector-mongodb-e2e-tests/src/test/java/org/apache/flink/tests/util/mongodb/MongoE2ECase.java
index 082f312..da9d821 100644
---
a/flink-connector-mongodb-e2e-tests/src/test/java/org/apache/flink/tests/util/mongodb/MongoE2ECase.java
+++
b/flink-connector-mongodb-e2e-tests/src/test/java/org/apache/flink/tests/util/mongodb/MongoE2ECase.java
@@ -68,7 +68,7 @@ class MongoE2ECase {
private static final int TEST_ORDERS_COUNT = 5;
@Container
- static final MongoDBContainer MONGO_CONTAINER =
+ private static final MongoDBContainer MONGO_CONTAINER =
new MongoDBContainer(MONGO_4_0)
.withLogConsumer(new Slf4jLogConsumer(LOG))
.withNetwork(NETWORK)
@@ -82,7 +82,7 @@ class MongoE2ECase {
.build();
@RegisterExtension
- public static final FlinkContainers FLINK =
+ private static final FlinkContainers FLINK =
FlinkContainers.builder()
.withFlinkContainersSettings(
FlinkContainersSettings.builder().numTaskManagers(2).build())
@@ -104,7 +104,7 @@ class MongoE2ECase {
}
@Test
- public void testUpsertSink() throws Exception {
+ void testUpsertSink() throws Exception {
MongoDatabase db = mongoClient.getDatabase("test_upsert");
List<Document> orders = mockOrders();
@@ -118,7 +118,7 @@ class MongoE2ECase {
}
@Test
- public void testAppendOnlySink() throws Exception {
+ void testAppendOnlySink() throws Exception {
MongoDatabase db = mongoClient.getDatabase("test_append_only");
List<Document> orders = mockOrders();
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtilsTest.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtilsTest.java
index 1724d5b..b5217d4 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtilsTest.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtilsTest.java
@@ -36,7 +36,7 @@ import static org.assertj.core.api.Assertions.assertThat;
class MongoSerdeUtilsTest {
@Test
- public void testSerializeList() throws IOException {
+ void testSerializeList() throws IOException {
List<String> expected = Arrays.asList("config.collections",
"config.chunks");
byte[] serialized = serializeList(expected);
@@ -46,7 +46,7 @@ class MongoSerdeUtilsTest {
}
@Test
- public void testSerializeMap() throws IOException {
+ void testSerializeMap() throws IOException {
Map<String, String> expected = new HashMap<>();
expected.put("k0", "v0");
expected.put("k1", "v1");
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/MongoSinkITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/MongoSinkITCase.java
index 3cd5e71..2673b04 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/MongoSinkITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/MongoSinkITCase.java
@@ -57,7 +57,7 @@ import static org.assertj.core.api.Assertions.assertThat;
/** IT cases for {@link MongoSink}. */
@Testcontainers
-public class MongoSinkITCase {
+class MongoSinkITCase {
private static final Logger LOG =
LoggerFactory.getLogger(MongoSinkITCase.class);
@@ -66,13 +66,14 @@ public class MongoSinkITCase {
MongoTestUtil.createMongoDBContainer(LOG);
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(1)
.build());
- @RegisterExtension final SharedObjectsExtension sharedObjects =
SharedObjectsExtension.create();
+ @RegisterExtension
+ private final SharedObjectsExtension sharedObjects =
SharedObjectsExtension.create();
private static final String TEST_DATABASE = "test_sink";
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java
index bd3ca66..5aacb20 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriterITCase.java
@@ -61,14 +61,14 @@ import static org.assertj.core.api.Assertions.fail;
/** Tests for {@link MongoWriter}. */
@Testcontainers
-public class MongoWriterITCase {
+class MongoWriterITCase {
private static final Logger LOG =
LoggerFactory.getLogger(MongoWriterITCase.class);
private static final String TEST_DATABASE = "test_writer";
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(2)
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/MongoSourceITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/MongoSourceITCase.java
index 3f1df50..ae2d0fd 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/MongoSourceITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/MongoSourceITCase.java
@@ -85,17 +85,18 @@ class MongoSourceITCase {
private static final int PARALLELISM = 2;
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(PARALLELISM)
.build());
@RegisterExtension
- static final MongoShardedContainers MONGO_SHARDED_CONTAINER =
+ private static final MongoShardedContainers MONGO_SHARDED_CONTAINER =
MongoTestUtil.createMongoDBShardedContainers(Network.newNetwork());
- @RegisterExtension final SharedObjectsExtension sharedObjects =
SharedObjectsExtension.create();
+ @RegisterExtension
+ private final SharedObjectsExtension sharedObjects =
SharedObjectsExtension.create();
private static MongoClient mongoClient;
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializerTest.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializerTest.java
index 001c10e..8f0a796 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializerTest.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializerTest.java
@@ -35,7 +35,7 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNotSame;
/** Unit tests for {@link MongoSourceEnumStateSerializer}. */
-public class MongoSourceEnumStateSerializerTest {
+class MongoSourceEnumStateSerializerTest {
@Test
void serializeAndDeserializeMongoSourceEnumState() throws Exception {
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactoryTest.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactoryTest.java
index 3dae596..f9084a7 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactoryTest.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactoryTest.java
@@ -66,7 +66,7 @@ import static
org.assertj.core.api.Assertions.assertThatThrownBy;
* Test for {@link MongoDynamicTableSource} and {@link MongoDynamicTableSink}
created by {@link
* MongoDynamicTableFactory}.
*/
-public class MongoDynamicTableFactoryTest {
+class MongoDynamicTableFactoryTest {
private static final ResolvedSchema SCHEMA =
new ResolvedSchema(
@@ -80,7 +80,7 @@ public class MongoDynamicTableFactoryTest {
UniqueConstraint.primaryKey("name", Arrays.asList("bbb",
"aaa")));
@Test
- public void testMongoSourceCommonProperties() {
+ void testMongoSourceCommonProperties() {
DynamicTableSource actualSource = createTableSource(SCHEMA,
getRequiredOptions());
MongoDynamicTableSource expectedSource =
@@ -96,7 +96,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoSinkCommonProperties() {
+ void testMongoSinkCommonProperties() {
DynamicTableSink actualSink = createTableSink(SCHEMA,
getRequiredOptions());
MongoDynamicTableSink expectedSink =
@@ -110,7 +110,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoReadProperties() {
+ void testMongoReadProperties() {
Map<String, String> properties = getRequiredOptions();
properties.put(SCAN_FETCH_SIZE.key(), "1024");
properties.put(SCAN_CURSOR_NO_TIMEOUT.key(), "false");
@@ -145,7 +145,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoLookupProperties() {
+ void testMongoLookupProperties() {
Map<String, String> properties = getRequiredOptions();
properties.put(LookupOptions.CACHE_TYPE.key(), "PARTIAL");
properties.put(LookupOptions.PARTIAL_CACHE_EXPIRE_AFTER_WRITE.key(),
"10s");
@@ -173,7 +173,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoSinkProperties() {
+ void testMongoSinkProperties() {
Map<String, String> properties = getRequiredOptions();
properties.put(BUFFER_FLUSH_MAX_ROWS.key(), "1001");
properties.put(BUFFER_FLUSH_INTERVAL.key(), "2min");
@@ -201,7 +201,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoSinkWithParallelism() {
+ void testMongoSinkWithParallelism() {
Map<String, String> properties = getRequiredOptions();
properties.put("sink.parallelism", "2");
@@ -219,7 +219,7 @@ public class MongoDynamicTableFactoryTest {
}
@Test
- public void testMongoValidation() {
+ void testMongoValidation() {
// fetch size lower than 1
assertSourceValidationRejects(
SCAN_FETCH_SIZE.key(), "0", "The fetch size must be larger
than 0.");
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSinkITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSinkITCase.java
index 1e945b0..a1dcbc6 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSinkITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSinkITCase.java
@@ -87,7 +87,7 @@ import static org.assertj.core.api.Assertions.assertThat;
/** IT tests for {@link MongoDynamicTableSink}. */
@Testcontainers
-public class MongoDynamicTableSinkITCase {
+class MongoDynamicTableSinkITCase {
private static final Logger LOG =
LoggerFactory.getLogger(MongoDynamicTableSinkITCase.class);
@@ -96,7 +96,7 @@ public class MongoDynamicTableSinkITCase {
MongoTestUtil.createMongoDBContainer(LOG);
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(1)
@@ -105,19 +105,19 @@ public class MongoDynamicTableSinkITCase {
private MongoClient mongoClient;
@BeforeEach
- public void setUp() {
+ void setUp() {
mongoClient =
MongoClients.create(MONGO_CONTAINER.getConnectionString());
}
@AfterEach
- public void tearDown() {
+ void tearDown() {
if (mongoClient != null) {
mongoClient.close();
}
}
@Test
- public void testSinkWithAllSupportedTypes() throws ExecutionException,
InterruptedException {
+ void testSinkWithAllSupportedTypes() throws ExecutionException,
InterruptedException {
String database = "test";
String collection = "sink_with_all_supported_types";
@@ -215,7 +215,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testRoundTripReadAndSink() throws ExecutionException,
InterruptedException {
+ void testRoundTripReadAndSink() throws ExecutionException,
InterruptedException {
String database = "test";
String sourceCollection = "test_round_trip_source";
String sinkCollection = "test_round_trip_sink";
@@ -297,7 +297,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testSinkWithAllRowKind() throws ExecutionException,
InterruptedException {
+ void testSinkWithAllRowKind() throws ExecutionException,
InterruptedException {
String database = "test";
String collection = "test_sink_with_all_row_kind";
@@ -349,7 +349,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testSinkWithReservedId() throws Exception {
+ void testSinkWithReservedId() throws Exception {
String database = "test";
String collection = "sink_with_reserved_id";
@@ -385,7 +385,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testSinkWithoutPrimaryKey() throws Exception {
+ void testSinkWithoutPrimaryKey() throws Exception {
String database = "test";
String collection = "sink_without_primary_key";
@@ -411,7 +411,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testSinkWithNonCompositePrimaryKey() throws Exception {
+ void testSinkWithNonCompositePrimaryKey() throws Exception {
String database = "test";
String collection = "sink_with_non_composite_pk";
@@ -440,7 +440,7 @@ public class MongoDynamicTableSinkITCase {
}
@Test
- public void testSinkWithCompositePrimaryKey() throws Exception {
+ void testSinkWithCompositePrimaryKey() throws Exception {
String database = "test";
String collection = "sink_with_composite_pk";
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSourceITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSourceITCase.java
index 062b374..f50a35a 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSourceITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSourceITCase.java
@@ -93,7 +93,7 @@ class MongoDynamicTableSourceITCase {
private static final Logger LOG =
LoggerFactory.getLogger(MongoDynamicTableSinkITCase.class);
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(1)
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
index 9e6c98d..abe2546 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPartitionedTableSinkITCase.java
@@ -54,11 +54,11 @@ import static
org.assertj.core.api.Assertions.assertThatThrownBy;
class MongoPartitionedTableSinkITCase {
@RegisterExtension
- static final MongoShardedContainers MONGO_SHARDED_CONTAINER =
+ private static final MongoShardedContainers MONGO_SHARDED_CONTAINER =
MongoTestUtil.createMongoDBShardedContainers(Network.newNetwork());
@RegisterExtension
- static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
+ private static final MiniClusterExtension MINI_CLUSTER_RESOURCE =
new MiniClusterExtension(
new MiniClusterResourceConfiguration.Builder()
.setNumberTaskManagers(1)
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractorTest.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractorTest.java
index 3214017..6ff7f4d 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractorTest.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractorTest.java
@@ -50,10 +50,10 @@ import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
/** Tests for {@link MongoPrimaryKeyExtractor}. */
-public class MongoPrimaryKeyExtractorTest {
+class MongoPrimaryKeyExtractorTest {
@Test
- public void testSinglePrimaryKey() {
+ void testSinglePrimaryKey() {
ResolvedSchema schema =
new ResolvedSchema(
Arrays.asList(
@@ -70,7 +70,7 @@ public class MongoPrimaryKeyExtractorTest {
}
@Test
- public void testObjectIdPrimaryKey() {
+ void testObjectIdPrimaryKey() {
ResolvedSchema schema =
new ResolvedSchema(
Arrays.asList(
@@ -92,7 +92,7 @@ public class MongoPrimaryKeyExtractorTest {
}
@Test
- public void testAmbiguousPrimaryKey() {
+ void testAmbiguousPrimaryKey() {
ResolvedSchema schema0 =
new ResolvedSchema(
Arrays.asList(
@@ -119,7 +119,7 @@ public class MongoPrimaryKeyExtractorTest {
}
@Test
- public void testNoPrimaryKey() {
+ void testNoPrimaryKey() {
ResolvedSchema schema =
new ResolvedSchema(
Arrays.asList(
@@ -136,7 +136,7 @@ public class MongoPrimaryKeyExtractorTest {
}
@Test
- public void testCompoundPrimaryKey() {
+ void testCompoundPrimaryKey() {
ResolvedSchema schema =
new ResolvedSchema(
Arrays.asList(
@@ -165,7 +165,7 @@ public class MongoPrimaryKeyExtractorTest {
}
@Test
- public void testPrimaryKeyWithSupportedTypes() {
+ void testPrimaryKeyWithSupportedTypes() {
ResolvedSchema schema =
new ResolvedSchema(
Arrays.asList(
diff --git
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java
index ac7e03a..fc9b7f5 100644
---
a/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java
+++
b/flink-connector-mongodb/src/test/java/org/apache/flink/connector/mongodb/table/converter/MongoConvertersTest.java
@@ -60,10 +60,10 @@ import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.assertThatThrownBy;
/** Unit tests for {@link BsonToRowDataConverters} and {@link
RowDataToBsonConverters}. */
-public class MongoConvertersTest {
+class MongoConvertersTest {
@Test
- public void testConvertBsonToRowData() {
+ void testConvertBsonToRowData() {
DataType rowType =
DataTypes.ROW(
DataTypes.FIELD("_id", DataTypes.STRING().notNull()),
@@ -184,7 +184,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonNullToRowDataWithNonNullableConstraints() {
+ void testConvertBsonNullToRowDataWithNonNullableConstraints() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.STRING().notNull()));
BsonDocument docWithNullValue = new BsonDocument("f0", new BsonNull());
@@ -198,7 +198,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonNumberAndBooleanToSqlString() {
+ void testConvertBsonNumberAndBooleanToSqlString() {
DataType rowType =
DataTypes.ROW(
DataTypes.FIELD("f0", DataTypes.STRING()),
@@ -231,7 +231,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlBoolean() {
+ void testConvertBsonToSqlBoolean() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.BOOLEAN()));
BsonDocument document = new BsonDocument("f0", BsonBoolean.FALSE);
@@ -246,7 +246,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlTinyInt() {
+ void testConvertBsonToSqlTinyInt() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.TINYINT()));
assertThatThrownBy(
() ->
@@ -256,7 +256,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlSmallInt() {
+ void testConvertBsonToSqlSmallInt() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.SMALLINT()));
assertThatThrownBy(
() ->
@@ -266,7 +266,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlInt() {
+ void testConvertBsonToSqlInt() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.INT()));
BsonDocument document = new BsonDocument("f0", new BsonInt32(-1));
@@ -281,7 +281,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlBigInt() {
+ void testConvertBsonToSqlBigInt() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.BIGINT()));
BsonDocument document = new BsonDocument("f0", new BsonInt64(127L));
@@ -296,7 +296,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlDouble() {
+ void testConvertBsonToSqlDouble() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.DOUBLE()));
BsonDocument document = new BsonDocument("f0", new
BsonDouble(127.11d));
@@ -311,7 +311,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlFloat() {
+ void testConvertBsonToSqlFloat() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.FLOAT()));
assertThatThrownBy(
() ->
@@ -321,7 +321,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonToSqlDecimal() {
+ void testConvertBsonToSqlDecimal() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.DECIMAL(10, 2)));
BsonDocument document =
@@ -339,7 +339,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertBsonInfiniteDecimalToSqlNumber() {
+ void testConvertBsonInfiniteDecimalToSqlNumber() {
BsonDecimal128 positiveInfinity = new
BsonDecimal128(Decimal128.POSITIVE_INFINITY);
BsonDecimal128 negativeInfinity = new
BsonDecimal128(Decimal128.NEGATIVE_INFINITY);
@@ -361,7 +361,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertRowDataToBson() {
+ void testConvertRowDataToBson() {
DataType rowType =
DataTypes.ROW(
DataTypes.FIELD("_id", DataTypes.STRING().notNull()),
@@ -426,7 +426,7 @@ public class MongoConvertersTest {
}
@Test
- public void testConvertRowDataNullValueToBsonWithNonNullableConstraints() {
+ void testConvertRowDataNullValueToBsonWithNonNullableConstraints() {
DataType rowType = DataTypes.ROW(DataTypes.FIELD("f0",
DataTypes.STRING().notNull()));
RowData rowData = GenericRowData.of((StringData) null);
