feat(metadata): 新增数个常用Metadata读取操作方法。

impl/src/main/java/cc/carm/lib/easysql/builder/impl/TableMetadataBuilderImpl.java

@@ -1,13 +1,20 @@
 package cc.carm.lib.easysql.builder.impl;
 
 import cc.carm.lib.easysql.api.builder.TableMetadataBuilder;
+import cc.carm.lib.easysql.api.function.SQLBiFunction;
 import cc.carm.lib.easysql.api.function.SQLFunction;
 import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
+import java.sql.Connection;
 import java.sql.DatabaseMetaData;
 import java.sql.ResultSet;
+import java.util.Collections;
+import java.util.LinkedHashSet;
+import java.util.Optional;
+import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 
 public class TableMetadataBuilderImpl
@@ -23,12 +30,35 @@ public class TableMetadataBuilderImpl
 
     @Override
     public CompletableFuture<Boolean> validateExist() {
-        return validate((meta) -> meta.getTables(null, null, tablePattern, new String[]{"TABLE"}));
+        return validate((meta, conn) -> meta.getTables(conn.getCatalog(), conn.getSchema(), tablePattern.toUpperCase(), new String[]{"TABLE"}));
     }
 
     @Override
-    public CompletableFuture<Boolean> isColumnExists(String columnPattern) {
-        return validate((meta) -> meta.getColumns(null, null, tablePattern, columnPattern));
+    public <R> CompletableFuture<R> fetchColumns(@Nullable String columnPattern,
+                                                 @NotNull SQLFunction<ResultSet, R> reader) {
+        return getManager().fetchMetadata((meta, conn) -> meta.getColumns(
+                conn.getCatalog(), conn.getSchema(), tablePattern.toUpperCase(),
+                Optional.ofNullable(columnPattern).map(String::toUpperCase).orElse("%")
+        ), reader);
+    }
+
+    @Override
+    public CompletableFuture<Boolean> isColumnExists(@NotNull String columnPattern) {
+        return validate((meta, conn) -> meta.getColumns(
+                conn.getCatalog(), conn.getSchema(),
+                tablePattern.toUpperCase(), columnPattern.toUpperCase()
+        ));
+    }
+
+    @Override
+    public CompletableFuture<Set<String>> listColumns(@Nullable String columnPattern) {
+        return fetchColumns(columnPattern, (rs) -> {
+            Set<String> data = new LinkedHashSet<>();
+            while (rs.next()) {
+                data.add(rs.getString("COLUMN_NAME"));
+            }
+            return Collections.unmodifiableSet(data);
+        });
     }
 
     /**
@@ -37,7 +67,7 @@ public class TableMetadataBuilderImpl
      * @param supplier supplier to get result set
      * @return result future
      */
-    private CompletableFuture<Boolean> validate(SQLFunction<DatabaseMetaData, ResultSet> supplier) {
+    private CompletableFuture<Boolean> validate(SQLBiFunction<DatabaseMetaData, Connection, ResultSet> supplier) {
         return getManager().fetchMetadata(supplier, ResultSet::next);
     }
 

impl/src/main/java/cc/carm/lib/easysql/manager/SQLManagerImpl.java

@@ -10,6 +10,7 @@ import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
 import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.builder.*;
+import cc.carm.lib.easysql.api.function.SQLBiFunction;
 import cc.carm.lib.easysql.api.function.SQLDebugHandler;
 import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import cc.carm.lib.easysql.api.function.SQLFunction;
@@ -155,10 +156,10 @@ public class SQLManagerImpl implements SQLManager {
     }
 
     @Override
-    public <R> CompletableFuture<R> fetchMetadata(@NotNull SQLFunction<DatabaseMetaData, R> metadata) {
+    public <R> CompletableFuture<R> fetchMetadata(@NotNull SQLBiFunction<DatabaseMetaData, Connection, R> reader) {
         return CompletableFuture.supplyAsync(() -> {
             try (Connection conn = getConnection()) {
-                return metadata.apply(conn.getMetaData());
+                return reader.apply(conn.getMetaData(), conn);
             } catch (SQLException ex) {
                 throw new RuntimeException(ex);
             }
@@ -166,19 +167,16 @@ public class SQLManagerImpl implements SQLManager {
     }
 
     @Override
-    public <R> CompletableFuture<R> fetchMetadata(@NotNull SQLFunction<DatabaseMetaData, ResultSet> supplier,
+    public <R> CompletableFuture<R> fetchMetadata(@NotNull SQLBiFunction<DatabaseMetaData, Connection, ResultSet> supplier,
                                                   @NotNull SQLFunction<@NotNull ResultSet, R> reader) {
-        return CompletableFuture.supplyAsync(() -> {
-            try (
-                    Connection conn = getConnection();
-                    ResultSet rs = supplier.apply(conn.getMetaData())
-            ) {
+        return fetchMetadata((meta, conn) -> {
+            try (ResultSet rs = supplier.apply(conn.getMetaData(), conn)) {
                 if (rs == null) throw new NullPointerException("Metadata返回的ResultSet为null。");
                 else return reader.apply(rs);
             } catch (SQLException ex) {
                 throw new RuntimeException(ex);
             }
-        }, this.executorPool);
+        });
     }
 
     @Override