Spring JDBCTemplate结合MariaDB Connector的元数据适配问题

1. 用MariaDB连接属性替代nullDatabaseMeansCurrent #

MariaDB驱动不支持nullDatabaseMeansCurrent，但可以通过useCatalogAsCurrentSchema=true连接属性，让驱动将catalog视为当前schema，使Spring获取元数据时自动绑定当前数据源指定的数据库（即catalog），避免跨库同名表匹配冲突。

配置方式 #

• 在JDBC URL中直接添加：

jdbc:mariadb://localhost:3306/your_database?useCatalogAsCurrentSchema=true

• Spring Boot项目可在application.properties中配置：

spring.datasource.url=jdbc:mariadb://localhost:3306/your_database?useCatalogAsCurrentSchema=true

2. 全局自定义JdbcTemplate适配元数据逻辑 #

如果连接属性无法满足需求，可自定义JdbcTemplate，重写元数据获取逻辑，默认绑定当前数据源的catalog：

自定义JdbcTemplate #

import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.DatabaseMetaData;
import java.sql.SQLException;

public class MariaDbJdbcTemplate extends JdbcTemplate {
    public MariaDbJdbcTemplate(DataSource dataSource) {
        super(dataSource);
    }

    @Override
    protected DatabaseMetaData createDatabaseMetaData(Connection con) throws SQLException {
        String currentDb = con.getCatalog();
        return new MariaDbDatabaseMetaDataWrapper(super.createDatabaseMetaData(con), currentDb);
    }
}

包装DatabaseMetaData，默认传入当前catalog #

import java.sql.DatabaseMetaData;
import java.sql.ResultSet;
import java.sql.SQLException;

public class MariaDbDatabaseMetaDataWrapper implements DatabaseMetaData {
    private final DatabaseMetaData delegate;
    private final String defaultCatalog;

    public MariaDbDatabaseMetaDataWrapper(DatabaseMetaData delegate, String defaultCatalog) {
        this.delegate = delegate;
        this.defaultCatalog = defaultCatalog;
    }

    @Override
    public ResultSet getTables(String catalog, String schemaPattern, String tableNamePattern, String[] types) throws SQLException {
        // 当catalog参数为null时，自动传入当前数据库名
        String useCatalog = (catalog == null) ? defaultCatalog : catalog;
        return delegate.getTables(useCatalog, schemaPattern, tableNamePattern, types);
    }

    // 其余DatabaseMetaData接口方法直接委托给delegate实现，此处省略
}

注册全局JdbcTemplate Bean #

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;

@Configuration
public class MariaDbJdbcConfig {
    @Bean
    public JdbcTemplate jdbcTemplate(DataSource dataSource) {
        return new MariaDbJdbcTemplate(dataSource);
    }
}

业务代码中注入的JdbcTemplate会自动使用该自定义实现，无需修改原有业务逻辑。

3. 全局配置SimpleJdbcInsert默认Catalog #

若问题集中在SimpleJdbcInsert，可自定义工厂Bean为其默认设置当前catalog：

实现SimpleJdbcInsert工厂 #

import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
import org.springframework.jdbc.core.simple.SimpleJdbcInsertOperations;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;

public class MariaDbSimpleJdbcInsertFactory {
    public static SimpleJdbcInsertOperations create(DataSource dataSource) {
        try (Connection con = dataSource.getConnection()) {
            return new SimpleJdbcInsert(dataSource).withCatalogName(con.getCatalog());
        } catch (SQLException e) {
            throw new RuntimeException("Failed to get current catalog", e);
        }
    }
}

注册全局Bean #

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;

@Configuration
public class MariaDbJdbcConfig {
    @Bean
    public SimpleJdbcInsertOperations simpleJdbcInsert(DataSource dataSource) {
        return MariaDbSimpleJdbcInsertFactory.create(dataSource);
    }
}

业务代码直接注入SimpleJdbcInsertOperations即可，无需手动调用withCatalogName。

4. Spring Boot全局数据源属性统一配置 #

在Spring Boot中，可通过自定义DataSourceProperties统一为所有数据源添加useCatalogAsCurrentSchema=true：

import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class MariaDbDataSourceConfig {
    @Bean
    @ConfigurationProperties("spring.datasource")
    public DataSourceProperties dataSourceProperties() {
        DataSourceProperties properties = new DataSourceProperties();
        properties.setDriverClassName("org.mariadb.jdbc.Driver");
        properties.getHikari().addDataSourceProperty("useCatalogAsCurrentSchema", "true");
        return properties;
    }
}

内容的提问来源于stack exchange，提问作者user327961