This is an automated email from the ASF dual-hosted git repository.

yx9o 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 248d6a6798c Remove useless PostgreSQLAuthenticationException (#20682)
248d6a6798c is described below

commit 248d6a6798c2e6363c70b18f168c58366387c45c
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Aug 31 17:37:47 2022 +0800

    Remove useless PostgreSQLAuthenticationException (#20682)
    
    * Remove useless PostgreSQLAuthenticationException
    
    * Remove useless PostgreSQLAuthenticationException
---
 .../PostgreSQLAuthenticationException.java         | 37 ----------------------
 .../migration/MigrationDataConsistencyChecker.java |  2 +-
 2 files changed, 1 insertion(+), 38 deletions(-)

diff --git 
a/shardingsphere-dialect-exception/shardingsphere-postgresql-dialect-exception/src/main/java/org/apache/shardingsphere/dialect/postgresql/exception/PostgreSQLAuthenticationException.java
 
b/shardingsphere-dialect-exception/shardingsphere-postgresql-dialect-exception/src/main/java/org/apache/shardingsphere/dialect/postgresql/exception/PostgreSQLAuthenticationException.java
deleted file mode 100644
index 94151cea24f..00000000000
--- 
a/shardingsphere-dialect-exception/shardingsphere-postgresql-dialect-exception/src/main/java/org/apache/shardingsphere/dialect/postgresql/exception/PostgreSQLAuthenticationException.java
+++ /dev/null
@@ -1,37 +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.shardingsphere.dialect.postgresql.exception;
-
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.dialect.exception.SQLDialectException;
-import 
org.apache.shardingsphere.dialect.postgresql.vendor.PostgreSQLVendorError;
-
-/**
- * PostgreSQL authentication exception.
- */
-@RequiredArgsConstructor
-@Getter
-public final class PostgreSQLAuthenticationException extends 
SQLDialectException {
-    
-    private static final long serialVersionUID = 1331782847269278560L;
-    
-    private final PostgreSQLVendorError vendorError;
-    
-    private final String message;
-}
diff --git 
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
 
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
index dd25752b284..201422f5ed0 100644
--- 
a/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
+++ 
b/shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/MigrationDataConsistencyChecker.java
@@ -81,7 +81,7 @@ public final class MigrationDataConsistencyChecker {
         this.jobConfig = jobConfig;
         sourceTableName = jobConfig.getSourceTableName();
         targetTableName = jobConfig.getTargetTableName();
-        tableNameSchemaNameMapping = new 
TableNameSchemaNameMapping(TableNameSchemaNameMapping.convert(jobConfig.getSourceSchemaName(),
 
+        tableNameSchemaNameMapping = new 
TableNameSchemaNameMapping(TableNameSchemaNameMapping.convert(jobConfig.getSourceSchemaName(),
                 new HashSet<>(Arrays.asList(jobConfig.getSourceTableName(), 
jobConfig.getTargetTableName()))));
         this.readRateLimitAlgorithm = readRateLimitAlgorithm;
     }

Reply via email to