Java：BigData 重命名为 Presto 并简化使用；Presto：新增配置文件；Trino：新增配置文件

Author: TommyLemon

.gitignore

@@ -20,3 +20,5 @@ APIJSON-Java-Server/APIJSONDemo-HikariCP/.idea
 APIJSON-Java-Server/APIJSONBigData/.settings
 APIJSON-Java-Server/APIJSONDemo-BigData/.idea
 APIJSON-Java-Server/APIJSONDemo-BigData/target
+APIJSON-Java-Server/APIJSONDemo-Presto/.idea
+APIJSON-Java-Server/APIJSONDemo-Presto/target

APIJSON-Java-Server/APIJSONDemo-BigData/src/main/java/apijson/demo/DemoSQLExecutor.java

@@ -5,9 +5,9 @@
 
 	<groupId>apijson.demo</groupId>
 	<artifactId>apijson-demo</artifactId>
-	<version>5.3.0</version>
+	<version>5.4.0</version>
 
-	<name>APIJSONDemo</name>
+	<name>APIJSONDemo-Presto</name>
 	<description>Demo project for testing APIJSON server based on SpringBoot</description>
 
 	<properties>
@@ -17,65 +17,43 @@
 	</properties>
 
 	<dependencies>
-    <!-- JDK 11+ 需要，否则启动报错 NoClassDefFoundError: javax/activation/UnsupportedDataTypeException -->
-    <dependency>
-      <groupId>javax.activation</groupId>
-      <artifactId>activation</artifactId>
-      <version>1.1.1</version>
-    </dependency>
+        <!-- JDK 11+ 需要，否则启动报错 NoClassDefFoundError: javax/activation/UnsupportedDataTypeException -->
+        <dependency>
+          <groupId>javax.activation</groupId>
+          <artifactId>activation</artifactId>
+          <version>1.1.1</version>
+        </dependency>
 
 		<!-- 需要的 APIJSON 相关依赖 -->
+        <dependency>
+            <groupId>com.github.Tencent</groupId>
+            <artifactId>APIJSON</artifactId>
+            <version>5.4.0</version>
+        </dependency>
 		<dependency>
 			<groupId>com.github.APIJSON</groupId>
 			<artifactId>apijson-framework</artifactId>
 			<version>5.3.0</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.github.Tecent</groupId>
+                    <artifactId>APIJSON</artifactId>
+                </exclusion>
+            </exclusions>
 		</dependency>
 
 		<!-- 需要用的数据库 JDBC 驱动 -->
-<!--		<dependency>-->
-<!--			<groupId>mysql</groupId>-->
-<!--			<artifactId>mysql-connector-java</artifactId>-->
-<!--			<version>8.0.29</version>-->
-<!--		</dependency>-->
-<!--        <dependency>-->
-<!--            <groupId>io.trino</groupId>-->
-<!--            <artifactId>trino-jdbc</artifactId>-->
-<!--            <version>400</version>-->
-<!--        </dependency>-->
         <dependency>
             <groupId>com.facebook.presto</groupId>
             <artifactId>presto-jdbc</artifactId>
             <version>0.277</version>
         </dependency>
 <!--        <dependency>-->
-<!--            <groupId>com.facebook.presto</groupId>-->
-<!--            <artifactId>presto-mysql</artifactId>-->
-<!--            <version>0.245</version>-->
-<!--            <scope>provided</scope>-->
-<!--            <exclusions>-->
-<!--                <exclusion>-->
-<!--                    <groupId>org.slf4j</groupId>-->
-<!--                    <artifactId>jcl-over-slf4j</artifactId>-->
-<!--                </exclusion>-->
-<!--                <exclusion>-->
-<!--                    <groupId>ch.qos.logback</groupId>-->
-<!--                    <artifactId>logback-classic</artifactId>-->
-<!--                </exclusion>-->
-<!--                <exclusion>-->
-<!--                    <groupId>ch.qos.logback</groupId>-->
-<!--                    <artifactId>logback-classic</artifactId>-->
-<!--                </exclusion>-->
-<!--                <exclusion>-->
-<!--                    <groupId>ch.qos.logback</groupId>-->
-<!--                    <artifactId>logback-examples</artifactId>-->
-<!--                </exclusion>-->
-<!--            </exclusions>-->
-<!--        </dependency>-->
-<!--        <dependency>-->
-<!--            <groupId>com.facebook.presto</groupId>-->
-<!--            <artifactId>presto-client</artifactId>-->
-<!--            <version>0.245</version>-->
+<!--            <groupId>io.trino</groupId>-->
+<!--            <artifactId>trino-jdbc</artifactId>-->
+<!--            <version>400</version>-->
 <!--        </dependency>-->
+
         <!-- Oracle, SQLServer 等其它数据库的 JDBC 驱动，可以在这里加上 Maven 依赖或 libs 目录放 Jar 包并依赖 -->
 
 		<!-- 需要用的 SpringBoot 框架，1.4.0 以上 -->

APIJSON-Java-Server/APIJSONDemo-BigData/README.md renamed to APIJSON-Java-Server/APIJSONDemo-Presto/README.md

@@ -29,7 +29,6 @@
 import apijson.framework.APIJSONApplication;
 import apijson.framework.APIJSONCreator;
 import apijson.orm.SQLConfig;
-import apijson.orm.SQLExecutor;
 
 
 /**
@@ -82,11 +81,6 @@ public void addCorsMappings(CorsRegistry registry) {
             public SQLConfig createSQLConfig() {
                 return new DemoSQLConfig();
             }
-
-            @Override
-            public SQLExecutor createSQLExecutor() {
-                return new DemoSQLExecutor();
-            }
         };
 
         try { //加载驱动程序
@@ -109,37 +103,6 @@ public SQLExecutor createSQLExecutor() {
         //    Log.e(TAG, "加载 Trino 驱动失败，请检查 pom.xml 中 TrinoDriver 版本是否存在以及可用 ！！！");
         //}
 
-        //// 需要用到的数据库驱动，如果这里没有可以自己新增
-        //try { //加载驱动程序
-        //    Log.d(TAG, "尝试加载 ClickHouse 驱动 <<<<<<<<<<<<<<<<<<<<< ");
-        //    Class.forName("ru.yandex.clickhouse.ClickHouseDriver");
-        //    Log.d(TAG, "成功加载 ClickHouse 驱动！>>>>>>>>>>>>>>>>>>>>> ");
-        //}
-        //catch (ClassNotFoundException e) {
-        //    e.printStackTrace();
-        //    Log.e(TAG, "加载 ClickHouse 驱动失败，请检查 pom.xml 中 ClickHouseDriver 版本是否存在以及可用 ！！！");
-        //}
-        //
-        //try { //加载驱动程序
-        //    Log.d(TAG, "尝试加载 Hadoop Hive 驱动 <<<<<<<<<<<<<<<<<<<<< ");
-        //    Class.forName("org.apache.hadoop.hive.jdbc.HiveDriver");
-        //    Log.d(TAG, "成功加载 Hadoop Hive 驱动！>>>>>>>>>>>>>>>>>>>>> ");
-        //}
-        //catch (ClassNotFoundException e) {
-        //    e.printStackTrace();
-        //    Log.e(TAG, "加载 Hive 驱动失败，请检查 pom.xml 中 HiveDriver 版本是否存在以及可用 ！！！");
-        //}
-        //
-        //try { //加载驱动程序
-        //    Log.d(TAG, "尝试加载 HBase PhoenixDriver 驱动 <<<<<<<<<<<<<<<<<<<<< ");
-        //    Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
-        //    Log.d(TAG, "成功加载 PhoenixDriver 驱动！>>>>>>>>>>>>>>>>>>>>> ");
-        //}
-        //catch (ClassNotFoundException e) {
-        //    e.printStackTrace();
-        //    Log.e(TAG, "加载 HBase PhoenixDriver 驱动失败，请检查 pom.xml 中 PhoenixDriver 版本是否存在以及可用 ！！！");
-        //}
-
     }
 
 }

APIJSON-Java-Server/APIJSONDemo-BigData/pom.xml renamed to APIJSON-Java-Server/APIJSONDemo-Presto/pom.xml

@@ -14,11 +14,6 @@
 
 package apijson.demo;
 
-import java.net.URLDecoder;
-import java.util.Map;
-
-import javax.servlet.http.HttpSession;
-
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -27,6 +22,11 @@
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.net.URLDecoder;
+import java.util.Map;
+
+import javax.servlet.http.HttpSession;
+
 import apijson.RequestMethod;
 import apijson.StringUtil;
 import apijson.framework.APIJSONController;

APIJSON-Java-Server/APIJSONDemo-BigData/src/main/java/apijson/demo/DemoApplication.java renamed to APIJSON-Java-Server/APIJSONDemo-Presto/src/main/java/apijson/demo/DemoApplication.java

@@ -28,7 +28,7 @@
 public class DemoSQLConfig extends APIJSONSQLConfig {
 
 	static {
-		DEFAULT_DATABASE = DATABASE_MYSQL;  // TODO 默认数据库类型，改成你自己的
+		DEFAULT_DATABASE = DATABASE_PRESTO;  // TODO 默认数据库类型，改成你自己的
 		DEFAULT_SCHEMA = "sys";  // TODO 默认数据库名/模式，改成你自己的，默认情况是 MySQL: sys, PostgreSQL: public, SQL Server: dbo, Oracle: 
 
         // 表名和数据库不一致的，需要配置映射关系。只使用 APIJSONORM 时才需要；
@@ -44,15 +44,12 @@ public class DemoSQLConfig extends APIJSONSQLConfig {
 
 	@Override
 	public String getDBVersion() {
-		return "5.7.22";  // "8.0.11";  // TODO 改成你自己的 MySQL 或 PostgreSQL 数据库版本号  // MYSQL 8 和 7 使用的 JDBC 配置不一样
+		return "8.0.11";  // TODO 改成你自己的 MySQL 或 PostgreSQL 数据库版本号  // MYSQL 8 和 7 使用的 JDBC 配置不一样
 	}
 
 	@JSONField(serialize = false)  // 不在日志打印 账号/密码 等敏感信息
 	@Override
 	public String getDBUri() {
-        if (isElasticsearch()) {
-            return "jdbc:es://http://localhost:9200/?timezone=UTC&page.size=250";
-        }
         if (isPresto()) { // Presto 配置文档  https://prestodb.io/docs/current/installation/jdbc.html
             return "jdbc:presto://localhost:8099/mysql?SSL=false";
         }
@@ -66,12 +63,26 @@ public String getDBUri() {
 	@JSONField(serialize = false)  // 不在日志打印 账号/密码 等敏感信息
 	@Override
 	public String getDBAccount() {
+        if (isPresto()) {
+            return "root";
+        }
+        if (isTrino()) {
+            return "root";
+        }
+
 		return "root";  // TODO 改成你自己的
 	}
 
 	@JSONField(serialize = false)  // 不在日志打印 账号/密码 等敏感信息
 	@Override
 	public String getDBPassword() {
+        if (isPresto()) {
+            return null;
+        }
+        if (isTrino()) {
+            return null;
+        }
+
 		return "apijson";  // TODO 改成你自己的，TiDB 可以当成 MySQL 使用， 默认密码为空字符串 ""
 	}
 

APIJSON-Java-Server/APIJSONDemo-BigData/src/main/java/apijson/demo/DemoController.java renamed to APIJSON-Java-Server/APIJSONDemo-Presto/src/main/java/apijson/demo/DemoController.java

@@ -1,4 +1,4 @@
-# PrestoDB 的配置文件 Demo
+# Presto(PrestoDB) 的配置文件 Demo
 
 复制到 Presto Server 源文件根目录，具体参考官方文档：<br />
 

APIJSON-Java-Server/APIJSONDemo-BigData/src/main/java/apijson/demo/DemoSQLConfig.java renamed to APIJSON-Java-Server/APIJSONDemo-Presto/src/main/java/apijson/demo/DemoSQLConfig.java

@@ -1,4 +1,4 @@
 connector.name=postgresql
-connection-url=jdbc:postgresql://postgres:5432
+connection-url=jdbc:postgresql://localhost:5432
 connection-user=root
 connection-password=apijson

APIJSON-Java-Server/APIJSONDemo-BigData/src/main/resources/application.properties renamed to APIJSON-Java-Server/APIJSONDemo-Presto/src/main/resources/application.properties

@@ -0,0 +1,5 @@
+# Trino(PrestoSQL) 的配置文件 Demo
+
+复制到 Trino Server 源文件根目录，具体参考官方文档：<br />
+
+https://trino.io/docs/current/installation/deployment.html

APIJSON-Java-Server/APIJSONDemo-BigData/etc/README.md renamed to Presto/README.md

@@ -0,0 +1,2 @@
+connector.name=hive-hadoop2
+hive.metastore.uri=thrift://hive:9083

APIJSON-Java-Server/APIJSONDemo-BigData/etc/catalog/hive.properties renamed to Presto/etc/catalog/hive.properties

@@ -0,0 +1,3 @@
+connector.name=mongodb
+mongodb.seeds=mongodb
+

APIJSON-Java-Server/APIJSONDemo-BigData/etc/catalog/mongodb.properties renamed to Presto/etc/catalog/mongodb.properties

@@ -0,0 +1,4 @@
+connector.name=mysql
+connection-url=jdbc:mysql://localhost:3306
+connection-user=root
+connection-password=apijson

APIJSON-Java-Server/APIJSONDemo-BigData/etc/catalog/mysql.properties renamed to Presto/etc/catalog/mysql.properties

@@ -0,0 +1,4 @@
+connector.name=postgresql
+connection-url=jdbc:postgresql://localhost:5432
+connection-user=root
+connection-password=apijson

APIJSON-Java-Server/APIJSONDemo-BigData/etc/catalog/postgres.properties renamed to Presto/etc/catalog/postgres.properties

@@ -0,0 +1 @@
+connector.name=tpch

APIJSON-Java-Server/APIJSONDemo-BigData/etc/catalog/tcph.properties renamed to Presto/etc/catalog/tcph.properties

@@ -0,0 +1,8 @@
+coordinator=true
+node-scheduler.include-coordinator=true
+http-server.http.port=8099
+discovery-server.enabled=true
+discovery.uri=http://localhost:8099
+
+query.max-memory=500MB
+query.max-memory-per-node=200MB

APIJSON-Java-Server/APIJSONDemo-BigData/etc/config.properties renamed to Presto/etc/config.properties

@@ -0,0 +1,5 @@
+-Xmx1G
+-XX:+UseG1GC
+-XX:G1HeapRegionSize=32M
+-XX:+UseGCOverheadLimit
+-XX:+ExplicitGCInvokesConcurrent

APIJSON-Java-Server/APIJSONDemo-BigData/etc/jvm.config renamed to Presto/etc/jvm.config

@@ -0,0 +1,3 @@
+node.environment=test
+node.id=test
+node.data-dir=/var/lib/presto/data