baize
/
cloud-server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: 数据展示

master
baize 2024-05-14 22:39:57 +08:00
parent 10a34edcd4
commit 45b7970463
2 changed files with 38 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/service/impl/DataSourceServiceImpl.java
View File

@ -142,10 +142,14 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
prepared.setString(1, dataSource.getDatabaseName()); // 设置数据库名称参数 prepared.setString(1, dataSource.getDatabaseName()); // 设置数据库名称参数
// 执行查询 // 执行查询
ResultSet resultSet = prepared.executeQuery(); ResultSet resultSet = prepared.executeQuery();
ResultSetMetaData rsmd = resultSet.getMetaData(); ResultSetMetaData rsmd = resultSet.getMetaData();
// DataValue dataValue = new DataValue();
ArrayList<DataValue> dataValueList = new ArrayList<>();
// 5. 处理查询结果 // 5. 处理查询结果
while (resultSet.next()) { while (resultSet.next()) {
String tableName = resultSet.getString("name"); String tableName = resultSet.getString("name");
@ -160,7 +164,31 @@ public class DataSourceServiceImpl extends ServiceImpl<DataSourceMapper, DataSou
// 将对象添加到 ArrayList 中 // 将对象添加到 ArrayList 中
list.add(databaseTableInformation); 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.setAccessSourceName(dataSource.getAccessSourceName());
assetStructure.setDatabaseName(dataSource.getDatabaseName()); assetStructure.setDatabaseName(dataSource.getDatabaseName());

34
muyu-modules/muyu-ruleengine/muyu-ruleengine-server/src/main/java/com/muyu/ruleengine/service/impl/RuleengineServiceImpl.java
View File

@ -202,31 +202,17 @@ public class RuleengineServiceImpl extends ServiceImpl<RuleengineMapper, Ruleeng
JavaCompiler systemJavaCompiler = ToolProvider.getSystemJavaCompiler(); JavaCompiler systemJavaCompiler = ToolProvider.getSystemJavaCompiler();
StandardJavaFileManager standardFileManager = systemJavaCompiler.getStandardFileManager(null, null, null); StandardJavaFileManager standardFileManager = systemJavaCompiler.getStandardFileManager(null, null, null);
log.info(codeIng); log.info(codeIng);
// JavaSourceFromString javaSourceFromString = new JavaSourceFromString(codeIng); JavaSourceFromString javaSourceFromString = new JavaSourceFromString("as",codeIng);
// JavaCompiler compiler = ToolProvider.getSystemJavaCompiler(); JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
// try (StandardJavaFileManager fileManager = compiler.getStandardFileManager(null, null, null)) { List<String> list = Arrays.asList("-d", targetDirectory);
// // 创建一个内存中的源文件 JavaCompiler.CompilationTask task = compiler.getTask(null, standardFileManager, null, list, null, Arrays.asList(javaSourceFromString));
// JavaFileObject sourceFileObject = new JavaSourceFromString("Test"+ruleId, content); boolean success = task.call();
// if (success){
// // 编译选项 log.info("编译成功");
// Iterable<String> options = Arrays.asList("-d", targetDirectory); }else {
// log.info("编译失败");
// // 编译源代码 }
// 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("编译成功");
return null; return null;
} }