Merge pull request #2829 from memorylorry/add-presto-support-20180927

add presto支持
This commit is contained in:
温绍锦
2018-10-03 19:52:35 +08:00
committed by GitHub
3 changed files with 8 additions and 2 deletions
@@ -109,6 +109,7 @@ public interface JdbcConstants {
String ALIYUN_DRDS = "aliyun_drds";
String PRESTO = "presto";
String PRESTO_DRIVER = "com.facebook.presto.jdbc.PrestoDriver";
String ELASTIC_SEARCH = "elastic_search";
@@ -470,7 +470,9 @@ public final class JdbcUtils implements JdbcConstants {
return JdbcConstants.ELASTIC_SEARCH_DRIVER;
} else if (rawUrl.startsWith("jdbc:clickhouse:")) {
return JdbcConstants.CLICKHOUSE_DRIVER;
} else {
} else if(rawUrl.startsWith("jdbc:presto:")) {
return JdbcConstants.PRESTO_DRIVER;
}else {
throw new SQLException("unkow jdbc driver : " + rawUrl);
}
}
@@ -563,6 +565,8 @@ public final class JdbcUtils implements JdbcConstants {
return ELASTIC_SEARCH;
} else if (rawUrl.startsWith("jdbc:clickhouse:")) {
return CLICKHOUSE;
}else if (rawUrl.startsWith("jdbc:presto:")) {
return PRESTO;
} else {
return null;
}
@@ -124,7 +124,8 @@ public class WallFilter extends FilterAdapter implements WallFilterMBean {
if (JdbcUtils.MYSQL.equals(dbType) || //
JdbcUtils.MARIADB.equals(dbType) || //
JdbcUtils.H2.equals(dbType)) {
JdbcUtils.H2.equals(dbType)||
JdbcUtils.PRESTO.equals(dbType)) {
if (config == null) {
config = new WallConfig(MySqlWallProvider.DEFAULT_CONFIG_DIR);
}