TreeData
/
cloud-etl-engine
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

--9--10

master
Qin Dong Ming 2024-09-10 09:38:24 +08:00
parent d9eede9169
commit 72527bfaa7
4 changed files with 12 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Dockerfile
View File

@ -10,7 +10,7 @@ COPY ./cloud-etl-server/target/cloud-engine.jar /home/app.jar
COPY ./cloud-etl-server/target/classes /home/lib COPY ./cloud-etl-server/target/classes /home/lib
COPY ./cloud-etl-server/target/classes/com/muyu/home/lib/com/muyu/abstract/*.jar /home/lib/ #COPY ./cloud-etl-server/target/classes/com/muyu/home/lib/com/muyu/abstract/*.jar /home/lib/
ENTRYPOINT ["java","-jar","-Dfile.encoding=UTF-8"] ENTRYPOINT ["java","-jar","-Dfile.encoding=UTF-8"]

16
cloud-etl-common/src/main/java/com/muyu/context/GenerateConstant.java
View File

@ -57,20 +57,4 @@ public class GenerateConstant {
"}"; "}";
} }
// public static String selectType(String level) {
// String type = "";
// switch (level) {
// case "F":
// type = DATA_FIELD;
// break;
// case "R":
// type = DATA_RECORD;
// break;
// case "C":
// type = DATA_SET;
// break;
// }
// return type;
// }
} }

13
cloud-etl-server/src/main/java/com/muyu/javacomplier/OSSFileDownload.java
View File

@ -4,9 +4,10 @@ import com.aliyun.oss.OSSClient;
import com.aliyun.oss.model.GetObjectRequest; import com.aliyun.oss.model.GetObjectRequest;
import com.aliyun.oss.model.ObjectMetadata; import com.aliyun.oss.model.ObjectMetadata;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
import lombok.extern.log4j.Log4j2;
import java.io.File; import java.io.File;
@Log4j2
public class OSSFileDownload { public class OSSFileDownload {
private static final String endpoint = "https://oss-cn-shanghai.aliyuncs.com"; private static final String endpoint = "https://oss-cn-shanghai.aliyuncs.com";
@ -27,21 +28,21 @@ public class OSSFileDownload {
// 判断 bucket 是否存在 // 判断 bucket 是否存在
Boolean flag_bucket = ossClient.doesBucketExist(bucketName); Boolean flag_bucket = ossClient.doesBucketExist(bucketName);
if (!flag_bucket) { if (!flag_bucket) {
System.out.println("bucket不存在"); log.info("bucket不存在");
return Result.error("bucket不存在"); return Result.error("bucket不存在");
} }
String objectName = fileName + ".java"; String objectName = fileName + ".java";
Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath + objectName); Boolean flag_file = ossClient.doesObjectExist(bucketName, filePath + objectName);
if (!flag_file) { if (!flag_file) {
System.out.println("预下载文件不存在"); log.info("预下载文件不存在");
return Result.error("预下载文件不存在"); return Result.error("预下载文件不存在");
} }
// 本地文件下载路径 // 本地文件下载路径
String localPath = "/home/" + objectName; String localPath = "/home/" + objectName;
ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + objectName), new File(localPath)); ObjectMetadata object = ossClient.getObject(new GetObjectRequest(bucketName, filePath + objectName), new File(localPath));
System.out.println("文件路径是:" + filePath); log.info("文件路径是:" + filePath);
System.out.println("新文件路径是:" + localPath); log.info("新文件路径是:" + localPath);
System.out.println("文件名称为:" + object); log.info("文件名称为:" + object);
ossClient.shutdown(); ossClient.shutdown();
return Result.success(source); return Result.success(source);
} }

9
cloud-etl-server/src/main/java/com/muyu/test/JavaClass.java
View File

@ -1,22 +1,21 @@
package com.muyu.test; package com.muyu.test;
import com.muyu.domain.constants.Result; import com.muyu.domain.constants.Result;
import lombok.extern.log4j.Log4j2;
import javax.tools.JavaCompiler; import javax.tools.JavaCompiler;
import javax.tools.ToolProvider; import javax.tools.ToolProvider;
@Log4j2
public class JavaClass { public class JavaClass {
public static Result<Object> compile(String fileName) { public static Result<Object> compile(String fileName) {
JavaCompiler compiler = ToolProvider.getSystemJavaCompiler(); JavaCompiler compiler = ToolProvider.getSystemJavaCompiler();
String[] strings = {"-classpath", "/home/lib", "-verbose", "-d", "/home/lib", "/home/" + fileName + ".java"}; String[] strings = {"-classpath", "/home/lib", "-verbose", "-d", "/home/lib", "/home/" + fileName + ".java"};
System.out.println("路径参数是:"+strings);
int result = compiler.run(null, null, null, strings); int result = compiler.run(null, null, null, strings);
System.out.println("编译结果是:"+result);
if (result == 0) { if (result == 0) {
System.out.println("编译成功，生成的.class文件位于源代码同目录"); log.info("编译成功，生成的.class文件位于源代码同目录");
} else { } else {
System.out.println("编译失败"); log.info("编译失败");
} }
return Result.success(); return Result.success();
} }