From 45b7970463ce68946c178cff76968da471bf645b Mon Sep 17 00:00:00 2001
From: baize <3533151373@qq.com>
Date: Tue, 14 May 2024 22:39:57 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=95=B0=E6=8D=AE=E5=B1=95=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/DataSourceServiceImpl.java   | 28 +++++++++++++++
 .../service/impl/RuleengineServiceImpl.java   | 34 ++++++-------------
 2 files changed, 38 insertions(+), 24 deletions(-)

diff --git a/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/service/impl/DataSourceServiceImpl.java b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/service/impl/DataSourceServiceImpl.java
index b549382..201e2cc 100644
--- a/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/service/impl/DataSourceServiceImpl.java
+++ b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/service/impl/DataSourceServiceImpl.java
@@ -142,10 +142,14 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
             prepared.setString(1, dataSource.getDatabaseName()); // 设置数据库名称参数
 
 
+
             // 执行查询
             ResultSet resultSet = prepared.executeQuery();
 
             ResultSetMetaData rsmd = resultSet.getMetaData();
+//            DataValue dataValue = new DataValue();
+            ArrayList<DataValue> dataValueList = new ArrayList<>();
+
             // 5. 处理查询结果
             while (resultSet.next()) {
                 String tableName = resultSet.getString("name");
@@ -160,7 +164,31 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
 
                 // 将对象添加到 ArrayList 中
                 list.add(databaseTableInformation);
+
+
+                System.out.println("222"+tableName);
+                String sqlServer="select * from "+tableName;
+                Statement statement = con.createStatement();
+                ResultSet preparedStatement = statement.executeQuery(sqlServer);
+
+                ResultSetMetaData metaData = preparedStatement.getMetaData();
+                while (preparedStatement.next()){
+                    for (int i = 1; i <= metaData.getColumnCount(); i++) {
+                        DataValue dataValue = new DataValue();
+                        String columnName = metaData.getColumnName(i);
+                        dataValue.setValue(preparedStatement.getObject(i));
+//                        dataValue.setType(preparedStatement.getString("type"));
+                        dataValue.setKey(dataSource.getDataSourceSystemName()+"-"+tableName+"-"+columnName);
+                        dataValueList.add(dataValue);
+                    }
+                }
             }
+            System.out.println(dataValueList);
+            System.out.println("================================");
+            for (DataValue value : dataValueList) {
+                System.out.println("123"+value);
+            }
+            System.out.println("================================");
             //参数复制对象
             assetStructure.setAccessSourceName(dataSource.getAccessSourceName());
             assetStructure.setDatabaseName(dataSource.getDatabaseName());
diff --git a/muyu-modules/muyu-ruleengine/muyu-ruleengine-server/src/main/java/com/muyu/ruleengine/service/impl/RuleengineServiceImpl.java b/muyu-modules/muyu-ruleengine/muyu-ruleengine-server/src/main/java/com/muyu/ruleengine/service/impl/RuleengineServiceImpl.java
index 5d8adf2..66f55c4 100644
--- a/muyu-modules/muyu-ruleengine/muyu-ruleengine-server/src/main/java/com/muyu/ruleengine/service/impl/RuleengineServiceImpl.java
+++ b/muyu-modules/muyu-ruleengine/muyu-ruleengine-server/src/main/java/com/muyu/ruleengine/service/impl/RuleengineServiceImpl.java
@@ -202,31 +202,17 @@ public class RuleengineServiceImpl extends ServiceImpl<RuleengineMapper, Ruleeng
         JavaCompiler systemJavaCompiler = ToolProvider.getSystemJavaCompiler();
         StandardJavaFileManager standardFileManager = systemJavaCompiler.getStandardFileManager(null, null, null);
         log.info(codeIng);
-//        JavaSourceFromString javaSourceFromString = new JavaSourceFromString(codeIng);
+        JavaSourceFromString javaSourceFromString = new JavaSourceFromString("as",codeIng);
 
-//        JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
-//        try (StandardJavaFileManager fileManager = compiler.getStandardFileManager(null, null, null)) {
-//            // 创建一个内存中的源文件
-//            JavaFileObject sourceFileObject = new JavaSourceFromString("Test"+ruleId, content);
-//
-//            // 编译选项
-//            Iterable<String> options = Arrays.asList("-d", targetDirectory);
-//
-//            // 编译源代码
-//            JavaCompiler.CompilationTask task = compiler.getTask(null, fileManager, null, options, null, Arrays.asList(sourceFileObject));
-//            boolean success = task.call();
-//
-//            if (success) {
-//                ruleengineMapper.addRulecontent(ruleContentReq);
-//                System.out.println("编译成功");
-//            } else {
-//                System.out.println("编译失败");
-//            }
-//
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//        return Result.success("编译成功");
+        JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
+        List<String> list = Arrays.asList("-d", targetDirectory);
+        JavaCompiler.CompilationTask task = compiler.getTask(null, standardFileManager, null, list, null, Arrays.asList(javaSourceFromString));
+        boolean success = task.call();
+        if (success){
+            log.info("编译成功");
+        }else {
+            log.info("编译失败");
+        }
         return null;
     }