Linkis1.2.0[datamodel][dataassets][datawarehouse] #952
Conversation
Linkis1.2.0+dss1.2.0[datamodel][dataassets][datawarehouse],Realize data model management, connect with Atlas, and realize blood relationship management
Zosimer
changed the title
Zosimer
changed the title
Linkis1.2.0+dss1.2.0[datamodel][dataassets][datawarehouse],Realize data model management, connect with Atlas, and realize blood relationship management
|
|
||
| wds.workspace.client.dws.version=v1 | ||
|
|
||
| wds.wedatasphere.data.assert.client.strategy=static |
There was a problem hiding this comment.
recommend wds.wedatasphere.data.assert.client.strategy=token
|
|
||
|
|
||
|
|
||
| wds.wedatasphere.data.model.client.strategy=static |
| getBaseMapper().insert(newOne); | ||
|
|
||
| //同步atlas | ||
| CreateModelTypeResult result = assertsSyncService.syncCreateModel( |
There was a problem hiding this comment.
publisher.publishEvent(new CreateModelEvent(this
, DataModelSecurityContextHolder.getContext().getDataModelAuthentication().getUser()
, vo.getFieldIdentifier()
, ClassificationConstant.DIMENSION));
| getBaseMapper().update(updateOne, Wrappers.<DssDatamodelDimension>lambdaUpdate().eq(DssDatamodelDimension::getId,id)); | ||
|
|
||
| //同步atlas | ||
| UpdateModelTypeResult updateModelTypeResult = assertsSyncService.syncUpdateModel( |
There was a problem hiding this comment.
publisher.publishEvent(new UpdateModelEvent(this
,DataModelSecurityContextHolder.getContext().getDataModelAuthentication().getUser()
,vo.getFieldIdentifier()
,orgFieldIdentifier
,ClassificationConstant.DIMENSION));
| } | ||
| getBaseMapper().deleteById(id); | ||
| //同步资产 | ||
| assertsSyncService.syncDeleteModel(new DeleteModelEvent(this |
There was a problem hiding this comment.
publisher.publishEvent(new DeleteModelEvent(this
,DataModelSecurityContextHolder.getContext().getDataModelAuthentication().getUser()
,dssDatamodelDimension.getFieldIdentifier()
,ClassificationConstant.DIMENSION));
| PreconditionUtil.checkState(1 == insert, DwException.stateReject("create dw layer failed")); | ||
|
|
||
| // 建立关联 | ||
| try { |
|
|
||
| // 删除关联 | ||
| try { | ||
| LinkisDataAssetsRemoteClient dataAssetsRemoteClient = LinkisRemoteClientHolder.getDataAssetsRemoteClient(); |
| PreconditionUtil.checkState(1 == i, DwException.stateReject("update layer failed")); | ||
|
|
||
| // 更新关联 | ||
| if (!Objects.equals(orgEnName, layer.getEnName())) { |
|
|
||
| // 建立关联 | ||
| try { | ||
| LinkisDataAssetsRemoteClient dataAssetsRemoteClient = LinkisRemoteClientHolder.getDataAssetsRemoteClient(); |
| int i = this.dwThemeDomainMapper.deleteById(record); | ||
| PreconditionUtil.checkState(1 == i, DwException.stateReject("remove action failed")); | ||
|
|
||
| // 删除关联 |
| int versionCount = (int) preReferences.stream().filter(e->{ | ||
| DssDatamodelTableColumns temp = gson.fromJson(e.getTableParams(),DssDatamodelTableColumns.class); | ||
| //名称相同且类型相同 | ||
| return modeType.getType() == temp.getModelType()&&StringUtils.equals(name,temp.getModelName()); |
There was a problem hiding this comment.
temp.getModelType() !=null && modeType.getType() == temp.getModelType() && StringUtils.equals(name, temp.getModelName());
fixed some bugs
Linkis1.2.0+dss1.2.0[datamodel][dataassets][datawarehouse],Realize data model management, connect with Atlas, and realize blood relationship management
What is the purpose of the change
(For example: AppConn Core defines the abstractions and interfaces of the AppConn core functions.
It is the core concept that enables DSS to easily and quickly integrate various upper-layer web systems.
Related issues: #953. )