深圳卓马科技有限公司
User Avatar

郑州网站建设陕西网站建设

深圳卓马科技有限公司 2026/09/09 21:30:44

代码

// Copyright tang. All rights reserved. // https://gitee.com/inrgihc/dbswitch // // Use of this source code is governed by a BSD-style license // // Author: tang (inrgihc@126.com) // Date : 2020/1/2 // Location: beijing , china ///////////////////////////////////////////////////////////// package org.dromara.dbswitch.product.register; import org.dromara.dbswitch.core.annotation.Product; import org.dromara.dbswitch.common.consts.Constants; import org.dromara.dbswitch.common.type.ProductTypeEnum; import org.dromara.dbswitch.core.provider.ProductFactoryProvider; import org.dromara.dbswitch.core.provider.ProductProviderFactory; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.net.URL; import java.util.ArrayList; import java.util.Enumeration; import java.util.HashSet; import java.util.List; import java.util.ServiceConfigurationError; import java.util.Set; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.BeanClassLoaderAware; import org.springframework.beans.factory.InitializingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.context.annotation.Configuration; @Slf4j @Configuration @ConditionalOnClass(ProductProviderFactory.class) public class ProductRegisterAutoConfiguration implements InitializingBean, BeanClassLoaderAware { private static final Set<String> providers = new HashSet<>(); private ClassLoader classLoader; private int parseLine(BufferedReader reader, int lc, List<String> names) throws IOException, ServiceConfigurationError { String ln = reader.readLine(); if (ln == null) { return -1; } int ci = ln.indexOf('#'); if (ci >= 0) { ln = ln.substring(0, ci); } ln = ln.trim(); int n = ln.length(); if (n != 0) { if ((ln.indexOf(' ') >= 0) || (ln.indexOf('	') >= 0)) { log.error("Illegal configuration-file syntax: {}", ln); } int cp = ln.codePointAt(0); if (!Character.isJavaIdentifierStart(cp)) { log.error("Illegal provider-class name: {}", ln); } for (int i = Character.charCount(cp); i < n; i += Character.charCount(cp)) { cp = ln.codePointAt(i); if (!Character.isJavaIdentifierPart(cp) && (cp != '.')) { log.error("Illegal provider-class name: {}", ln); } } if (!providers.contains(ln) && !names.contains(ln)) { names.add(ln); } } return lc + 1; } private List<String> parse(URL url) throws ServiceConfigurationError { InputStream in = null; BufferedReader reader = null; ArrayList<String> names = new ArrayList<>(); try { in = url.openStream(); reader = new BufferedReader(new InputStreamReader(in, "utf-8")); int lc = 1; while ((lc = parseLine(reader, lc, names)) >= 0) { } } catch (IOException x) { log.error("Error reading configuration file", x); } finally { try { if (reader != null) { reader.close(); } if (in != null) { in.close(); } } catch (IOException y) { log.error("Error closing configuration file", y); } } return names; } @Override public void setBeanClassLoader(ClassLoader classLoader) { this.classLoader = classLoader; } @Override public void afterPropertiesSet() throws Exception { log.info("Register database product now ..."); ClassLoader loader = (null != classLoader) ? classLoader : ProductProviderFactory.class.getClassLoader(); Enumeration<URL> resources = loader.getResources(Constants.SPI_FILE); while (resources.hasMoreElements()) { URL url = resources.nextElement(); providers.addAll(parse(url)); } int totalCount = 0; for (String className : providers) { Class<?> aClass = classLoader.loadClass(className); if (ProductFactoryProvider.class.isAssignableFrom(aClass)) { if (aClass.isAnnotationPresent(Product.class)) { Product annotation = aClass.getAnnotation(Product.class); ProductTypeEnum productType = annotation.value(); if (null != productType) { ProductProviderFactory.register(productType, className); ++totalCount; } } } } log.info("Finish to register total {} database product !", totalCount); } }

这段代码是dbswitch开源数据库同步工具的核心组件之一，负责在 Spring 容器启动时自动扫描并注册支持的数据库产品实现类。以下是详细解析：

🧩 一、核心功能概述

该类通过 Java 的 SPI（Service Provider Interface）机制动态加载数据库方言实现类，并将其注册到ProductProviderFactory工厂中，实现数据库产品的自动发现与注册。

🔍 二、关键代码解析

1.类定义与注解
@Slf4j @Configuration @ConditionalOnClass(ProductProviderFactory.class) public class ProductRegisterAutoConfiguration implements InitializingBean, BeanClassLoaderAware
  • @Configuration：声明为 Spring 配置类。
  • @ConditionalOnClass：仅当类路径存在ProductProviderFactory时生效（保障环境兼容性）。
  • InitializingBean：在 Bean 属性设置后触发afterPropertiesSet()初始化逻辑。
  • BeanClassLoaderAware：获取 Spring 容器的类加载器。
2.SPI 文件解析
private List<String> parse(URL url) { ... } private int parseLine(BufferedReader reader, int lc, List<String> names) { ... }
  • 作用：读取META-INF/services目录下的 SPI 配置文件（文件名由Constants.SPI_FILE定义）。
  • 流程：
    1. 按行读取配置文件（如org.dromara.dbswitch.core.provider.ProductFactoryProvider）。
    2. 过滤注释（#开头）和非法类名（如包含空格或非 Java 标识符）。
    3. 将有效实现类全限定名存入providers集合。
3.数据库产品注册
@Override public void afterPropertiesSet() { // 获取类加载器 ClassLoader loader = (null != classLoader) ? classLoader : ProductProviderFactory.class.getClassLoader(); // 扫描所有 SPI 配置文件 Enumeration<URL> resources = loader.getResources(Constants.SPI_FILE); while (resources.hasMoreElements()) { providers.addAll(parse(resources.nextElement())); // 解析文件内容 } // 注册到工厂 int totalCount = 0; for (String className : providers) { Class<?> aClass = classLoader.loadClass(className); if (ProductFactoryProvider.class.isAssignableFrom(aClass) // 确保实现接口 && aClass.isAnnotationPresent(Product.class)) { // 检查 @Product 注解 Product annotation = aClass.getAnnotation(Product.class); ProductTypeEnum productType = annotation.value(); // 获取数据库类型（如 ORACLE、MYSQL） ProductProviderFactory.register(productType, className); // 注册到工厂 ++totalCount; } } log.info("Finish to register total {} database product !", totalCount); }

📦 三、技术要点总结

特性说明
SPI 机制通过META-INF/services文件实现数据库方言的可插拔扩展
动态注册利用 Spring 的InitializingBean在容器启动时完成注册
类型安全通过@Product注解绑定数据库类型枚举（如ProductTypeEnum.ORACLE）
错误防护校验类名合法性，避免非法配置导致运行时异常

🌰 四、实际应用场景

假设新增达梦数据库支持：

  1. 实现接口：
    @Product(ProductTypeEnum.DAMENG) public class DamengProductProvider implements ProductFactoryProvider { ... }
  2. SPI 配置：
    在META-INF/services/org.dromara.dbswitch.core.provider.ProductFactoryProvider文件中添加：
    org.dromara.dbswitch.dm.DamengProductProvider
  3. 自动注册：
    Spring 启动时，该类会被扫描并注册到ProductProviderFactory，后续可通过ProductTypeEnum.DAMENG调用。

⚙️ 五、与 dbswitch 架构的关系

此组件是 dbswitch多数据库支持的基石，其设计体现了以下核心思想：

  1. 解耦：通过 SPI 分离接口与实现。
  2. 扩展性：新增数据库仅需添加实现类和 SPI 配置。
  3. 自动化：Spring 容器管理生命周期，避免手动注册。

通过这种设计，dbswitch 能灵活支持 20+ 种数据库（如 Oracle、MySQL、PostgreSQL、达梦等），成为异构数据库迁移的高效工具。

版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈，一经查实，立即删除！

南宁网站建设网站正在建设中

移动端能运行 CosyVoice3 吗？当前依赖较高暂不适合在智能语音助手、虚拟主播和个性化有声内容爆发的今天，阿里通义实验室推出的CosyVoice3成为了开源社区关注的

2026/06/30 14:06:08

南通网站建设机械网站建设

Vim命令行模式实用技巧1. 使用Tab键补全Ex命令在Vim的命令行中，如同在shell里一样，我们可以使用<Tab>键来自动补全命令。Vim会依据已输入的内容智能地给出补全建议。例如，

2026/06/30 12:30:31

深圳营销型网站建设建设商城网站

DIgSILENT-PowerFactory电力仿真软件快速上手指南【免费下载链接】DIgSILENT-PowerFactory入门教程DIgSILENT-PowerFactory是一款强大的电力系统

2026/06/30 13:14:34

诸城网站建设湖州网站建设

科研实验室以太网POE温湿度监控系统设计方案一、方案设计背景与目标1. 设计背景科研实验室（如生物培养室、化学试剂存储室、电子元器件测试实验室等）对温湿度环境具有极高敏感性

2026/06/30 12:01:29

网站建设空间洛阳网站建设

当你在社交媒体上分享一张照片时，是否意识到这张看似普通的图片可能正在泄露你的隐私？从GPS定位到面部特征，现代照片中隐藏的信息远超你的想象。今天，

2026/06/30 13:58:08

邢台网站建设甘肃网站建设

Qwen3-14B：用32K上下文重塑企业级长文档智能处理在今天的企业AI实践中，一个常见的尴尬场景是：法务上传了一份80页的合同PDF，系统却

2026/06/30 14:02:38

郑州网站建设十堰网站建设

分段加载终极指南：快速解决千万级文档加载性能瓶颈【免费下载链接】MaxKB强大易用的开源企业级智能体平台项目地址: https://gitcode.com/feizhiyun/MaxKB

2026/06/30 10:04:48

深圳网站建设石家庄网站建设

DepthCrafter：免费生成视频深度序列的开源工具【免费下载链接】DepthCrafterDepthCrafter是一款开源工具，能为开放世界视频生成时间一致性强、细

2026/06/30 13:52:07

装饰网站建设旅游网站建设

安卓设备上的代码编辑革命：VS Code本地化部署深度解析【免费下载链接】vscode_for_android安卓本地使用vs code编辑器实现方案项目地址: https://gitc

2026/06/30 14:11:09