指标统计sql脚本

ZB_CK/差异清单导出/ZB_CK_CHECK_CBDATA.sql

@@ -24,7 +24,7 @@ WITH (
 
 );
 
-create table kafka_cbdata
+create table KAFKA_CBDATA
 (
     uwConclueDate      varchar(64) null,
     startTime          varchar(64) null,
@@ -51,7 +51,7 @@ WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=
 ;
 
 -- 车型
-create table check_webservice
+create table CHECK_WEBSERVICE
 (
     HOSTNAME            VARCHAR(20),
     COMCODE             VARCHAR(50),
@@ -69,7 +69,7 @@ WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=
 'table-name' = 'check_webservice','username' = 'service','password' = 'ydwf12356aA!','scan.fetch-size' = '1000','sink.buffer-flush.max-rows' = '100');
 
 
-create table check_cbdata
+create table CHECK_CBDATA
 (
     uwConclueDate      varchar(64) ,
     startTime          varchar(64) ,
@@ -96,7 +96,7 @@ WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=
 ;
 
 
-insert into check_cbdata
+insert into ZB_CK.ZB_CK_MYSQL.CHECK_CBDATA
 select
 	s1.uwConclueDate       ,
 	s1.startTime           ,
@@ -118,10 +118,10 @@ select
 	s1.`flag`              ,
 	s1.log_time          
 from (
-	select * from kafka_cbdata where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
+	select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
 ) s1
 left join (
-	select * from WEB_REALTIME_BUSINESS_INFO where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
+	select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
 ) s2
 on s1.`no` = s2.BUSINESSNO
 and s1.COMCODE = s2.COMCODE

ZB_CK/差异清单导出/ZB_CK_CHECK_WEBSERVICE.sql

@@ -103,7 +103,7 @@ WITH ('connector' ='jdbc','url'='jdbc:mysql://9.1.200.87:3306/zb_ck?useTimezone=
 ;
 
 
-insert into check_webservice
+insert into ZB_CK.ZB_CK_MYSQL.CHECK_WEBSERVICE
 select
 	s2.HOSTNAME                ,
 	s2.COMCODE                 ,
@@ -117,11 +117,11 @@ select
 	s2.BUSINESSNATURE          ,
 	s2.BUSINESSCHANNELCODE
 from (
-	select * from WEB_REALTIME_BUSINESS_INFO
+	select * from ZB_CK.ZB_CK_ORACLE_ANAQUERY.WEB_REALTIME_BUSINESS_INFO
 	where UNDERWRITEENDDATE like concat(DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyy-MM-dd'),'%')
 ) s2
 left join (
-	select * from kafka_cbdata
+	select * from ZB_CK.ZB_CK_MYSQL.KAFKA_CBDATA
 	where uwConclueDate = DATE_FORMAT(TIMESTAMPADD(DAY,-1,LOCALTIMESTAMP),'yyyyMMdd')
 ) s1
 on s1.`no` = s2.BUSINESSNO