@@ -133,7 +133,7 @@ void testUpsertNewDocument() throws Exception {
133133
134134 boolean isNew = flatCollection .upsert (key , document );
135135
136- assertTrue (isNew , "Should return true for new document" );
136+ assertTrue (isNew );
137137
138138 queryAndAssert (
139139 key ,
@@ -160,7 +160,7 @@ void testUpsertMergesWithExistingDocument() throws Exception {
160160 Key key = new SingleValueKey (DEFAULT_TENANT , docId );
161161
162162 boolean firstResult = flatCollection .upsert (key , initialDoc );
163- assertTrue (firstResult , "First upsert should create new document" );
163+ assertTrue (firstResult );
164164
165165 // Now upsert with only some fields - others should be PRESERVED (merge behavior)
166166 ObjectNode mergeNode = OBJECT_MAPPER .createObjectNode ();
@@ -170,7 +170,7 @@ void testUpsertMergesWithExistingDocument() throws Exception {
170170 Document mergeDoc = new JSONDocument (mergeNode );
171171
172172 boolean secondResult = flatCollection .upsert (key , mergeDoc );
173- assertTrue (secondResult , "Second upsert should update existing document" );
173+ assertTrue (secondResult );
174174
175175 // Verify merge behavior: item updated, price/quantity/in_stock preserved
176176 queryAndAssert (
@@ -445,7 +445,7 @@ void testUnknownFieldsAsPerMissingColumnStrategy(MissingColumnStrategy missingCo
445445 FLAT_COLLECTION_NAME , key ));
446446 ResultSet rs = ps .executeQuery ()) {
447447 assertTrue (rs .next ());
448- assertEquals (0 , rs .getInt (1 ), "Document should not exist in DB after exception" );
448+ assertEquals (0 , rs .getInt (1 ));
449449 }
450450 } else {
451451 CreateResult result = flatCollection .create (key , document );
@@ -2650,11 +2650,11 @@ void testBulkUpdateWithAfterUpdateReturn() throws Exception {
26502650 }
26512651 resultIterator .close ();
26522652
2653- assertTrue (results .size () > 1 , "Should return multiple updated documents" );
2653+ assertTrue (results .size () > 1 );
26542654
26552655 for (Document doc : results ) {
26562656 JsonNode json = OBJECT_MAPPER .readTree (doc .toJson ());
2657- assertEquals (999 , json .get ("quantity" ).asInt (), "All docs should have updated quantity" );
2657+ assertEquals (999 , json .get ("quantity" ).asInt ());
26582658 }
26592659
26602660 PostgresDatastore pgDatastore = (PostgresDatastore ) postgresDatastore ;
@@ -2666,7 +2666,7 @@ void testBulkUpdateWithAfterUpdateReturn() throws Exception {
26662666 FLAT_COLLECTION_NAME ));
26672667 ResultSet rs = ps .executeQuery ()) {
26682668 assertTrue (rs .next ());
2669- assertEquals (results .size (), rs .getInt (1 ), "DB should have same number of updated rows" );
2669+ assertEquals (results .size (), rs .getInt (1 ));
26702670 }
26712671 }
26722672
@@ -2718,11 +2718,8 @@ void testBulkUpdateWithBeforeUpdateReturn() throws Exception {
27182718 String id = json .get ("id" ).asText ();
27192719 int returnedQuantity = json .get ("quantity" ).asInt ();
27202720
2721- assertTrue (originalQuantities .containsKey (id ), "Returned doc ID should be in original set" );
2722- assertEquals (
2723- originalQuantities .get (id ).intValue (),
2724- returnedQuantity ,
2725- "Returned quantity should be the ORIGINAL value" );
2721+ assertTrue (originalQuantities .containsKey (id ));
2722+ assertEquals (originalQuantities .get (id ).intValue (), returnedQuantity );
27262723 }
27272724
27282725 // But database should have the NEW value
@@ -2734,7 +2731,7 @@ void testBulkUpdateWithBeforeUpdateReturn() throws Exception {
27342731 FLAT_COLLECTION_NAME ));
27352732 ResultSet rs = ps .executeQuery ()) {
27362733 while (rs .next ()) {
2737- assertEquals (888 , rs .getInt ("quantity" ), "DB should have the updated value" );
2734+ assertEquals (888 , rs .getInt ("quantity" ));
27382735 }
27392736 }
27402737 }
@@ -2760,7 +2757,7 @@ void testBulkUpdateWithNoneReturn() throws Exception {
27602757 flatCollection .bulkUpdate (query , updates , options );
27612758
27622759 // Should return empty iterator
2763- assertFalse (resultIterator .hasNext (), "Should return empty iterator for NONE return type" );
2760+ assertFalse (resultIterator .hasNext ());
27642761 resultIterator .close ();
27652762
27662763 // But database should still be updated
@@ -2796,7 +2793,7 @@ void testBulkUpdateNoMatchingDocuments() throws Exception {
27962793 CloseableIterator <Document > resultIterator =
27972794 flatCollection .bulkUpdate (query , updates , options );
27982795
2799- assertFalse (resultIterator .hasNext (), "Should return empty iterator when no docs match" );
2796+ assertFalse (resultIterator .hasNext ());
28002797 resultIterator .close ();
28012798 }
28022799
@@ -2829,7 +2826,7 @@ void testBulkUpdateMultipleFields() throws Exception {
28292826 }
28302827 resultIterator .close ();
28312828
2832- assertEquals (3 , results .size (), "Should return 3 Soap items" );
2829+ assertEquals (3 , results .size ());
28332830
28342831 for (Document doc : results ) {
28352832 JsonNode json = OBJECT_MAPPER .readTree (doc .toJson ());
@@ -2933,8 +2930,8 @@ void testBulkUpdateNonExistentColumnWithSkipStrategy() throws Exception {
29332930
29342931 assertEquals (1 , results .size ());
29352932 JsonNode json = OBJECT_MAPPER .readTree (results .get (0 ).toJson ());
2936- assertEquals (111 , json .get ("price" ).asInt (), "Valid column should be updated" );
2937- assertFalse (json .has ("nonExistentColumn" ), "Non-existent column should not appear" );
2933+ assertEquals (111 , json .get ("price" ).asInt ());
2934+ assertFalse (json .has ("nonExistentColumn" ));
29382935 }
29392936
29402937 @ Test
0 commit comments