Repository: ignite Updated Branches: refs/heads/master 1df4f2967 -> 35ce5b1e0
IGNITE-7413 Fix SqlDmlExample This closes #3389 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/35ce5b1e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/35ce5b1e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/35ce5b1e Branch: refs/heads/master Commit: 35ce5b1e0971525c665aa19cec7fe63662ccba86 Parents: 1df4f29 Author: Pavel Tupitsyn <[email protected]> Authored: Thu Jan 18 12:05:12 2018 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Thu Jan 18 12:05:12 2018 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/examples/sql/SqlDmlExample.java | 12 +++--------- .../Apache.Ignite.Examples/Sql/SqlDmlExample.cs | 5 +---- 2 files changed, 4 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/35ce5b1e/examples/src/main/java/org/apache/ignite/examples/sql/SqlDmlExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDmlExample.java b/examples/src/main/java/org/apache/ignite/examples/sql/SqlDmlExample.java index cb2a04a..dbb1088 100644 --- a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDmlExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/sql/SqlDmlExample.java @@ -119,15 +119,9 @@ public class SqlDmlExample { * @param personCache Person cache. */ private static void delete(IgniteCache<Long, Person> personCache) { - String sql = - "delete from Person " + - "where id in (" + - "select p.id " + - "from Person p, \"" + ORG_CACHE + "\".Organization as o " + - "where o.name != ? and p.orgId = o.id" + - ")"; - - personCache.query(new SqlFieldsQuery(sql).setArgs("ASF")).getAll(); + String sql = "delete from Person where orgId != ?"; + + personCache.query(new SqlFieldsQuery(sql).setArgs(1)).getAll(); } /** http://git-wip-us.apache.org/repos/asf/ignite/blob/35ce5b1e/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Sql/SqlDmlExample.cs ---------------------------------------------------------------------- diff --git a/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Sql/SqlDmlExample.cs b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Sql/SqlDmlExample.cs index a37db76..7b84fc34 100644 --- a/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Sql/SqlDmlExample.cs +++ b/modules/platforms/dotnet/examples/Apache.Ignite.Examples/Sql/SqlDmlExample.cs @@ -153,10 +153,7 @@ namespace Apache.Ignite.Examples.Sql /// <param name="employeeCache">Employee cache.</param> private static void Delete(ICache<int, Employee> employeeCache) { - var qry = new SqlFieldsQuery(string.Format( - "delete from Employee where _key in (" + - "select emp._key from Employee emp, \"{0}\".Organization org " + - "where org.Name != ? and org._key = emp.organizationId)", OrganizationCacheName), "ASF"); + var qry = new SqlFieldsQuery("delete from Employee where organizationId != ?", 1); employeeCache.Query(qry); }
