Apache Calcite Demo

Apache Calcite Demo

Author: rameshm76

.idea/.gitignore

@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.ascendant76</groupId>
+    <artifactId>calcitedata</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.7.5</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+
+    <properties>
+        <maven.compiler.source>18</maven.compiler.source>
+        <maven.compiler.target>18</maven.compiler.target>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.calcite</groupId>
+            <artifactId>calcite-core</artifactId>
+            <version>1.32.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.calcite</groupId>
+            <artifactId>calcite-csv</artifactId>
+            <version>1.32.0</version>
+        </dependency>
+    </dependencies>
+</project>

.idea/codeStyles/Project.xml

@@ -0,0 +1,59 @@
+package com.ascendant76.calcitedata;
+
+import org.apache.calcite.util.Sources;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.Statement;
+import java.util.Properties;
+
+public class Main {
+
+    public static final String AGGREGATION_QUERY = """
+            SELECT d.name, COUNT(*)
+            FROM emps AS e JOIN depts AS d ON e.deptno = d.deptno
+            GROUP BY d.name""";
+    public static final String SELECT_QUERY = "select * from EMPS";
+
+    public static void main(String[] args) throws ClassNotFoundException {
+        final Properties info = new Properties();
+        info.put(
+                "model",
+                Sources.of(Main.class.getResource("/sales/model.json")).file().getAbsolutePath());
+
+        Class.forName("org.apache.calcite.jdbc.Driver");
+        try (
+                final Connection connection = DriverManager.getConnection("jdbc:calcite:", info);
+                final Statement statement = connection.createStatement();
+                final ResultSet resultSet = statement.executeQuery(SELECT_QUERY)) {
+            while (resultSet.next()) {
+                System.out.print("EMPNO: " + resultSet.getString("EMPNO"));
+                System.out.print(", NAME: " + resultSet.getString("NAME"));
+                System.out.print(", DEPTNO: " + resultSet.getString("DEPTNO"));
+                System.out.print(", GENDER: " + resultSet.getString("GENDER"));
+                System.out.print(", CITY: " + resultSet.getString("CITY"));
+                System.out.print(", EMPID: " + resultSet.getString("EMPID"));
+                System.out.print(", AGE: " + resultSet.getInt("AGE"));
+                System.out.print(", SLACKER: " + resultSet.getString("SLACKER"));
+                System.out.print(", MANAGER: " + resultSet.getString("MANAGER"));
+                System.out.println(", JOINEDAT: " + resultSet.getString("JOINEDAT"));
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+        try (
+                final Connection connection = DriverManager.getConnection("jdbc:calcite:", info);
+                final Statement statement = connection.createStatement();
+                final ResultSet resultSet = statement.executeQuery(AGGREGATION_QUERY)
+        ) {
+            while (resultSet.next()) {
+                System.out.print("NAME: " + resultSet.getString("NAME"));
+                System.out.println(", EXPR$1: " + resultSet.getString("EXPR$1"));
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

.idea/codeStyles/codeStyleConfig.xml

@@ -0,0 +1,4 @@
+DEPTNO:int,NAME:string
+10,"Sales"
+20,"Marketing"
+30,"Accounts"

.idea/compiler.xml

@@ -0,0 +1,7 @@
+DEPTNO:int,NAME:string
+10,"Sales"
+20,"Marketing"
+30,"Accounts"
+40,"40"
+50,"50"
+60,"60"

.idea/csv-plugin.xml

@@ -0,0 +1,29 @@
+{
+  "version": "1.0",
+  "defaultSchema": "CUSTOM_TABLE",
+  "schemas": [
+    {
+      "name": "CUSTOM_TABLE",
+      "tables": [
+        {
+          "name": "EMPS",
+          "type": "custom",
+          "factory": "org.apache.calcite.adapter.csv.CsvTableFactory",
+          "operand": {
+            "file": "EMPS.csv.gz",
+            "flavor": "scannable"
+          }
+        },
+        {
+          "name": "DEPTS",
+          "type": "custom",
+          "factory": "org.apache.calcite.adapter.csv.CsvTableFactory",
+          "operand": {
+            "file": "DEPTS.csv",
+            "flavor": "scannable"
+          }
+        }
+      ]
+    }
+  ]
+}