hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: hzya:460722dde6a05b69738e1bbc5e2cc1347a4f138d
Branches Tags
hzya:master
hzya:lets
hzya:sw
hzya:ht
hzya:voucher-gm
hzya:wansheng
hzya:jianhui0521
hzya:zhouju
hzya:wx-grp
hzya:fw-oa
hzya:fw-nifi
hzya:kjs
hzya:fw-grpU8
hzya:grpU8
hzya:237master
hzya:kunb
hzya:dongj
hzya:ax
hzya:deguangxin
hzya:fw-bip
hzya:dev
hzya:xs
hzya:fw-weixin
hzya:fw-ningbobank
hzya:fw-u9c
hzya:fw-u8c
hzya:fw-u8
hzya:fw-ncc
hzya:fw-nc
hzya:fw-dd
hzya:fw-cbs
hzya:service-grp
hzya:service-cbs
hzya:yingdesai
hzya:hecan
hzya:zqt
hzya:yuecheng-project
hzya:lvleigang
hzya:nanxun-grp
hzya:guojh
hzya:xiangerlin
hzya:yuqh
hzya:changelogdatasource
..
compare: hzya:56841ca743a886bfb7c5389c5673d90da2c51ec0
Branches Tags
hzya:lets
hzya:sw
hzya:ht
hzya:voucher-gm
hzya:wansheng
hzya:jianhui0521
hzya:zhouju
hzya:wx-grp
hzya:fw-oa
hzya:fw-nifi
hzya:kjs
hzya:master
hzya:fw-grpU8
hzya:grpU8
hzya:237master
hzya:kunb
hzya:dongj
hzya:ax
hzya:deguangxin
hzya:fw-bip
hzya:dev
hzya:xs
hzya:fw-weixin
hzya:fw-ningbobank
hzya:fw-u9c
hzya:fw-u8c
hzya:fw-u8
hzya:fw-ncc
hzya:fw-nc
hzya:fw-dd
hzya:fw-cbs
hzya:service-grp
hzya:service-cbs
hzya:yingdesai
hzya:hecan
hzya:zqt
hzya:yuecheng-project
hzya:lvleigang
hzya:nanxun-grp
hzya:guojh
hzya:xiangerlin
hzya:yuqh
hzya:changelogdatasource

No commits in common. "460722dde6a05b69738e1bbc5e2cc1347a4f138d" and "56841ca743a886bfb7c5389c5673d90da2c51ec0" have entirely different histories.
460722dde6 ... 56841ca743

4 changed files with 45 additions and 158 deletions
Show Stats Expand all files Collapse all files

70
base-buildpackage/src/test/java/com/hzya/frame/TestINifiBaseOperation.java
View File

@ -1,12 +1,8 @@
package com.hzya.frame; package com.hzya.frame;
import com.hzya.frame.nifiapi.model.joincreateprocessorandupdateparam.CreateProcessorAndUpdateParamJoin;
import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.Component19; import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.Component19;
import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.ControllerServices19; import com.hzya.frame.nifiapi.model.joingetallcontrollerservice.ControllerServices19;
import com.hzya.frame.nifiapi.model.resultNeedModifyController.PortFilterResult; import com.hzya.frame.nifiapi.model.resultNeedModifyController.PortFilterResult;
import com.hzya.frame.nifiapi.model.resultprocessorsinfo.Component16;
import com.hzya.frame.nifiapi.model.resultprocessorsinfo.Config16;
import com.hzya.frame.nifiapi.operation.INifiAppOperation;
import com.hzya.frame.nifiapi.operation.INifiBaseOperation; import com.hzya.frame.nifiapi.operation.INifiBaseOperation;
import org.junit.Test; import org.junit.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
@ -14,9 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.context.junit4.SpringRunner;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* @Author：liuyang * @Author：liuyang
@ -33,9 +27,6 @@ public class TestINifiBaseOperation {
@Autowired @Autowired
private INifiBaseOperation iNifiBaseOperation; private INifiBaseOperation iNifiBaseOperation;
@Autowired
private INifiAppOperation iNifiAppOperation;
@Test @Test
public void testGetNeedModifyControllerServicesByProcessGroup() throws Exception { public void testGetNeedModifyControllerServicesByProcessGroup() throws Exception {
try { try {
@ -72,65 +63,4 @@ public class TestINifiBaseOperation {
e.printStackTrace(); e.printStackTrace();
} }
} }
@Test
public void testCopyProcessor() throws Exception {
try {
String targetProcessorId = "7f70897a-0196-1000-241a-3a7cdf5bf521";
String parentProcessGroupId = "76e23100-ad84-1aab-4447-b9ee936ee7d5";
String copyTargetProcessGroupId = "76e23115-ad84-1aab-7630-21c76aa3973d";
String s = iNifiBaseOperation.copyProcessor(targetProcessorId, parentProcessGroupId, copyTargetProcessGroupId);
System.out.println("新处理器id：" + s);
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void testCreateProcessorAndUpdateParam() {
try {
Map<String, String> properties = new HashMap<>();
properties.put("File Size", "1B");
properties.put("Batch Size", "2");
properties.put("Data Format", "Binary");
properties.put("Unique FlowFiles", "true");
properties.put("character-set", "GBK");
Config16 config16 = new Config16();
config16.setProperties(properties);
Component16 component16 = new Component16();
component16.setName("修改处理器名称2");
component16.setConfig(config16);
CreateProcessorAndUpdateParamJoin createProcessorAndUpdateParamJoin = new CreateProcessorAndUpdateParamJoin();
createProcessorAndUpdateParamJoin.setComponent(component16);
createProcessorAndUpdateParamJoin.setTargetProcessorId("7f70897a-0196-1000-241a-3a7cdf5bf521");
createProcessorAndUpdateParamJoin.setCopyTargetProcessGroupId("76e23115-ad84-1aab-7630-21c76aa3973d");
createProcessorAndUpdateParamJoin.setParentProcessGroupId("76e23100-ad84-1aab-4447-b9ee936ee7d5");
String processorAndUpdateParam = iNifiAppOperation.createProcessorAndUpdateParam(createProcessorAndUpdateParamJoin);
System.out.println("新处理器id：" + processorAndUpdateParam);
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void testgGetFindStateClearMarkProcessor() throws Exception {
try {
iNifiBaseOperation.getFindStateClearMarkProcessor("41437b87-0196-1000-6951-50e41e75c0da", "接口状态清理标记");
} catch (Exception e) {
e.printStackTrace();
}
}
@Test
public void testBatchEnabledControllerServices() throws Exception {
try {
iNifiBaseOperation.batchEnabledControllerServices("4143d803-0196-1000-968f-b06f55b43a3f", "xxxx");
} catch (Exception e) {
e.printStackTrace();
}
}
} }

121
base-buildpackage/src/test/java/com/hzya/frame/TestNifiDbSync.java
View File

@ -6,7 +6,6 @@ import com.hzya.frame.nifiapi.model.joincreateconnections.Revision18;
import com.hzya.frame.nifiapi.model.joincreateconnections.SourceOrDestination18; import com.hzya.frame.nifiapi.model.joincreateconnections.SourceOrDestination18;
import com.hzya.frame.nifiapi.model.joincreateoracleapp.CreateAppInstanceJoin; import com.hzya.frame.nifiapi.model.joincreateoracleapp.CreateAppInstanceJoin;
import com.hzya.frame.nifiapi.model.joincreateprocessconnection.CreateProcessorConnections; import com.hzya.frame.nifiapi.model.joincreateprocessconnection.CreateProcessorConnections;
import com.hzya.frame.nifiapi.model.joincreateprocessorandupdateparam.CreateProcessorAndUpdateParamJoin;
import com.hzya.frame.nifiapi.model.joincreparamcontext.CreateParamContextJoin; import com.hzya.frame.nifiapi.model.joincreparamcontext.CreateParamContextJoin;
import com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller.FindNeedModifyController; import com.hzya.frame.nifiapi.model.joinfindneedmodifycontroller.FindNeedModifyController;
import com.hzya.frame.nifiapi.model.joingetcontroller.Component12; import com.hzya.frame.nifiapi.model.joingetcontroller.Component12;
@ -41,7 +40,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.context.junit4.SpringRunner;
import java.util.*; import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* @Author：liuyang * @Author：liuyang
@ -75,12 +77,7 @@ public class TestNifiDbSync {
String newProcessGroupsId = testCreateProcessGroups(parentProcessGroupId, processGroupsName); String newProcessGroupsId = testCreateProcessGroups(parentProcessGroupId, processGroupsName);
//新建GenerateFlowFile处理器(开始的处理器) //新建GenerateFlowFile处理器(开始的处理器)
// String generateFlowFileId = testCreateProcessor(newProcessGroupsId); String generateFlowFileId = testCreateProcessor(newProcessGroupsId);
CreateProcessorAndUpdateParamJoin createProcessorAndUpdateParamJoin = new CreateProcessorAndUpdateParamJoin();
createProcessorAndUpdateParamJoin.setTargetProcessorId("02d23f3c-7003-1a1b-1cdc-e9f37874bd78");
createProcessorAndUpdateParamJoin.setParentProcessGroupId("76e23100-ad84-1aab-4447-b9ee936ee7d5");
createProcessorAndUpdateParamJoin.setCopyTargetProcessGroupId(newProcessGroupsId);
String generateFlowFileId = nifiOperation.createProcessorAndUpdateParam(createProcessorAndUpdateParamJoin);
//创建Oracle应用 //创建Oracle应用
//初始化实例 //初始化实例
@ -89,11 +86,11 @@ public class TestNifiDbSync {
createOracleApp.setParentProcessGroupId("76e23100-ad84-1aab-4447-b9ee936ee7d5"); createOracleApp.setParentProcessGroupId("76e23100-ad84-1aab-4447-b9ee936ee7d5");
createOracleApp.setCopyTargetProcessGroupId(newProcessGroupsId); createOracleApp.setCopyTargetProcessGroupId(newProcessGroupsId);
//上下文 //上下文
CreateParamContextJoin createParamContextJoin = setOracleParamContextJoin(); CreateParamContextJoin createParamContextJoin = setOracleParamContextJoin(newProcessGroupsId);
createOracleApp.setCreateParamContextJoin(createParamContextJoin); createOracleApp.setCreateParamContextJoin(createParamContextJoin);
//控制器 //控制器
// FindNeedModifyController findNeedModifyController = setOracleFindNeedModifyController(newProcessGroupsId); FindNeedModifyController findNeedModifyController = setOracleFindNeedModifyController(newProcessGroupsId);
// createOracleApp.setFindNeedModifyController(findNeedModifyController); createOracleApp.setFindNeedModifyController(findNeedModifyController);
CreateAppInstanceResult oracleAppContext = nifiOperation.createAppContext(createOracleApp); CreateAppInstanceResult oracleAppContext = nifiOperation.createAppContext(createOracleApp);
//创建Mysql应用 //创建Mysql应用
@ -106,26 +103,18 @@ public class TestNifiDbSync {
CreateParamContextJoin createParamContextJoin2 = setMysqlParamContextJoin(newProcessGroupsId); CreateParamContextJoin createParamContextJoin2 = setMysqlParamContextJoin(newProcessGroupsId);
createOracleApp2.setCreateParamContextJoin(createParamContextJoin2); createOracleApp2.setCreateParamContextJoin(createParamContextJoin2);
//控制器 //控制器
// FindNeedModifyController findNeedModifyController2 = setMysqlFindNeedModifyController(newProcessGroupsId); FindNeedModifyController findNeedModifyController2 = setMysqlFindNeedModifyController(newProcessGroupsId);
// createOracleApp2.setFindNeedModifyController(findNeedModifyController2); createOracleApp2.setFindNeedModifyController(findNeedModifyController2);
CreateAppInstanceResult mysqlAppContext = nifiOperation.createAppContext(createOracleApp2); CreateAppInstanceResult mysqlAppContext = nifiOperation.createAppContext(createOracleApp2);
//新建LogAttribute处理器(结束处理器) //新建LogAttribute处理器(结束处理器)
// String logAttributeId = testCreateProcessor2(); String logAttributeId = testCreateProcessor2(newProcessGroupsId);
// String logAttributeId = null;
CreateProcessorAndUpdateParamJoin createProcessorAndUpdateParamJoin2 = new CreateProcessorAndUpdateParamJoin();
createProcessorAndUpdateParamJoin2.setTargetProcessorId("7f70897a-0196-1000-241a-3a7cdf5bf521");
createProcessorAndUpdateParamJoin2.setParentProcessGroupId("76e23100-ad84-1aab-4447-b9ee936ee7d5");
createProcessorAndUpdateParamJoin2.setCopyTargetProcessGroupId(newProcessGroupsId);
String logAttributeId = nifiOperation.createProcessorAndUpdateParam(createProcessorAndUpdateParamJoin2);
//查找对应应用的连接标记 //查找对应应用的连接标记
//TYPE=INPUT_PORT //TYPE=INPUT_PORT
PortFilterResult oracleMarkInput = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(oracleAppContext.getNewProcessGroupId(), "f5228bc8-0360-41eb-a640-9f4df953937c"); PortFilterResult oracleMark = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(oracleAppContext.getNewProcessGroupId(), null);
PortFilterResult oracleMarkOutPut = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(oracleAppContext.getNewProcessGroupId(), "4929a9ac-291a-4ea2-a4b1-286ddf47164a");
//TYPE=OUTPUT_PORT //TYPE=OUTPUT_PORT
PortFilterResult mysqlMarkInput = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(mysqlAppContext.getNewProcessGroupId(), "be05a6ad-a440-43ed-b4c0-d1edcf03334f"); PortFilterResult mysqlMark = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(mysqlAppContext.getNewProcessGroupId(), null);
PortFilterResult mysqlMarkOutput = iNifiBaseOperation.getNeedModifyControllerRelationshipByProcessGroup(mysqlAppContext.getNewProcessGroupId(), "7ac85368-f2c9-48df-ab5b-ea610449083d");
//批量创建连接关系 //批量创建连接关系
//连接关系一:开始处理器->Oracle应用 //连接关系一:开始处理器->Oracle应用
@ -135,7 +124,7 @@ public class TestNifiDbSync {
source.setType("PROCESSOR"); source.setType("PROCESSOR");
SourceOrDestination18 destination = new SourceOrDestination18(); SourceOrDestination18 destination = new SourceOrDestination18();
destination.setId(oracleMarkInput.getInputPorts().get(0).getId()); destination.setId(oracleMark.getInputPorts().get(0).getId());
destination.setGroupId(oracleAppContext.getNewProcessGroupId()); destination.setGroupId(oracleAppContext.getNewProcessGroupId());
destination.setType("INPUT_PORT"); destination.setType("INPUT_PORT");
@ -159,12 +148,12 @@ public class TestNifiDbSync {
//连接关系二：Oracle应用->Mysql应用 //连接关系二：Oracle应用->Mysql应用
SourceOrDestination18 source2 = new SourceOrDestination18(); SourceOrDestination18 source2 = new SourceOrDestination18();
source2.setId(oracleMarkOutPut.getOutputPorts().get(0).getId()); source2.setId(oracleMark.getOutputPorts().get(0).getId());
source2.setGroupId(oracleAppContext.getNewProcessGroupId()); source2.setGroupId(oracleAppContext.getNewProcessGroupId());
source2.setType("OUTPUT_PORT"); source2.setType("OUTPUT_PORT");
SourceOrDestination18 destination2 = new SourceOrDestination18(); SourceOrDestination18 destination2 = new SourceOrDestination18();
destination2.setId(mysqlMarkInput.getInputPorts().get(0).getId()); destination2.setId(mysqlMark.getInputPorts().get(0).getId());
destination2.setGroupId(mysqlAppContext.getNewProcessGroupId()); destination2.setGroupId(mysqlAppContext.getNewProcessGroupId());
destination2.setType("INPUT_PORT"); destination2.setType("INPUT_PORT");
@ -186,7 +175,7 @@ public class TestNifiDbSync {
//连接关系三：Mysql应用->结束处理器 //连接关系三：Mysql应用->结束处理器
SourceOrDestination18 source3 = new SourceOrDestination18(); SourceOrDestination18 source3 = new SourceOrDestination18();
source3.setId(mysqlMarkOutput.getOutputPorts().get(0).getId()); source3.setId(mysqlMark.getOutputPorts().get(0).getId());
source3.setGroupId(mysqlAppContext.getNewProcessGroupId()); source3.setGroupId(mysqlAppContext.getNewProcessGroupId());
source3.setType("OUTPUT_PORT"); source3.setType("OUTPUT_PORT");
@ -216,12 +205,6 @@ public class TestNifiDbSync {
createProcessorConnections.setCreateConnections18(createConnections18List); createProcessorConnections.setCreateConnections18(createConnections18List);
iNifiBaseOperation.batchCreateProcessorConnections(createProcessorConnections); iNifiBaseOperation.batchCreateProcessorConnections(createProcessorConnections);
//去掉流程组内对应的处理器旧状态
// List<String> stringList = new ArrayList<>();
// stringList.add(oracleAppContext.getNewProcessGroupId());
// stringList.add(mysqlAppContext.getNewProcessGroupId());
// iNifiBaseOperation.clearProcessGroupState(stringList);
//启动业务处理器 //启动业务处理器
ProcessGroupsInfoResult9 processGroups = nifiApiService.getProcessGroups(newProcessGroupsId); ProcessGroupsInfoResult9 processGroups = nifiApiService.getProcessGroups(newProcessGroupsId);
Revision9 revision = processGroups.getRevision(); Revision9 revision = processGroups.getRevision();
@ -238,7 +221,7 @@ public class TestNifiDbSync {
} }
public CreateParamContextJoin setOracleParamContextJoin() throws Exception { public CreateParamContextJoin setOracleParamContextJoin(String processGroupsId) throws Exception {
Revision revision = new Revision(); Revision revision = new Revision();
revision.setVersion(0); revision.setVersion(0);
@ -246,31 +229,31 @@ public class TestNifiDbSync {
parameter.setSensitive(false); parameter.setSensitive(false);
parameter.setName("additionalWhereClause"); parameter.setName("additionalWhereClause");
parameter.setValue("1=1"); parameter.setValue("1=1");
parameter.setDescription("where条件"); parameter.setDescription("参数描述");
Parameter2 parameter2 = new Parameter2(); Parameter2 parameter2 = new Parameter2();
parameter2.setSensitive(false); parameter2.setSensitive(false);
parameter2.setName("columnsToReturn"); parameter2.setName("columnsToReturn");
parameter2.setValue("pk_invbasdoc,invcode,ts"); parameter2.setValue("CSALEID,VRECEIPTCODE,NHEADSUMMNY,TS");
parameter2.setDescription("需要查询的表字段"); parameter2.setDescription("参数描述");
Parameter2 parameter3 = new Parameter2(); Parameter2 parameter3 = new Parameter2();
parameter3.setSensitive(false); parameter3.setSensitive(false);
parameter3.setName("customOrderByColumn"); parameter3.setName("customOrderByColumn");
parameter3.setValue("ts asc"); parameter3.setValue("ts asc");
parameter3.setDescription("排序规则"); parameter3.setDescription("参数描述");
Parameter2 parameter4 = new Parameter2(); Parameter2 parameter4 = new Parameter2();
parameter4.setSensitive(false); parameter4.setSensitive(false);
parameter4.setName("maximumValueColumns"); parameter4.setName("maximumValueColumns");
parameter4.setValue("ts"); parameter4.setValue("ts");
parameter4.setDescription("分片字段"); parameter4.setDescription("参数描述");
Parameter2 parameter5 = new Parameter2(); Parameter2 parameter5 = new Parameter2();
parameter5.setSensitive(false); parameter5.setSensitive(false);
parameter5.setName("sourceTbName"); parameter5.setName("sourceTbName");
parameter5.setValue("U8C241231.BD_INVBASDOC"); parameter5.setValue("U8C241231.SO_SALE");
parameter5.setDescription("查询表名称"); parameter5.setDescription("参数描述");
Parameters2 parameters = new Parameters2(); Parameters2 parameters = new Parameters2();
parameters.setParameter(parameter); parameters.setParameter(parameter);
@ -295,7 +278,7 @@ public class TestNifiDbSync {
parametersList.add(parameters5); parametersList.add(parameters5);
Component3 component = new Component3(); Component3 component = new Component3();
component.setName("oracle参数环境2505241627"); component.setName("oracle参数环境2505221548");
component.setParameters(parametersList); component.setParameters(parametersList);
ParameterContextsJoin parameterContextsJoin = new ParameterContextsJoin(); ParameterContextsJoin parameterContextsJoin = new ParameterContextsJoin();
@ -304,7 +287,7 @@ public class TestNifiDbSync {
CreateParamContextJoin createParamContextJoin = new CreateParamContextJoin(); CreateParamContextJoin createParamContextJoin = new CreateParamContextJoin();
createParamContextJoin.setParameterContextsJoin(parameterContextsJoin); createParamContextJoin.setParameterContextsJoin(parameterContextsJoin);
// createParamContextJoin.setProcessGroupsId(processGroupsId); createParamContextJoin.setProcessGroupsId(processGroupsId);
return createParamContextJoin; return createParamContextJoin;
} }
@ -312,29 +295,23 @@ public class TestNifiDbSync {
Revision revision = new Revision(); Revision revision = new Revision();
revision.setVersion(0); revision.setVersion(0);
// Parameter2 parameter = new Parameter2(); Parameter2 parameter = new Parameter2();
// parameter.setSensitive(false); parameter.setSensitive(false);
// parameter.setName("Release Signal Identifier"); parameter.setName("Release Signal Identifier");
// parameter.setValue("table_creation"); parameter.setValue("table_creation");
// parameter.setDescription("参数描述"); parameter.setDescription("参数描述");
Parameter2 parameter2 = new Parameter2(); Parameter2 parameter2 = new Parameter2();
parameter2.setSensitive(false); parameter2.setSensitive(false);
parameter2.setName("autoTableCreation"); parameter2.setName("autoTableCreation");
parameter2.setValue("Y"); parameter2.setValue("Y");
parameter2.setDescription("是否自动建表"); parameter2.setDescription("参数描述");
Parameter2 parameter3 = new Parameter2(); Parameter2 parameter3 = new Parameter2();
parameter3.setSensitive(false); parameter3.setSensitive(false);
parameter3.setName("mappingRelationship"); parameter3.setName("mappingRelationship");
parameter3.setValue("[\n" + " {\n" + " \"targetTbName\": \"iep_bd_invbasdoc\",\n" + " \"targetDBType\": \"mysql8.0.44\",\n" + " \"writeType\": \"1\",\n" + " \"fieldRelationship\": [\n" + " {\n" + " \"sourceFieldName\": \"PK_INVBASDOC\",\n" + " \"sourceFieldType\": \"CHAR(20)\",\n" + " \"targetFieldName\": \"pk_invbasdoc\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"存货档案id\",\n" + " \"primaryKey\": \"Y\"\n" + " },\n" + " {\n" + " \"sourceFieldName\": \"INVCODE\",\n" + " \"sourceFieldType\": \"VARCHAR(30)\",\n" + " \"targetFieldName\": \"invcode\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"单据号\"\n" + " },\n" + " {\n" + " \"sourceFieldName\": \"TS\",\n" + " \"sourceFieldType\": \"CHAR(19)\",\n" + " \"targetFieldName\": \"ts\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"时间戳\"\n" + " }\n" + " ]\n" + " }\n" + "]"); parameter3.setValue("[\n" + " {\n" + " \"targetTbName\": \"iep_so_sale\",\n" + " \"targetDBType\": \"mysql8.0.44\",\n" + " \"writeType\": \"1\",\n" + " \"fieldRelationship\": [\n" + " {\n" + " \"sourceFieldName\": \"CSALEID\",\n" + " \"sourceFieldType\": \"CHAR(20)\",\n" + " \"targetFieldName\": \"csaleid\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"销售主表id\",\n" + " \"primaryKey\": \"Y\"\n" + " },\n" + " {\n" + " \"sourceFieldName\": \"VRECEIPTCODE\",\n" + " \"sourceFieldType\": \"VARCHAR(30)\",\n" + " \"targetFieldName\": \"vreceiptcode\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"单据号\"\n" + " },\n" + " {\n" + " \"sourceFieldName\": \"NHEADSUMMNY\",\n" + " \"sourceFieldType\": \"DECIMAL(13,8)\",\n" + " \"targetFieldName\": \"nheadsummny\",\n" + " \"targetFieldType\": \"decimal(20,10)\",\n" + " \"targetFieldNameNotes\": \"金额合计\"\n" + " },\n" + " {\n" + " \"sourceFieldName\": \"TS\",\n" + " \"sourceFieldType\": \"CHAR(19)\",\n" + " \"targetFieldName\": \"ts\",\n" + " \"targetFieldType\": \"varchar(20)\",\n" + " \"targetFieldNameNotes\": \"时间戳\"\n" + " }\n" + " ]\n" + " }\n" + " ]");
parameter3.setDescription("字段对照关系"); parameter3.setDescription("参数描述");
Parameter2 parameter4 = new Parameter2();
parameter4.setSensitive(false);
parameter4.setName("releaseSignalIdentifier");
parameter4.setValue(UUID.randomUUID().toString());
parameter4.setDescription("建表信号，传随机值！");
// Parameter2 parameter4 = new Parameter2(); // Parameter2 parameter4 = new Parameter2();
// parameter4.setSensitive(false); // parameter4.setSensitive(false);
@ -349,7 +326,7 @@ public class TestNifiDbSync {
// parameter5.setDescription("参数描述"); // parameter5.setDescription("参数描述");
Parameters2 parameters = new Parameters2(); Parameters2 parameters = new Parameters2();
parameters.setParameter(parameter4); parameters.setParameter(parameter);
Parameters2 parameters2 = new Parameters2(); Parameters2 parameters2 = new Parameters2();
parameters2.setParameter(parameter2); parameters2.setParameter(parameter2);
@ -371,7 +348,7 @@ public class TestNifiDbSync {
// parametersList.add(parameters5); // parametersList.add(parameters5);
Component3 component = new Component3(); Component3 component = new Component3();
component.setName("mysql参数环境2505241627"); component.setName("mysql参数环境2505230915");
component.setParameters(parametersList); component.setParameters(parametersList);
ParameterContextsJoin parameterContextsJoin = new ParameterContextsJoin(); ParameterContextsJoin parameterContextsJoin = new ParameterContextsJoin();
@ -501,8 +478,7 @@ public class TestNifiDbSync {
String mysqlProcessGroupId = testCreateSnippetInstance(processGroupsId, parentProcessGroupId, mysqlSnippetId); String mysqlProcessGroupId = testCreateSnippetInstance(processGroupsId, parentProcessGroupId, mysqlSnippetId);
//新建LogAttribute处理器(结束处理器) //新建LogAttribute处理器(结束处理器)
// String logAttributeId = testCreateProcessor2(); String logAttributeId = testCreateProcessor2(processGroupsId);
String logAttributeId = null;
//修改Oracle应用数据源 //修改Oracle应用数据源
//修改Oracle应用上下文环境 //修改Oracle应用上下文环境
@ -620,9 +596,8 @@ public class TestNifiDbSync {
/** /**
* 创建LogAttribute处理器 * 创建LogAttribute处理器
*/ */
@Test public String testCreateProcessor2(String groupId) throws Exception {
public void testCreateProcessor2() throws Exception { String processorId = null;
// String processorId = null;
try { try {
Revision15 revision15 = new Revision15(); Revision15 revision15 = new Revision15();
revision15.setVersion("0"); revision15.setVersion("0");
@ -650,28 +625,18 @@ public class TestNifiDbSync {
component15.setConfig(config15); component15.setConfig(config15);
// component15.setPosition(position15); // component15.setPosition(position15);
//定义连接关系
Relationships15 relationships15 = new Relationships15();
relationships15.setName("success");
relationships15.setAutoTerminate(true);
// relationships15.setRetry(true);
// relationships15.setDescription("123");
List<Relationships15> relationships15List = new ArrayList<>();
relationships15List.add(relationships15);
component15.setRelationships(relationships15List);
CreateProcessorJoin15 createProcessorJoin15 = new CreateProcessorJoin15(); CreateProcessorJoin15 createProcessorJoin15 = new CreateProcessorJoin15();
createProcessorJoin15.setComponent(component15); createProcessorJoin15.setComponent(component15);
createProcessorJoin15.setRevision(revision15); createProcessorJoin15.setRevision(revision15);
String groupId = "76e23115-ad84-1aab-7630-21c76aa3973d"; // String groupId = "019610d1-f933-1f70-16ea-3cf005012c4b";
CreateProcess16 processor = nifiApiService.createProcessor(groupId, createProcessorJoin15); CreateProcess16 processor = nifiApiService.createProcessor(groupId, createProcessorJoin15);
// System.out.println("处理器id：" + processor.getId()); // System.out.println("处理器id：" + processor.getId());
// processorId = processor.getId(); processorId = processor.getId();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
// return processorId; return processorId;
} }
/** /**

10
base-buildpackage/src/test/java/com/hzya/frame/TestNifiServiceApi.java
View File

@ -896,7 +896,7 @@ public class TestNifiServiceApi {
public void testGetProcessor() throws Exception { public void testGetProcessor() throws Exception {
try { try {
// String processId = "01961137-f933-1f70-4f08-6fc7041f99bd"; // String processId = "01961137-f933-1f70-4f08-6fc7041f99bd";
String processId2 = "02d23f3c-7003-1a1b-1cdc-e9f37874bd78"; String processId2 = "7f70897a-0196-1000-241a-3a7cdf5bf521";
ProcessorsInfo16 processor = nifiApiService.getProcessor(processId2); ProcessorsInfo16 processor = nifiApiService.getProcessor(processId2);
String id = processor.getId(); String id = processor.getId();
System.out.println(id); System.out.println(id);
@ -1087,12 +1087,4 @@ public class TestNifiServiceApi {
// e.printStackTrace(); // e.printStackTrace();
// } // }
// } // }
@Test
public void testClearProcessorRequests() throws Exception {
try {
nifiApiService.clearProcessorRequests("019617a7-f933-1f70-9747-dac20033270f");
} catch (Exception e) {
e.printStackTrace();
}
}
} }

2
fw-nifi/src/main/java/com/hzya/frame/nifiapi/model/processgroupid/Connections.java
View File

@ -12,7 +12,7 @@ public class Connections {
private Permissions permissions; private Permissions permissions;
private Component component; private Component component;
private Status status; private Status status;
// private List<String> bends; private List<String> bends;
private String labelIndex; private String labelIndex;
private String zIndex; private String zIndex;
private String sourceId; private String sourceId;