diff --git a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SQLUpdateTest.java b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SQLUpdateTest.java index 3848782420e..eadc22e1a7c 100644 --- a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SQLUpdateTest.java +++ b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SQLUpdateTest.java @@ -24,7 +24,6 @@ import com.orientechnologies.orient.core.metadata.schema.OType; import com.orientechnologies.orient.core.record.OElement; import com.orientechnologies.orient.core.record.impl.ODocument; -import com.orientechnologies.orient.core.sql.OCommandSQL; import com.orientechnologies.orient.core.sql.executor.OResult; import com.orientechnologies.orient.core.sql.executor.OResultSet; import java.util.ArrayList; @@ -511,10 +510,9 @@ public void testEscaping() { database .command( - new OCommandSQL( - "UPDATE FormatEscapingTest SET test = 'aaa \\b bbb' WHERE @rid = " - + document.getIdentity())) - .execute(); + "UPDATE FormatEscapingTest SET test = 'aaa \\b bbb' WHERE @rid = " + + document.getIdentity()) + .close(); database.reload(document); Assert.assertEquals(document.field("test"), "aaa \b bbb"); @@ -530,10 +528,9 @@ public void testEscaping() { database .command( - new OCommandSQL( - "UPDATE FormatEscapingTest SET test = 'aaa \\f bbb' WHERE @rid = " - + document.getIdentity())) - .execute(); + "UPDATE FormatEscapingTest SET test = 'aaa \\f bbb' WHERE @rid = " + + document.getIdentity()) + .close(); database.reload(document); Assert.assertEquals(document.field("test"), "aaa \f bbb"); diff --git a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SchemaTest.java b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SchemaTest.java index 6bd71b5c9e6..fd9f7b39d9c 100755 --- a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SchemaTest.java +++ b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SchemaTest.java @@ -33,7 +33,6 @@ import com.orientechnologies.orient.core.sql.OCommandSQLParsingException; import com.orientechnologies.orient.core.sql.executor.OResult; import com.orientechnologies.orient.core.sql.executor.OResultSet; -import com.orientechnologies.orient.core.sql.query.OSQLSynchQuery; import com.orientechnologies.orient.core.storage.cluster.OOfflineClusterException; import java.io.IOException; import java.util.HashSet; @@ -781,39 +780,31 @@ public void testCaseSensitivePropNames() { schema.dropClass(className); } - private void swapClusters(ODatabaseDocumentInternal databaseDocumentTx, int i) { - databaseDocumentTx + private void swapClusters(ODatabaseDocumentInternal session, int i) { + session .command("CREATE CLASS TestRenameClusterNew extends TestRenameClusterOriginal clusters 2") .close(); - databaseDocumentTx - .command("INSERT INTO TestRenameClusterNew (iteration) VALUES(" + i + ")") - .close(); + session.command("INSERT INTO TestRenameClusterNew (iteration) VALUES(" + i + ")").close(); - databaseDocumentTx + session .command("ALTER CLASS TestRenameClusterOriginal removecluster TestRenameClusterOriginal") .close(); - databaseDocumentTx - .command("ALTER CLASS TestRenameClusterNew removecluster TestRenameClusterNew") - .close(); - databaseDocumentTx.command("DROP CLASS TestRenameClusterNew").close(); - databaseDocumentTx + session.command("ALTER CLASS TestRenameClusterNew removecluster TestRenameClusterNew").close(); + session.command("DROP CLASS TestRenameClusterNew").close(); + session .command("ALTER CLASS TestRenameClusterOriginal addcluster TestRenameClusterNew") .close(); - databaseDocumentTx.command("DROP CLUSTER TestRenameClusterOriginal").close(); - databaseDocumentTx - .command( - new OCommandSQL("ALTER CLUSTER TestRenameClusterNew name TestRenameClusterOriginal")) - .execute(); + session.command("DROP CLUSTER TestRenameClusterOriginal").close(); + session.command("ALTER CLUSTER TestRenameClusterNew name TestRenameClusterOriginal").close(); - databaseDocumentTx.getLocalCache().clear(); + session.getLocalCache().clear(); - List result = - databaseDocumentTx.query( - new OSQLSynchQuery("select * from TestRenameClusterOriginal")); + List result = + session.query("select * from TestRenameClusterOriginal").stream().toList(); Assert.assertEquals(result.size(), 1); - ODocument document = result.get(0); - Assert.assertEquals(document.field("iteration"), i); + OResult document = result.get(0); + Assert.assertEquals(document.getProperty("iteration"), i); } } diff --git a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SecurityTest.java b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SecurityTest.java index 6f9353d5497..498c60e3c9d 100755 --- a/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SecurityTest.java +++ b/tests/src/test/java/com/orientechnologies/orient/test/database/auto/SecurityTest.java @@ -72,7 +72,7 @@ public void testSecurityAccessWriter() throws IOException { reopendb("writer", "writer"); try { - new ODocument().save("internal"); + database.save(new ODocument(), "internal"); Assert.assertTrue(false); } catch (OSecurityAccessException e) { Assert.assertTrue(true);