From 00e6b576d81ab3860ad269da42bb962e98871b52 Mon Sep 17 00:00:00 2001 From: Qin Dong Ming <2720806930@qq.com> Date: Sun, 8 Sep 2024 19:56:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=AE=B9=E5=99=A8=E9=83=A8?= =?UTF-8?q?=E8=B7=AF=E5=BE=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/muyu/test/RuleTest.java | 124 +++++++++--------- 1 file changed, 62 insertions(+), 62 deletions(-) diff --git a/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java b/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java index c6226d4..f92e1dc 100644 --- a/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java +++ b/cloud-etl-server/src/main/java/com/muyu/test/RuleTest.java @@ -1,62 +1,62 @@ -package com.muyu.test; - -import com.muyu.BasicEngine; -import com.muyu.core.domain.DataValue; -import com.muyu.domain.EngineVersion; - - -import java.io.File; -import java.io.IOException; -import java.lang.reflect.InvocationTargetException; -import java.net.URL; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.util.Map; -import java.util.concurrent.ConcurrentHashMap; - - -public class RuleTest { - static Map> engineMap = new ConcurrentHashMap<>(); - - //外部类文件路径 - public static final String engineWorkSourcePath = "/home/lib/"; - public static final String className = "com.muyu.abstracts.generate."; - - public static void test(EngineVersion engineVersion) { - try { - //外部类文件路径 - String externalClassFilePath = - engineWorkSourcePath + "/com/muyu/abstracts/" + engineVersion.getName() + ".class"; - Path classFilePath = Paths.get(externalClassFilePath); - //获取外部类所在的目录 - String externalClassDir = externalClassFilePath.substring(0, externalClassFilePath.lastIndexOf('/')); - URL[] urls = new URL[]{new File(externalClassDir).toURI().toURL()}; - ExternalClassLoader externalClassLoader = new ExternalClassLoader(urls); - //加载类 全限定名 - Class clazz = externalClassLoader.loadClassFromPath(classFilePath, className + engineVersion.getName()); - Object instance = clazz.getDeclaredConstructor().newInstance(); - engineMap.put(engineVersion.getName(), (BasicEngine) instance); - } catch (IOException e) { - throw new RuntimeException(e); - } catch (InvocationTargetException e) { - throw new RuntimeException(e); - } catch (InstantiationException e) { - throw new RuntimeException(e); - } catch (IllegalAccessException e) { - throw new RuntimeException(e); - } catch (NoSuchMethodException e) { - throw new RuntimeException(e); - } - DataValue dataValue = DataValue.builder() - .type("String") - .label("手机号") - .key("phone") - .value("张三") - .build(); - - BasicEngine engine = engineMap.get(engineVersion.getName()); - engine.set(dataValue); - engine.execution(); - } - -} +//package com.muyu.test; +// +//import com.muyu.BasicEngine; +//import com.muyu.core.domain.DataValue; +//import com.muyu.domain.EngineVersion; +// +// +//import java.io.File; +//import java.io.IOException; +//import java.lang.reflect.InvocationTargetException; +//import java.net.URL; +//import java.nio.file.Path; +//import java.nio.file.Paths; +//import java.util.Map; +//import java.util.concurrent.ConcurrentHashMap; +// +// +//public class RuleTest { +// static Map> engineMap = new ConcurrentHashMap<>(); +// +// //外部类文件路径 +// public static final String engineWorkSourcePath = "/home/lib/"; +// public static final String className = "com.muyu.abstracts.generate."; +// +// public static void test(EngineVersion engineVersion) { +// try { +// //外部类文件路径 +// String externalClassFilePath = +// engineWorkSourcePath + "/com/muyu/abstracts/" + engineVersion.getName() + ".class"; +// Path classFilePath = Paths.get(externalClassFilePath); +// //获取外部类所在的目录 +// String externalClassDir = externalClassFilePath.substring(0, externalClassFilePath.lastIndexOf('/')); +// URL[] urls = new URL[]{new File(externalClassDir).toURI().toURL()}; +// ExternalClassLoader externalClassLoader = new ExternalClassLoader(urls); +// //加载类 全限定名 +// Class clazz = externalClassLoader.loadClassFromPath(classFilePath, className + engineVersion.getName()); +// Object instance = clazz.getDeclaredConstructor().newInstance(); +// engineMap.put(engineVersion.getName(), (BasicEngine) instance); +// } catch (IOException e) { +// throw new RuntimeException(e); +// } catch (InvocationTargetException e) { +// throw new RuntimeException(e); +// } catch (InstantiationException e) { +// throw new RuntimeException(e); +// } catch (IllegalAccessException e) { +// throw new RuntimeException(e); +// } catch (NoSuchMethodException e) { +// throw new RuntimeException(e); +// } +// DataValue dataValue = DataValue.builder() +// .type("String") +// .label("手机号") +// .key("phone") +// .value("张三") +// .build(); +// +// BasicEngine engine = engineMap.get(engineVersion.getName()); +// engine.set(dataValue); +// engine.execution(); +// } +// +//}