获取数据库表（草稿）

原理

要通过 JDBC 驱动获取数据库中的表、视图等对象信息，核心是利用 JDBC 规范中定义的数据库元数据（Database Metadata） 机制，具体流程如下：

建立数据库连接
首先通过 JDBC 驱动加载并建立与目标数据库的连接（Connection对象），这是获取元数据的前提。例如，通过DriverManager.getConnection(url, username, password)方法获得连接，其中url需指定数据库类型（如 MySQL、Oracle 等），驱动会根据类型适配对应的连接逻辑。
获取数据库元数据对象
调用Connection对象的getMetaData()方法，得到DatabaseMetaData对象。该对象封装了数据库的元数据信息，包括数据库产品名称、版本、支持的功能，以及最重要的表、视图、列等对象的结构信息。
通过元数据查询表、视图等对象
DatabaseMetaData提供了一系列专门用于查询数据库对象的方法，常用的包括：
- 获取表信息：调用getTables(String catalog, String schema, String tableNamePattern, String[] types)方法。其中：
  - catalog和schema分别对应数据库的目录和模式（不同数据库对这两个概念的实现有差异，如 MySQL 的catalog对应数据库名，Oracle 的schema通常对应用户名）；
  - tableNamePattern用于模糊匹配表名（如"%"表示所有表）；
  - types指定要查询的对象类型，传入{"TABLE"}可获取表，传入{"VIEW"}可获取视图，若需同时查询则传入{"TABLE", "VIEW"}。
- 方法返回ResultSet结果集，包含表 / 视图的名称、类型、所属模式等信息，可通过getString("TABLE_NAME")、getString("TABLE_TYPE")等方法提取具体字段。
处理结果并关闭资源
遍历查询得到的ResultSet，提取所需的表、视图名称或其他属性后，依次关闭结果集、元数据对象和数据库连接，避免资源泄露。

简言之，JDBC 驱动通过封装数据库底层的元数据查询逻辑，向上提供统一的DatabaseMetaData接口，开发者无需关注不同数据库的内部实现差异，只需调用标准方法即可便捷地获取表、视图等对象信息。这一机制体现了 JDBC “面向接口编程” 的设计思想，保证了数据库操作的跨平台性。

使用方法

1.下载JdbcTableLoader.java文件（md5hash：dd071f3d53f752a9afe24f45721f096d），放到服务器上，使用javac JdbcTableLoader.java编译成JdbcTableLoader.class文件。如果服务器没有javac工具，可以下载编译后的JdbcTableLoader.class文件（md5sum：37e597df1f420d3875f4037a3ac92d89）。

JdbcTableLoader.classJdbcTableLoader.java

2.下载config.properties文件，放于JdbcTableLoader.java相同目录，将数据库信息填写到文件中。

config.properties

3.执行java JdbcTableLoader命令查看结果

代码示例

JdbcTableLoader.java

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.net.URL;
import java.net.URLClassLoader;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;
import java.sql.Driver;

/**
 * JDBC驱动加载器和表信息获取器
 */
public class JdbcTableLoader implements AutoCloseable {
    
    private Properties config;
    private Connection connection;
    private Class driverClass;
    
    public JdbcTableLoader(String configFile) throws IOException {
        loadConfig(configFile);
    }
    
    /**
     * 加载配置文件
     */
    private void loadConfig(String configFile) throws IOException {
        System.out.println("加载配置文件: " + new File(configFile).getAbsolutePath());
        config = new Properties();
        try (FileInputStream fis = new FileInputStream(configFile)) {
            config.load(fis);
        }
    }
    
    /**
     * 加载JDBC驱动
     */
    public void loadDriver() throws Throwable {
        String libDir = config.getProperty("jdbc.lib.dir");
        String driverClassName = config.getProperty("jdbc.driver.class");
        
        // 加载lib目录下的所有jar包
        File libFolder = new File(libDir);
        if (!libFolder.exists() || !libFolder.isDirectory()) {
            throw new RuntimeException("驱动目录不存在: " + libDir);
        }
        
        List<URL> urls = new ArrayList<>();
        File[] jarFiles = libFolder.listFiles((dir, name) -> name.endsWith(".jar"));
        if (jarFiles != null) {
            for (File jarFile : jarFiles) {
                urls.add(jarFile.toURI().toURL());
            }
        }
        
        // 创建类加载器并加载驱动
        URLClassLoader classLoader = new URLClassLoader(urls.toArray(new URL[0]));
        // 某些驱动需要设置当前线程的类加载器
        Thread.currentThread().setContextClassLoader(classLoader);
        driverClass =  classLoader.loadClass(driverClassName);
        System.out.println("JDBC驱动加载成功: " + driverClass);
    }
    
    /**
     * 建立数据库连接
     */
    public void connect() throws Throwable {
        String url = config.getProperty("jdbc.url");
        String username = config.getProperty("jdbc.username");
        String password = config.getProperty("jdbc.password");
        Properties info = new Properties();
        info.put("user", username);
        info.put("password", password);
        connection = ((Driver) driverClass.getConstructor().newInstance()).connect(url, info);
        System.out.println("数据库连接成功");
    }
    
    /**
     * 获取指定catalog和schema的表信息
     */
    public List<String> getTables() throws Exception {
        String catalog = config.getProperty("jdbc.catalog");
        String schema = config.getProperty("jdbc.schema");
        String tableTypes = config.getProperty("jdbc.table.types");
        System.out.println("catalog: " + catalog);
        System.out.println("schema: " + schema);
        System.out.println("tableTypes: " + tableTypes);
        if (tableTypes == null || tableTypes.isEmpty()) {
            tableTypes = "TABLE,VIEW,MATERIALIZED QUERY TABLE,SYNONYM,ALIAS,EXTERNAL TABLE";
        }
        String tableMaxString = config.getProperty("jdbc.table.max");
        int maxTableCount = 100;
        try {   
            maxTableCount = Integer.parseInt(tableMaxString);
        } catch (NumberFormatException e) {
            // 默认100
        }
        
        List<String> tables = new ArrayList<>();
        DatabaseMetaData metaData = connection.getMetaData();
        
        try (ResultSet rs = metaData.getTables(catalog, schema, "%", tableTypes.split(","))) {
            int count = 0;
            while (rs.next()) {
                if (count >= maxTableCount) {
                    break;
                }
                count++;
                String tableName = rs.getString("TABLE_NAME");
                tables.add(tableName);
                System.out.println("发现表: " + tableName);
            }
        }
        
        return tables;
    }
    
    /**
     * 关闭连接
     */
    @Override
    public void close() {
        if (connection != null) {
            try {
                connection.close();
                System.out.println("数据库连接已关闭");
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * 主方法，用于测试
     */
    public static void main(String[] args) {
        long start = System.currentTimeMillis();
        try (JdbcTableLoader loader = new JdbcTableLoader("config.properties")) {
            loader.loadDriver();
            loader.connect();
            List<String> tables = loader.getTables();
            System.out.println("展示 " + tables.size() + " 个表");
            long end = System.currentTimeMillis();
            System.out.println("耗时: " + (end - start) + " 毫秒");
        } catch (Throwable e) {
            e.printStackTrace();
        }
    }
}

config.properties

# JDBC驱动目录
jdbc.lib.dir=C:\\Users\\heybo\\Downloads\\2025-06-25\\lib

# JDBC驱动类名
jdbc.driver.class=com.mysql.jdbc.Driver

# 数据库连接URL
jdbc.url=jdbc:mysql://10.10.13.188:6688/writedb_hyb?useOldAliasMetadataBehavior=true&useUnicode=true&characterEncoding=GBK&zeroDateTimeBehavior=convertToNull&useCursorFetch=true&defaultFetchSize=-2147483648&useSSL=false

# 数据库用户名
jdbc.username=admin

# 数据库密码
jdbc.password=admin

# 数据库catalog
jdbc.catalog=smartbidemo

# 数据库schema
jdbc.schema= 

# 获取表类型，英文逗号隔开
jdbc.table.types=TABLE,VIEW,MATERIALIZED QUERY TABLE,SYNONYM,ALIAS,EXTERNAL TABLE

# 最多获取多少张表
jdbc.table.max=1

关注我们

服务支持

页面树结构

获取数据库表（草稿）

原理

使用方法

代码示例