Repository: ignite Updated Branches: refs/heads/ignite-2.4 63445893f -> f3f9f2a24
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/f3f9f2a2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f3f9f2a2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f3f9f2a2 Branch: refs/heads/ignite-2.4 Commit: f3f9f2a24b23027cf0c835140322e41a788932ae Parents: 6344589 Author: Pavel Tupitsyn <[email protected]> Authored: Thu Jan 18 12:05:12 2018 +0300 Committer: Pavel Tupitsyn <[email protected]> Committed: Thu Jan 18 12:13:02 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/f3f9f2a2/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/f3f9f2a2/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); }
