4c i )j kl m )n opq rs )t )uv )wx i y z{ )| } )~     i        &i  *   /    > 9i    > <   )        ^i ^   ) e e i i  w     e}  w w   |      )      tableManagerBLcom/artfess/dataShare/dataCollect/manager/BizClusterTableManager;RuntimeVisibleAnnotationsLjavax/annotation/Resource; infoManagerALcom/artfess/dataShare/dataCollect/manager/BizClusterInfoManager;tableTriggerManagerILcom/artfess/dataShare/dataCollect/manager/BizClusterTableTriggerManager;infoModeManagerELcom/artfess/dataShare/dataCollect/manager/BizClusterInfoModeManager;()VCodeLineNumberTableLocalVariableTablethisHLcom/artfess/dataShare/dataCollect/controller/BizClusterTableController;create`(Lcom/artfess/dataShare/dataCollect/model/BizClusterTable;)Lcom/artfess/base/model/CommonResult;info8Lcom/artfess/dataShare/dataCollect/model/BizClusterInfo;t9Lcom/artfess/dataShare/dataCollect/model/BizClusterTable;resultZ StackMapTable Signaturet(Lcom/artfess/dataShare/dataCollect/model/BizClusterTable;)Lcom/artfess/base/model/CommonResult;5Lorg/springframework/web/bind/annotation/PostMapping;value/%Lio/swagger/annotations/ApiOperation;添加实体的接口"RuntimeVisibleParameterAnnotations!Lio/swagger/annotations/ApiParam;namemodel 实体信息5Lorg/springframework/validation/annotation/Validated;!Lcom/artfess/base/valid/AddGroup;5Lorg/springframework/web/bind/annotation/RequestBody;exportj(Lorg/springframework/web/multipart/MultipartFile;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;file1Lorg/springframework/web/multipart/MultipartFile; clusterInfoIdLjava/lang/String; Exceptions~(Lorg/springframework/web/multipart/MultipartFile;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult; /importFile导入数据汇聚表信息 httpMethodPOSTnotes6Lorg/springframework/web/bind/annotation/RequestParam;requiredDeploy9(Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;tableIdM(Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;/Deploy/{tableId}4直接发布表,创建实体表-使用默认的SQL6Lorg/springframework/web/bind/annotation/PathVariable; saveTableVo[(Lcom/artfess/dataShare/dataCollect/vo/TableDetailVo;)Lcom/artfess/base/model/CommonResult;vo4Lcom/artfess/dataShare/dataCollect/vo/TableDetailVo;o(Lcom/artfess/dataShare/dataCollect/vo/TableDetailVo;)Lcom/artfess/base/model/CommonResult; /saveTableVo-保存查询表信息、字段信息、模型 queryTableVoH(Ljava/lang/String;)Lcom/artfess/dataShare/dataCollect/vo/TableDetailVo;/queryTableVo/{tableId}0根据表查询表信息、字段信息、模型queryTableData](Lcom/artfess/dataShare/factory/QueryParamVo;)Lcom/artfess/dataShare/factory/QueryResultData; queryParamVo,Lcom/artfess/dataShare/factory/QueryParamVo;/queryTableData)数据查询 分页,加搜索、排序queryTableInfo#(Ljava/lang/String;)Ljava/util/Map;insertTigerSql triggerMapLjava/util/Map;map triggerSqlLjava/util/List;tableinfoMode;GLjava/util/List;>;I(Ljava/lang/String;)Ljava/util/Map;/queryTableInfo/{tableId}<根据表查询建表语句、触发器语句、创建结果 createdTable/createdTable/{tableId} 手动建表createdTrigger/createdTrigger/{tableId}手动建触发器downloadMainTempFile=(Ljavax/servlet/http/HttpServletResponse;Ljava/lang/String;)Vresponse(Ljavax/servlet/http/HttpServletResponse;8Lorg/springframework/web/bind/annotation/RequestMapping;downloadMainTempFile/{tableId}method7Lorg/springframework/web/bind/annotation/RequestMethod;producesapplication/json; charset=utf-8下载导入的模板 模板别名 importMain导入汇聚主表数据 downTableSqlitem@Lcom/artfess/dataShare/dataCollect/model/BizClusterTableTrigger; queryWrapper=Lcom/baomidou/mybatisplus/core/conditions/query/QueryWrapper;listtableSqltextLjava/lang/StringBuffer; rootRealPathpathLjava/io/File;RLjava/util/List;downTableSql/{tableId}'下载建表语句和触发器SQL文件 数据表IDlistJsonG(Lcom/artfess/base/query/QueryFilter;)Lcom/artfess/base/query/PageList; queryFilter$Lcom/artfess/base/query/QueryFilter;.Lcom/baomidou/mybatisplus/core/metadata/IPage;pageList!Lcom/artfess/base/query/PageList;iLcom/baomidou/mybatisplus/core/metadata/IPage;\Lcom/artfess/base/query/PageList;(Lcom/artfess/base/query/QueryFilter;)Lcom/artfess/base/query/PageList;查询汇聚主表数据通用查询对象checkTableExists](Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult; clusterId tableNameEntypeisExistsq(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;验证表是否已经存在 汇聚方ID 表英文名3发布类型(0:未有表发布,1:已有表发布)checkPhysicsTableExists!验证物理表是否已经存在 copyTable^(Lcom/artfess/dataShare/dataResource/ods/vo/CopyTableVo;)Lcom/artfess/base/model/CommonResult;7Lcom/artfess/dataShare/dataResource/ods/vo/CopyTableVo;r(Lcom/artfess/dataShare/dataResource/ods/vo/CopyTableVo;)Lcom/artfess/base/model/CommonResult;引用/复制创建的其他表复制创建的其他表 queryTableSqlqueryTableSql/{tableId}根据tableId查询建表语句 saveTableSqlK(Ljava/lang/String;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;_(Ljava/lang/String;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;保存建表SQL 建表语句deployHaveTable createTrigger%已有表发布-同时创建触发器已有表发布是否创建触发器 0否 1是deployDotHaveTable%未有表发布-同时创建触发器 removeTable4刪除表-如果表已经创建同步删除实体表^(Lcom/baomidou/mybatisplus/extension/activerecord/Model;)Lcom/artfess/base/model/CommonResult;Lcom/artfess/base/controller/BaseController; SourceFileBizClusterTableController.java8Lorg/springframework/web/bind/annotation/RestController;!/biz/dataCollect/clusterTable/v1/&Lcom/artfess/base/annotation/ApiGroup;groupgroup_biz_dataShareLio/swagger/annotations/Api;tags"数据汇聚-数据汇聚表信息      6com/artfess/dataShare/dataCollect/model/BizClusterInfo    0 java/lang/StringBuilder  _    @com/artfess/dataShare/dataCollect/manager/BizClusterTableManager #com/artfess/base/model/CommonResult  ! "导入数据汇聚表成功 # 发布表成功 $ 维护成功 java/util/HashMap %&7com/artfess/dataShare/dataCollect/model/BizClusterTable/com/artfess/base/exception/ApplicationException未查询到表  ' %(:com/artfess/dataShare/dataCollect/model/BizClusterInfoMode )* +,SELECT trigger_schema,trigger_name,event_manipulation,event_object_schema,event_object_table,action_statement FROM information_schema.triggers WHERE EVENT_OBJECT_TABLE = ?java/lang/Object -. /0is_created_trigger1 12java/util/ArrayList 34 56 78 java/util/MapCREATE TRIGGER  trigger_name  9 :event_object_table  AFTER event_manipulation ON  FOR EACH ROW action_statementsql ;trigger <=is_created_table >?createTableSql L@ 手动建表成功 手动建触发器成功   "导入主表数据成功;com/baomidou/mybatisplus/core/conditions/query/QueryWrapper table_id_ A2 B C Djava/lang/StringBuffer创建表SQL: E>com/artfess/dataShare/dataCollect/model/BizClusterTableTrigger F GH I/temp/ J KL MNO PQ R.txt ST java/io/FileU VW XYcom/artfess/base/query/PageList Z 8[ \验证成功,可以发布表 不存在!已经存在,请更换表名可以使用表名 D[ F] 操作成功 获取成功 ^_ ` a 保存成功 TT已有表发布成功 Yb未有表发布成功 [ Fcom/artfess/dataShare/dataCollect/controller/BizClusterTableController*com/artfess/base/controller/BaseControllerjava/lang/Exceptionjava/lang/String*org/springframework/jdbc/core/JdbcTemplatejava/util/Listjava/util/Iterator&javax/servlet/http/HttpServletResponsegetId()Ljava/lang/String; com/artfess/base/util/StringUtilisEmpty(Ljava/lang/String;)Z getClusterId?com/artfess/dataShare/dataCollect/manager/BizClusterInfoManagergetO(Ljava/io/Serializable;)Lcom/baomidou/mybatisplus/extension/activerecord/Model;java/lang/IntegervalueOf(I)Ljava/lang/Integer; setDeployed(Ljava/lang/Integer;)VsetIsCreateTable setIsDele(Ljava/lang/String;)VgetSysTableCodeappend-(Ljava/lang/String;)Ljava/lang/StringBuilder;getTableNameEntoStringsetTableNameEn baseService&Lcom/artfess/base/manager/BaseManager;save(Ljava/lang/Object;)Z)com/artfess/base/enums/ResponseErrorEnums FAIL_OPTION+Lcom/artfess/base/enums/ResponseErrorEnums;@(Lcom/artfess/base/enums/ResponseErrorEnums;Ljava/lang/Object;)VF(Lorg/springframework/web/multipart/MultipartFile;Ljava/lang/String;)V(ZLjava/lang/String;)V7(Lcom/artfess/dataShare/dataCollect/vo/TableDetailVo;)VgetByIdK(Ljava/lang/String;)Lcom/baomidou/mybatisplus/extension/activerecord/Model;Ccom/artfess/dataShare/dataCollect/manager/BizClusterInfoModeManager*(Ljava/io/Serializable;)Ljava/lang/Object;getDatabaseAlias$com/artfess/base/util/DataSourceUtilgetJdbcTempByDsAlias@(Ljava/lang/String;)Lorg/springframework/jdbc/core/JdbcTemplate; queryForList7(Ljava/lang/String;[Ljava/lang/Object;)Ljava/util/List;size()Iput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;iterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;&(Ljava/lang/Object;)Ljava/lang/Object;-(Ljava/lang/Object;)Ljava/lang/StringBuilder;addqueryTriggerSql$(Ljava/lang/String;)Ljava/util/List;getIsCreateTable()Ljava/lang/Integer;&(Ljava/lang/String;)Ljava/lang/String;eqGcom/artfess/dataShare/dataCollect/manager/BizClusterTableTriggerManagerD(Lcom/baomidou/mybatisplus/core/conditions/Wrapper;)Ljava/util/List;getCreateTableSql,(Ljava/lang/String;)Ljava/lang/StringBuffer; getTriggerSqlgetNamecom/artfess/base/util/FileUtil getIoTmpdir separatorreplaceD(Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/lang/String; createFolder(Ljava/lang/String;Z)Vjava/lang/SystemcurrentTimeMillis()J(J)Ljava/lang/StringBuilder; writeFile'(Ljava/lang/String;Ljava/lang/String;)Vcom/artfess/base/util/HttpUtil downLoadFileO(Ljavax/servlet/http/HttpServletResponse;Ljava/lang/String;Ljava/lang/String;)VgetClusterTableQueryListT(Lcom/artfess/base/query/QueryFilter;)Lcom/baomidou/mybatisplus/core/metadata/IPage;1(Lcom/baomidou/mybatisplus/core/metadata/IPage;)V'(Ljava/lang/String;Ljava/lang/String;)Zequals:(Lcom/artfess/dataShare/dataResource/ods/vo/CopyTableVo;)VsuccessK(Ljava/lang/Object;Ljava/lang/String;)Lcom/artfess/base/model/CommonResult;setCreateTableSql updateById9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V!/*6 x+K*+M+ + + + Y,+*+=YY* K LM#N+O1PRR`SdTpV*7xx` R[ss!ss[cX*+,Y \ ] ![sssssZM*+ Y! m n[ssM*+"Y# t u[ssO *+$M, { |   [ss? *+% [ss&Y'M*+()N- *Y+,*--./:-:01:2:3YS4:5,678W9Y:: ;:  < =>: Y? @ABC DABEF GABHI JAB: &Y':  K 8W L @A8W M GA8W  NWF,O8W!,6 8W,O*+P8W,Q-R8W,S*+T8W,r 28BFXbmv /9<GJUhu E < v y2X8RBHFDX24< v X2: ^  [ssM*+UYV  [ssM*+WYX  [s s   Q*+,Y   3[s[e[ssssssZZ*+,ZY[\  )[s[ssss!sZsZ  *,])N^Y_:`,aW*bc:-d:eYfg:hW;:<3=i:  j: Eh khEh hWɻ Ylmnop:q Yorst:  uvwY x: +  yzJ -3>Fel l e!  -3> !I"!# $ -%'O &'(9)[s)[ss*ss*ss+,-*+{M|Y,}N-*./ 012 31453[s[e[ss6ss6s.s789x*+,~67-4YY Y,$Y Y,Y" & G L m4xx:x;x< k=& %>)[s8[ss?ss?Bs:s@s;sAs<sBZCD9x*+,67-4YY Y,$Y Y,Y" &GLm 4xx:x;x< k=& %>)[sD[ssEss?Bs:s@s;sAs<sBZCFGM*+Y & 'HI)[sF[ssJssKLT*+TM, - .  )[sM[ssNssNss+OP})*+])N-,*-WY5678*)))Q)[sO[ssRssR)ss+ssSTPX*+,Y ? @ UQ3[sT[e[ssVssW)ss+sUsXY9c*+,-Y H I*U>3[sY[e[ssZssZ=ss+ssSsUsX[M*+Y O P3[s[[e[ss\ss\ss+A]3 *+)2  [ss!ss[c^_`*a[sbcd[sefg[sh