@@ -61,8 +61,8 @@ public void testCreateListTables() throws Exception {
61
61
Assert .assertNotNull (result );
62
62
63
63
// list result entries
64
- List <IonValue > tableNames2 = new ArrayList <IonValue >();
65
- result .forEach (tableNames2 :: add );
64
+ List <String > tableNames2 = new ArrayList <>();
65
+ result .forEach (v -> tableNames2 . add ((( IonString ) v ). stringValue ()) );
66
66
Assert .assertTrue (tableNames2 .contains (tableName1 ));
67
67
Assert .assertTrue (tableNames2 .contains (tableName2 ));
68
68
@@ -91,9 +91,9 @@ public void testCreateListIndexes() throws Exception {
91
91
92
92
Set <String > result = StreamSupport .stream (indexQueryResult .spliterator (), false )
93
93
.map (v -> (IonStruct ) v )
94
- .map (s -> s .get ("expr" ). toString ())
94
+ .map (s -> (( IonString ) s .get ("expr" )). stringValue ())
95
95
.collect (Collectors .toSet ());
96
- Assert .assertEquals (new HashSet <String >(Arrays .asList ("\" [attr1]\" " )), result );
96
+ Assert .assertEquals (new HashSet <>(Arrays .asList ("[attr1]" )), result );
97
97
98
98
// clean up
99
99
cleanUp (ledgerName );
@@ -126,7 +126,7 @@ public void testUpdateQueryDataTypes() throws Exception {
126
126
}
127
127
});
128
128
129
- wallet .setDescription ("my business wallet" );
129
+ wallet .setDescription ("my test wallet" );
130
130
wallet .setBalance (26.12d );
131
131
wallet .setTags (ImmutableMap .of ());
132
132
wallet .setType (WalletType .BUSINESS );
@@ -254,8 +254,6 @@ private void createLedgerAndTables(String ledgerName, String ... tableNames) thr
254
254
Assert .assertEquals (ledger .name (), ledgerName );
255
255
256
256
QldbDriver driver = getDriver (ledgerName );
257
-
258
- // create tables
259
257
for (String tableName : tableNames ) {
260
258
driver .execute (txn -> { return txn .execute ("CREATE TABLE " + tableName ); });
261
259
}
0 commit comments