This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 8d50588 Adjusted exception type (#14365)
8d50588 is described below
commit 8d505885a840fdc6c3b552ac2c595ec05c448dec
Author: Himanshu <addyjeri...@gmail.com>
AuthorDate: Wed Dec 29 18:10:06 2021 +0530
Adjusted exception type (#14365)
* Adjusted exception type
* Update ShowStatementExecutorFactory.java
* Update SetStatementExecutorFactory.java
* Update HintStatementExecutorFactory.java
* Update CommonDistSQLBackendHandlerFactory.java
* Update AdvancedDistSQLBackendHandlerFactory.java
* Update DistSQLBackendHandlerFactory.java
Co-authored-by: Liang Zhang <terrym...@163.com>
Co-authored-by: Liang Zhang <zhangli...@apache.org>
---
.../proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java | 3 +--
.../distsql/ral/advanced/AdvancedDistSQLBackendHandlerFactory.java | 3 +--
.../text/distsql/ral/common/CommonDistSQLBackendHandlerFactory.java | 3 +--
.../text/distsql/ral/common/hint/HintStatementExecutorFactory.java | 3 +--
.../text/distsql/ral/common/set/SetStatementExecutorFactory.java | 3 +--
.../text/distsql/ral/common/show/ShowStatementExecutorFactory.java | 3 +--
6 files changed, 6 insertions(+), 12 deletions(-)
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
index 5860965..6382244 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/DistSQLBackendHandlerFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.distsql.parser.statement.DistSQLStatement;
@@ -58,6 +57,6 @@ public final class DistSQLBackendHandlerFactory {
if (sqlStatement instanceof RALStatement) {
return RALBackendHandlerFactory.newInstance(databaseType,
(RALStatement) sqlStatement, connectionSession);
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/AdvancedDistSQLBackendHandlerFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/AdvancedDistSQLBackendHandlerFactory.java
index 508fc1f..1996bf8 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/AdvancedDistSQLBackendHandlerFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/advanced/AdvancedDistSQLBackendHandlerFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql.ral.advanced;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.distsql.parser.statement.ral.AdvancedDistSQLStatement;
@@ -51,6 +50,6 @@ public final class AdvancedDistSQLBackendHandlerFactory {
} else if (sqlStatement instanceof ParseStatement) {
return new ParseDistSQLBackendHandler(databaseType,
(ParseStatement) sqlStatement, connectionSession);
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/CommonDistSQLBackendHandlerFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/CommonDistSQLBackendHandlerFactory.java
index 659eaac..f6eaa99 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/CommonDistSQLBackendHandlerFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/CommonDistSQLBackendHandlerFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql.ral.common;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.distsql.parser.statement.ral.CommonDistSQLStatement;
@@ -61,6 +60,6 @@ public final class CommonDistSQLBackendHandlerFactory {
if (sqlStatement instanceof AlterDistSQLStatement) {
return new AlterDistSQLBackendHandler((AlterDistSQLStatement)
sqlStatement, connectionSession);
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/hint/HintStatementExecutorFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/hint/HintStatementExecutorFactory.java
index ac1111b..0fc27b7 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/hint/HintStatementExecutorFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/hint/HintStatementExecutorFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql.ral.common.hint;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.HintDistSQLStatement;
@@ -85,6 +84,6 @@ public final class HintStatementExecutorFactory {
if (sqlStatement instanceof ClearShardingHintStatement) {
return new ClearShardingHintExecutor();
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/set/SetStatementExecutorFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/set/SetStatementExecutorFactory.java
index 84e9fda..4822e13 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/set/SetStatementExecutorFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/set/SetStatementExecutorFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql.ral.common.set;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.SetDistSQLStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.set.SetInstanceStatusStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.set.SetVariableStatement;
@@ -52,6 +51,6 @@ public final class SetStatementExecutorFactory {
if (sqlStatement instanceof SetInstanceStatusStatement) {
return new SetInstanceStatusExecutor((SetInstanceStatusStatement)
sqlStatement);
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
diff --git
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/show/ShowStatementExecutorFactory.java
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/show/ShowStatementExecutorFactory.java
index a4f75a1..9700ceb 100644
---
a/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/show/ShowStatementExecutorFactory.java
+++
b/shardingsphere-proxy/shardingsphere-proxy-backend/src/main/java/org/apache/shardingsphere/proxy/backend/text/distsql/ral/common/show/ShowStatementExecutorFactory.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.proxy.backend.text.distsql.ral.common.show;
-import com.mchange.v1.db.sql.UnsupportedTypeException;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.ShowDistSQLStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.show.ShowAllVariablesStatement;
import
org.apache.shardingsphere.distsql.parser.statement.ral.common.show.ShowAuthorityRuleStatement;
@@ -67,6 +66,6 @@ public final class ShowStatementExecutorFactory {
if (sqlStatement instanceof ShowAuthorityRuleStatement) {
return new ShowAuthorityRuleExecutor(connectionSession);
}
- throw new
UnsupportedTypeException(sqlStatement.getClass().getCanonicalName());
+ throw new
UnsupportedOperationException(sqlStatement.getClass().getCanonicalName());
}
}
