You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/12/27 08:24:25 UTC
[18/23] ignite git commit: IGNITE-7318 Fixed file name. Step 2.
IGNITE-7318 Fixed file name. Step 2.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/bb26300a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/bb26300a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/bb26300a
Branch: refs/heads/ignite-zk
Commit: bb26300aacafa2a844489b9c64c9a502219bda21
Parents: 2c7603c
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Wed Dec 27 11:28:26 2017 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Wed Dec 27 11:28:26 2017 +0700
----------------------------------------------------------------------
.../ignite/examples/sql/SqlDdlExample.java | 118 +++++++++++++++++++
.../ignite/examples/sql/SqlDdlExample1.java | 118 -------------------
2 files changed, 118 insertions(+), 118 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/bb26300a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample.java b/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample.java
new file mode 100644
index 0000000..12a9ac8
--- /dev/null
+++ b/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample.java
@@ -0,0 +1,118 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.examples.sql;
+
+import java.util.List;
+import org.apache.ignite.Ignite;
+import org.apache.ignite.IgniteCache;
+import org.apache.ignite.Ignition;
+import org.apache.ignite.cache.query.SqlFieldsQuery;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.examples.ExampleNodeStartup;
+
+/**
+ * Example to showcase DDL capabilities of Ignite's SQL engine.
+ * <p>
+ * Remote nodes could be started from command line as follows:
+ * {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
+ * <p>
+ * Alternatively you can run {@link ExampleNodeStartup} in either same or another JVM.
+ */
+public class SqlDdlExample {
+ /** Dummy cache name. */
+ private static final String DUMMY_CACHE_NAME = "dummy_cache";
+
+ /**
+ * Executes example.
+ *
+ * @param args Command line arguments, none required.
+ * @throws Exception If example execution failed.
+ */
+ @SuppressWarnings({"unused", "ThrowFromFinallyBlock"})
+ public static void main(String[] args) throws Exception {
+ try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
+ print("Cache query DDL example started.");
+
+ // Create dummy cache to act as an entry point for SQL queries (new SQL API which do not require this
+ // will appear in future versions, JDBC and ODBC drivers do not require it already).
+ CacheConfiguration<?, ?> cacheCfg = new CacheConfiguration<>(DUMMY_CACHE_NAME).setSqlSchema("PUBLIC");
+
+ try (
+ IgniteCache<?, ?> cache = ignite.getOrCreateCache(cacheCfg)
+ ) {
+ // Create reference City table based on REPLICATED template.
+ cache.query(new SqlFieldsQuery(
+ "CREATE TABLE city (id LONG PRIMARY KEY, name VARCHAR) WITH \"template=replicated\"")).getAll();
+
+ // Create table based on PARTITIONED template with one backup.
+ cache.query(new SqlFieldsQuery(
+ "CREATE TABLE person (id LONG, name VARCHAR, city_id LONG, PRIMARY KEY (id, city_id)) " +
+ "WITH \"backups=1, affinity_key=city_id\"")).getAll();
+
+ // Create an index.
+ cache.query(new SqlFieldsQuery("CREATE INDEX on Person (city_id)")).getAll();
+
+ print("Created database objects.");
+
+ SqlFieldsQuery qry = new SqlFieldsQuery("INSERT INTO city (id, name) VALUES (?, ?)");
+
+ cache.query(qry.setArgs(1L, "Forest Hill")).getAll();
+ cache.query(qry.setArgs(2L, "Denver")).getAll();
+ cache.query(qry.setArgs(3L, "St. Petersburg")).getAll();
+
+ qry = new SqlFieldsQuery("INSERT INTO person (id, name, city_id) values (?, ?, ?)");
+
+ cache.query(qry.setArgs(1L, "John Doe", 3L)).getAll();
+ cache.query(qry.setArgs(2L, "Jane Roe", 2L)).getAll();
+ cache.query(qry.setArgs(3L, "Mary Major", 1L)).getAll();
+ cache.query(qry.setArgs(4L, "Richard Miles", 2L)).getAll();
+
+ print("Populated data.");
+
+ List<List<?>> res = cache.query(new SqlFieldsQuery(
+ "SELECT p.name, c.name FROM Person p INNER JOIN City c on c.id = p.city_id")).getAll();
+
+ print("Query results:");
+
+ for (Object next : res)
+ System.out.println(">>> " + next);
+
+ cache.query(new SqlFieldsQuery("drop table Person")).getAll();
+ cache.query(new SqlFieldsQuery("drop table City")).getAll();
+
+ print("Dropped database objects.");
+ }
+ finally {
+ // Distributed cache can be removed from cluster only by #destroyCache() call.
+ ignite.destroyCache(DUMMY_CACHE_NAME);
+ }
+
+ print("Cache query DDL example finished.");
+ }
+ }
+
+ /**
+ * Prints message.
+ *
+ * @param msg Message to print before all objects are printed.
+ */
+ private static void print(String msg) {
+ System.out.println();
+ System.out.println(">>> " + msg);
+ }
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/bb26300a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample1.java
----------------------------------------------------------------------
diff --git a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample1.java b/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample1.java
deleted file mode 100644
index 12a9ac8..0000000
--- a/examples/src/main/java/org/apache/ignite/examples/sql/SqlDdlExample1.java
+++ /dev/null
@@ -1,118 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.examples.sql;
-
-import java.util.List;
-import org.apache.ignite.Ignite;
-import org.apache.ignite.IgniteCache;
-import org.apache.ignite.Ignition;
-import org.apache.ignite.cache.query.SqlFieldsQuery;
-import org.apache.ignite.configuration.CacheConfiguration;
-import org.apache.ignite.examples.ExampleNodeStartup;
-
-/**
- * Example to showcase DDL capabilities of Ignite's SQL engine.
- * <p>
- * Remote nodes could be started from command line as follows:
- * {@code 'ignite.{sh|bat} examples/config/example-ignite.xml'}.
- * <p>
- * Alternatively you can run {@link ExampleNodeStartup} in either same or another JVM.
- */
-public class SqlDdlExample {
- /** Dummy cache name. */
- private static final String DUMMY_CACHE_NAME = "dummy_cache";
-
- /**
- * Executes example.
- *
- * @param args Command line arguments, none required.
- * @throws Exception If example execution failed.
- */
- @SuppressWarnings({"unused", "ThrowFromFinallyBlock"})
- public static void main(String[] args) throws Exception {
- try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
- print("Cache query DDL example started.");
-
- // Create dummy cache to act as an entry point for SQL queries (new SQL API which do not require this
- // will appear in future versions, JDBC and ODBC drivers do not require it already).
- CacheConfiguration<?, ?> cacheCfg = new CacheConfiguration<>(DUMMY_CACHE_NAME).setSqlSchema("PUBLIC");
-
- try (
- IgniteCache<?, ?> cache = ignite.getOrCreateCache(cacheCfg)
- ) {
- // Create reference City table based on REPLICATED template.
- cache.query(new SqlFieldsQuery(
- "CREATE TABLE city (id LONG PRIMARY KEY, name VARCHAR) WITH \"template=replicated\"")).getAll();
-
- // Create table based on PARTITIONED template with one backup.
- cache.query(new SqlFieldsQuery(
- "CREATE TABLE person (id LONG, name VARCHAR, city_id LONG, PRIMARY KEY (id, city_id)) " +
- "WITH \"backups=1, affinity_key=city_id\"")).getAll();
-
- // Create an index.
- cache.query(new SqlFieldsQuery("CREATE INDEX on Person (city_id)")).getAll();
-
- print("Created database objects.");
-
- SqlFieldsQuery qry = new SqlFieldsQuery("INSERT INTO city (id, name) VALUES (?, ?)");
-
- cache.query(qry.setArgs(1L, "Forest Hill")).getAll();
- cache.query(qry.setArgs(2L, "Denver")).getAll();
- cache.query(qry.setArgs(3L, "St. Petersburg")).getAll();
-
- qry = new SqlFieldsQuery("INSERT INTO person (id, name, city_id) values (?, ?, ?)");
-
- cache.query(qry.setArgs(1L, "John Doe", 3L)).getAll();
- cache.query(qry.setArgs(2L, "Jane Roe", 2L)).getAll();
- cache.query(qry.setArgs(3L, "Mary Major", 1L)).getAll();
- cache.query(qry.setArgs(4L, "Richard Miles", 2L)).getAll();
-
- print("Populated data.");
-
- List<List<?>> res = cache.query(new SqlFieldsQuery(
- "SELECT p.name, c.name FROM Person p INNER JOIN City c on c.id = p.city_id")).getAll();
-
- print("Query results:");
-
- for (Object next : res)
- System.out.println(">>> " + next);
-
- cache.query(new SqlFieldsQuery("drop table Person")).getAll();
- cache.query(new SqlFieldsQuery("drop table City")).getAll();
-
- print("Dropped database objects.");
- }
- finally {
- // Distributed cache can be removed from cluster only by #destroyCache() call.
- ignite.destroyCache(DUMMY_CACHE_NAME);
- }
-
- print("Cache query DDL example finished.");
- }
- }
-
- /**
- * Prints message.
- *
- * @param msg Message to print before all objects are printed.
- */
- private static void print(String msg) {
- System.out.println();
- System.out.println(">>> " + msg);
- }
-}