1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.data.pipeline.core.exception.data;
19
20 import org.apache.shardingsphere.infra.exception.core.external.sql.sqlstate.XOpenSQLState;
21
22 import javax.annotation.Nullable;
23
24
25
26
27 public final class PipelineTableDataConsistencyCheckLoadingFailedException extends PipelineDataException {
28
29 private static final long serialVersionUID = 8965231249677009738L;
30
31 public PipelineTableDataConsistencyCheckLoadingFailedException(@Nullable final String schemaName, final String tableName) {
32 this(schemaName, tableName, null);
33 }
34
35 public PipelineTableDataConsistencyCheckLoadingFailedException(@Nullable final String schemaName, final String tableName, final Exception cause) {
36 super(XOpenSQLState.CONNECTION_EXCEPTION, 1, String.format("Data check table '%s' failed.", null != schemaName ? schemaName + "." + tableName : tableName), cause);
37 }
38 }