福州欧派兰商贸有限公司
User Avatar

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

福州欧派兰商贸有限公司 2026/09/09 17:40:42

代码

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

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

无锡网站建设永康网站建设

PC微信小程序解密工具为技术开发者提供了一套完整的源码提取解决方案。通过wxapkg解密技术，开发者能够深入分析小程序架构，为技术研究和合法开发提供强有力的支持。本指南将详

2026/06/30 11:09:24

衡水网站建设建设官方网站

第一章：从感知到决策，多 Agent 融合如何重塑自动驾驶？在自动驾驶系统中，传统的集中式架构正逐渐被分布式多 Agent 系统所取代。通过将感

2026/06/30 11:17:24

永州网站建设郑州建设网站

如何用all-rag-techniques实现智能文档检索：完整实战指南【免费下载链接】all-rag-techniquesImplementation of all RAG techn

2026/06/30 11:47:58

黄石网站建设汕头网站建设

全面掌握Netperf：网络性能测试的瑞士军刀从零开始，深度解析Netperf的安装、使用和实战应用目录全面掌握Netperf：网络性能测试的瑞士军刀

2026/06/30 11:46:57

济南网站建设公司荥阳网站建设

目录已开发项目效果实现截图开发技术路线相关技术介绍核心代码参考示例结论源码lw获取/同行可拿货,招校园代理 ：文章底部获取博主联系方式！已开发项目效果实现截图同行可拿货,招

2026/06/30 13:17:35

涪陵网站建设长沙市网站建设公司

开发是我不想重复的路早几年都流行学计算机，传言就业薪资高，就选了软件开发专业。在学校也不算混子吧，该学的java、python、前端操作系统都学了࿰

2026/06/30 12:06:29

桂林网站建设长沙企业网站建设

第一章：量子机器学习的 VSCode 调试在开发量子机器学习应用时，调试是确保算法正确性和性能优化的关键环节。Visual Studio Code（VSCod

2026/06/30 11:44:27

网站建设报价表网站建设实训

Keil5安装实战避坑全攻略：从下载到调试的硬核经验分享在嵌入式开发的世界里，如果你刚入手一块STM32板子，第一步不是写代码，也不是接线——而

2026/06/30 13:06:34

徐家汇网站建设网站建设与

RS232 与 RS485 到底怎么选？一文讲透工业串口通信的本质差异你有没有遇到过这样的场景：在调试一块嵌入式板子时，串口线一接上，电脑终端就

2026/06/30 13:22:35

聊城网站建设宝应网站建设

Android Studio中文界面定制指南：5分钟打造专属开发环境【免费下载链接】AndroidStudioChineseLanguagePackAndroidStudio中文插件(官

2026/06/30 12:29:31