diff --git a/datachecker-check/src/main/java/org/opengauss/datachecker/check/slice/SliceCheckEventHandler.java b/datachecker-check/src/main/java/org/opengauss/datachecker/check/slice/SliceCheckEventHandler.java
index 0e7771b786740b219d1ef773c9c5ba954e7561c8..36d7218a03e68c0a71140cde2551e74adeefaf16 100644
--- a/datachecker-check/src/main/java/org/opengauss/datachecker/check/slice/SliceCheckEventHandler.java
+++ b/datachecker-check/src/main/java/org/opengauss/datachecker/check/slice/SliceCheckEventHandler.java
@@ -93,9 +93,7 @@ public class SliceCheckEventHandler {
      */
     public void handleFailed(SliceCheckEvent checkEvent) {
         LogUtils.warn(log, "slice check event , table slice has unknown error [{}][{} : {}]", checkEvent.getCheckName(),
-                checkEvent.getSource()
-                        .getTableHash(), checkEvent.getSink()
-                        .getTableHash());
+                checkEvent.getSource(), checkEvent.getSink());
         long count = getCheckSliceCount(checkEvent);
         sliceCheckContext.refreshSliceCheckProgress(checkEvent.getSlice(), count);
         CheckDiffResult result = buildSliceDiffResult(checkEvent.getSlice(), (int) count, true, "slice has unknown error");
diff --git a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/MysqlDataAccessService.java b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/MysqlDataAccessService.java
index 40319a2872ca28d42b2a0d5903fea28d9d106aaf..8383c694dfca380874aa78623e07baeabbe40ca8 100644
--- a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/MysqlDataAccessService.java
+++ b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/MysqlDataAccessService.java
@@ -65,8 +65,8 @@ public class MysqlDataAccessService extends AbstractDataAccessService {
     @Override
     public List<String> dasQueryTableNameList() {
         String schema = properties.getSchema();
-        String sql = "SELECT info.table_name tableName FROM information_schema.tables info WHERE table_schema='"
-                + schema + "'";
+        String sql = "select info.table_name tableName from information_schema.tables info where table_schema='"
+                + schema + "'  and table_type='BASE TABLE'";
         return adasQueryTableNameList(sql);
     }
 
diff --git a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/OpgsDataAccessService.java b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/OpgsDataAccessService.java
index 6b5dca7e6a359b1015d8e016ff17d556ce985050..d910ef588925970a78950d567a406df248176541 100644
--- a/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/OpgsDataAccessService.java
+++ b/datachecker-extract/src/main/java/org/opengauss/datachecker/extract/data/access/OpgsDataAccessService.java
@@ -27,6 +27,7 @@ import org.opengauss.datachecker.common.entry.extract.TableMetadata;
 import org.opengauss.datachecker.extract.data.mapper.OpgsMetaDataMapper;
 
 import javax.annotation.PostConstruct;
+
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -75,22 +76,43 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
         return health(schema, sql);
     }
 
+    /**
+     * <pre>
+     * DAS查询表名列表
+     *  select c.relname tableName from pg_class c  LEFT JOIN pg_namespace n on n.oid = c.relnamespace
+     *  where n.nspname=? and c.relkind ='r';
+     *  </pre>
+     *
+     * @return tableNameList
+     */
     @Override
     public List<String> dasQueryTableNameList() {
         String schema = properties.getSchema();
         String sql = "select c.relname tableName from pg_class c  LEFT JOIN pg_namespace n on n.oid = c.relnamespace "
-                + " where n.nspname='" + schema + "' and c.relkind ='r';";
+            + " where n.nspname='" + schema + "' and c.relkind ='r';";
         return adasQueryTableNameList(sql);
     }
 
+    /**
+     * <pre>
+     *     查询表主键列信息
+     *      select c.relname tableName,ns.nspname,ns.oid,a.attname columnName from pg_class c
+     *      left join pg_namespace ns on c.relnamespace=ns.oid
+     *      left join pg_attribute a on c.oid=a.attrelid and a.attnum>0 and not a.attisdropped
+     *      inner join pg_constraint cs on a.attrelid=cs.conrelid and a.attnum=any(cs.conkey)
+     *      where ns.nspname='test' and cs.contype='p';
+     * </pre>
+     *
+     * @return primaryColumnList 主键列信息列表
+     */
     @Override
     public List<PrimaryColumnBean> queryTablePrimaryColumns() {
         String schema = properties.getSchema();
         String sql = "select c.relname tableName,ns.nspname,ns.oid,a.attname columnName from pg_class c "
-                + "left join pg_namespace ns on c.relnamespace=ns.oid "
-                + "left join pg_attribute a on c.oid=a.attrelid and a.attnum>0 and not a.attisdropped "
-                + "inner join pg_constraint cs on a.attrelid=cs.conrelid and a.attnum=any(cs.conkey) "
-                + "where ns.nspname='" + schema + "' and cs.contype='p';";
+            + "left join pg_namespace ns on c.relnamespace=ns.oid "
+            + "left join pg_attribute a on c.oid=a.attrelid and a.attnum>0 and not a.attisdropped "
+            + "inner join pg_constraint cs on a.attrelid=cs.conrelid and a.attnum=any(cs.conkey) "
+            + "where ns.nspname='" + schema + "' and cs.contype='p';";
         return adasQueryTablePrimaryColumns(sql);
     }
 
@@ -98,10 +120,10 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
     public List<PrimaryColumnBean> queryTablePrimaryColumns(String tableName) {
         String schema = properties.getSchema();
         String sql = "select c.relname tableName,ns.nspname,ns.oid,a.attname columnName from pg_class c "
-                + "left join pg_namespace ns on c.relnamespace=ns.oid "
-                + "left join pg_attribute a on c.oid=a.attrelid and a.attnum>0 and not a.attisdropped "
-                + "inner join pg_constraint cs on a.attrelid=cs.conrelid and a.attnum=any(cs.conkey) "
-                + "where ns.nspname='" + schema + "' and c.relname='" + tableName + "' and cs.contype='p';";
+            + "left join pg_namespace ns on c.relnamespace=ns.oid "
+            + "left join pg_attribute a on c.oid=a.attrelid and a.attnum>0 and not a.attisdropped "
+            + "inner join pg_constraint cs on a.attrelid=cs.conrelid and a.attnum=any(cs.conkey) "
+            + "where ns.nspname='" + schema + "' and c.relname='" + tableName + "' and cs.contype='p';";
         return adasQueryTablePrimaryColumns(sql);
     }
 
@@ -119,12 +141,12 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
     public List<TableMetadata> dasQueryTableMetadataList() {
         LowerCaseTableNames lowerCaseTableNames = getLowerCaseTableNames();
         String colTableName = Objects.equals(LowerCaseTableNames.SENSITIVE, lowerCaseTableNames)
-                ? "c.relname tableName"
-                : "lower(c.relname) tableName";
+            ? "c.relname tableName"
+            : "lower(c.relname) tableName";
         String sql = " select n.nspname tableSchema, " + colTableName + ",c.reltuples tableRows, "
-                + "case when c.reltuples>0 then pg_table_size(c.oid)/c.reltuples else 0 end as avgRowLength "
-                + "from pg_class c LEFT JOIN pg_namespace n on n.oid = c.relnamespace " + "where n.nspname='"
-                + properties.getSchema() + "' and c.relkind ='r';";
+            + "case when c.reltuples>0 then pg_table_size(c.oid)/c.reltuples else 0 end as avgRowLength "
+            + "from pg_class c LEFT JOIN pg_namespace n on n.oid = c.relnamespace " + "where n.nspname='"
+            + properties.getSchema() + "' and c.relkind ='r';";
         return wrapperTableMetadata(adasQueryTableMetadataList(sql));
     }
 
@@ -153,9 +175,9 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
     @Override
     public List<Object> queryPointList(Connection connection, DataAccessParam param) {
         String sql = "select s.%s from ( select row_number() over(order by r.%s  asc) as rn,r.%s  from %s.%s r) s"
-                + "  where mod(s.rn, %s ) = 1;";
+            + "  where mod(s.rn, %s ) = 1;";
         sql = String.format(sql, param.getColName(), param.getColName(), param.getColName(), param.getSchema(),
-                param.getName(), param.getOffset());
+            param.getName(), param.getOffset());
         return adasQueryPointList(connection, sql);
     }
 
@@ -164,7 +186,6 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
         return opgsMetaDataMapper.checkDatabaseNotEmpty(properties.getSchema());
     }
 
-
     @Override
     public LowerCaseTableNames queryLowerCaseTableNames() {
         String sql = "SHOW VARIABLES  LIKE \"lower_case_table_names\";";
@@ -181,7 +202,8 @@ public class OpgsDataAccessService extends AbstractDataAccessService {
         } finally {
             closeConnection(connection);
         }
-        return isOgCompatibilityB() ? result.getOrDefault(DOLPHIN_LOWER_CASE_TABLE_NAMES, LowerCaseTableNames.UNKNOWN)
-                : result.getOrDefault(LOWER_CASE_TABLE_NAMES, LowerCaseTableNames.UNKNOWN);
+        return isOgCompatibilityB()
+            ? result.getOrDefault(DOLPHIN_LOWER_CASE_TABLE_NAMES, LowerCaseTableNames.UNKNOWN)
+            : result.getOrDefault(LOWER_CASE_TABLE_NAMES, LowerCaseTableNames.UNKNOWN);
     }
 }