武汉瑞书云信息技术有限公司
User Avatar

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

武汉瑞书云信息技术有限公司 2026/09/09 17:45:35

代码

// 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、达梦等），成为异构数据库迁移的高效工具。

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

吉安网站建设网站建设知识

UNIX 用户管理：停机通知、用户关怀与离职处理在使用 UNIX 服务器时，停机是不可避免的一部分，合理处理停机通知、与用户保持良好关系以及妥善处理用户离职等问题，对于服务器管理员来说至关重要。1.

2026/06/30 12:46:02

惠州网站建设php网站建设

如何快速安装LiteLoaderQQNT：QQNT插件的终极指南【免费下载链接】LiteLoaderQQNT_Install针对 LiteLoaderQQNT 的安装脚本项目地址: ht

2026/06/30 11:09:23

常州网站建设长安网站建设

HunyuanOCR插件生态构想：让AI能力像应用商店一样自由扩展在智能办公、数字政务和自动化流程日益普及的今天，文档识别早已不再是“把图片转成文字”那么简单。现实场景中&

2026/06/30 13:07:34

网站建设维护免费建设网站

目录已开发项目效果实现截图开发技术介绍系统开发工具：核心代码参考示例1.建立用户稀疏矩阵，用于用户相似度计算【相似度矩阵】2.计算目标用户与其他用户的相似度系统测试总结源码

2026/06/30 13:56:38

郑州网站建设网站建设空间

2025年全新视角：Tailwind CSS深度应用与效率革命【免费下载链接】awesome-tailwindcss😎 Awesome things related to

2026/06/30 13:09:34

房产网站建设福田网站建设

从零开始掌握Artisan：咖啡烘焙师的终极可视化工具指南【免费下载链接】artisanartisan: visual scope for coffee roasters项目地址: ht

2026/06/30 11:59:58

建设网站教程宁波外贸网站建设

CosyVoice3能否识别儿童声音？不同年龄层声纹适应性分析在智能语音助手走进千家万户的今天，越来越多家长开始期待一个能“像孩子一样说话”的AI角色——无论是为儿童故事配

2026/06/30 10:32:20

网站建设哪家好微网站的建设

AI智能字幕消除工具：一键清除视频硬字幕，还原纯净画质【免费下载链接】video-subtitle-remover基于AI的图片/视频硬字幕去除、文本水印去除，

2026/06/30 14:03:38

广州网站建设公司内蒙古网站建设

使用 GDB 进行调试的全面指南1. 准备工作在开始调试之前，需要构建带有调试符号的可执行文件。在构建选项中启用BR2_ENABLE_DEBUG（即“Build packages with debug

2026/06/30 11:06:54

网站建设学习团购网站建设

终极指南：如何使用SpleeterGUI轻松分离音乐人声和伴奏 🎵【免费下载链接】SpleeterGuiWindows desktop front end for Spl

2026/06/30 14:18:09