修复Doris无法获取到列的主键信息

dlink-metadata/dlink-metadata-base/src/main/java/com/dlink/metadata/driver/AbstractJdbcDriver.java

@@ -193,7 +193,7 @@ public abstract class AbstractJdbcDriver extends AbstractDriver {
                 String columnName = results.getString(dbQuery.columnName());
                 if (columnList.contains(dbQuery.columnKey())) {
                     String key = results.getString(dbQuery.columnKey());
-                    field.setKeyFlag(Asserts.isNotNullString(key) && Asserts.isEqualsIgnoreCase("PRI", key));
+                    field.setKeyFlag(Asserts.isNotNullString(key) && Asserts.isEqualsIgnoreCase(dbQuery.isPK(), key));
                 }
                 field.setName(columnName);
                 if (columnList.contains(dbQuery.columnType())) {

dlink-metadata/dlink-metadata-base/src/main/java/com/dlink/metadata/query/AbstractDBQuery.java

@@ -132,4 +132,9 @@ public abstract class AbstractDBQuery implements IDBQuery {
     public String collation() {
         return "COLLATION_NAME";
     }
+
+    @Override
+    public String isPK() {
+        return "PRI";
+    }
 }

dlink-metadata/dlink-metadata-base/src/main/java/com/dlink/metadata/query/IDBQuery.java

@@ -146,4 +146,9 @@ public interface IDBQuery {
      * 自定义字段名称
      */
     String[] columnCustom();
+
+    /**
+     * @return 主键值
+     */
+    String isPK();
 }

dlink-metadata/dlink-metadata-doris/src/main/java/com/dlink/metadata/query/DorisQuery.java

@@ -101,4 +101,9 @@ public class DorisQuery extends AbstractDBQuery {
     public String autoIncrement() {
         return "Default";
     }
+
+    @Override
+    public String isPK() {
+        return "YES";
+    }
 }

dlink-web/src/pages/Welcome.tsx

@@ -779,6 +779,9 @@ export default (): React.ReactNode => {
                 <li>
                   <Link>新增 实时任务监控容错机制</Link>
                 </li>
+                <li>
+                  <Link>修复 Doris无法获取到列的主键信息</Link>
+                </li>
               </ul>
             </Paragraph>
           </Timeline.Item>