diff --git a/11 DM_TD_EXTERNAL_MARKET_NEW.sql b/11 DM_TD_EXTERNAL_MARKET_NEW.sql index ed69a23..0da8085 100644 --- a/11 DM_TD_EXTERNAL_MARKET_NEW.sql +++ b/11 DM_TD_EXTERNAL_MARKET_NEW.sql @@ -10,9 +10,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; -- COMMAND ---------- @@ -27,9 +27,9 @@ -- ETL_UPDATE_DT TIMESTAMP -- ) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; -- COMMAND ---------- diff --git a/CHC/04 DM_TD_EXT_CHC_PACK2MARKET.sql b/CHC/04 DM_TD_EXT_CHC_PACK2MARKET.sql index f884de9..c9fb64d 100644 --- a/CHC/04 DM_TD_EXT_CHC_PACK2MARKET.sql +++ b/CHC/04 DM_TD_EXT_CHC_PACK2MARKET.sql @@ -40,9 +40,9 @@ -- ETL_UPDATE_DT TIMESTAMP -- ) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; -- COMMAND ---------- @@ -51,9 +51,9 @@ -- MARKET STRING, -- PACK_CODE STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_keycompetitor'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_keycompetitor'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_keycompetitor'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_keycompetitor'; -- COMMAND ---------- @@ -62,9 +62,9 @@ -- PACK_CODE STRING, -- CLASS STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_class'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_class'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_class'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market_class'; -- COMMAND ---------- @@ -324,4 +324,4 @@ LEFT JOIN DWD.DWD_GND_TBLCLASS T2 AND (T2.NFC1_CODE IS NULL OR T1.APP1_CODE = T2.NFC1_CODE) AND (T2.NFC2_CODE IS NULL OR T1.APP2_CODE = T2.NFC2_CODE) AND (T2.NFC3_CODE IS NULL OR T1.APP3_CODE = T2.NFC3_CODE) - AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) \ No newline at end of file + AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) diff --git a/CHPA/02 tmp_ims_td_prod_tmp.sql b/CHPA/02 tmp_ims_td_prod_tmp.sql index 43a24b6..f05c5e3 100644 --- a/CHPA/02 tmp_ims_td_prod_tmp.sql +++ b/CHPA/02 tmp_ims_td_prod_tmp.sql @@ -1,7 +1,6 @@ -- Databricks notebook source -- DBTITLE 1,产品挂中文名 - --Product中文名字,若有超过5个CORP或者MANU生产，则将其报告上排序的优先级调低 insert overwrite table tmp.tmp_ims_td_prod_tmp SELECT DISTINCT PROD.PROD_COD @@ -29,4 +28,4 @@ SELECT DISTINCT PROD.PROD_COD UPDATE dws.dws_ims_td_prod_cn SET RANK_TYPE = 0 where PROD_COD in ( SELECT DISTINCT PROD_COD FROM tmp.tmp_ims_td_prod_tmp - ); \ No newline at end of file + ); diff --git a/EC/03 ec_load_data.ipynb b/EC/03 ec_load_data.ipynb index 9ce790a..d435a7e 100644 --- a/EC/03 ec_load_data.ipynb +++ b/EC/03 ec_load_data.ipynb @@ -9,12 +9,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778478974793, + "finishTime": 1778669598531, "inputWidgets": {}, "nuid": "86f0c1e4-9672-4b69-b7d7-e972573aa69d", "showTitle": false, - "startTime": 1778478973655, - "submitTime": 1778478972034, + "startTime": 1778669598528, + "submitTime": 1778669597681, "tableResultSettingsMap": {}, "title": "" } @@ -38,12 +38,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778478975285, + "finishTime": 1778669598678, "inputWidgets": {}, "nuid": "f319d145-a050-425c-b86f-c73d2e6f41ad", "showTitle": false, - "startTime": 1778478974798, - "submitTime": 1778478972040, + "startTime": 1778669598536, + "submitTime": 1778669597686, "tableResultSettingsMap": {}, "title": "" } @@ -89,12 +89,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778478991545, + "finishTime": 1778669612999, "inputWidgets": {}, "nuid": "a11838c0-855f-4fe6-95d7-790959cb6739", "showTitle": false, - "startTime": 1778478975290, - "submitTime": 1778478972044, + "startTime": 1778669598682, + "submitTime": 1778669597690, "tableResultSettingsMap": {}, "title": "" } @@ -477,12 +477,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778655803909, + "finishTime": 1778669615065, "inputWidgets": {}, "nuid": "85453796-9385-4a5a-bf20-6bfd459580ae", "showTitle": false, - "startTime": 1778655745740, - "submitTime": 1778655744617, + "startTime": 1778669613004, + "submitTime": 1778669597696, "tableResultSettingsMap": {}, "title": "" } @@ -494,7 +494,7 @@ "select\n", "iqvia_lineno,iqvia_pack_code,prod_cod,iqvia_notes,new_pack_flag,is_exists_chpa,product_id,prescription_nature,medicine_type,zk_medicine_tier1,zk_medicine_tier2,zk_medicine_tier3,zk_medicine_tier4,common_name,dosage_form,user_type,category_name,product_name,brand_name,zk_manu_des,zk_corp_des,zk_pack_des,counting_unit_a,dosage_unit_a,unit_a,app1_cod,app1_des,app1_des_c,app2_cod,app2_des,app2_des_c,app3_cod,app3_des,app3_des_c,atc1_cod,atc1_des,atc1_des_c,atc2_cod,atc2_des,atc2_des_c,atc3_cod,atc3_des,atc3_des_c,atc4_cod,atc4_des,atc4_des_c,bio_desc,cmps_cod,cmps_des,cmps_des_c,corp_cod,corp_des,corp_des_c,edl_desc,eth_otc_desc,gene_orig_desc,gqce_desc,manu_cod,manu_des,manu_des_c,mnfl_cod,mnfl_des,nrdl_desc,pack_des,stgh_des,pack_lch,paed_desc,prod_des,prod_des_c,tcm_desc,vbp_desc,unit,counting_unit,dosage_unit,NRDL_ENTRY_DATE,t2.Market,t2.bu,nvl(t2.extend_market_ratio,1) as extend_market_ratio,is_az\n", "from tmp.tmp_ec_temp_market t1\n", - "left join (select Market,BU,Extend_Market,MAX(Extend_Market_Ratio) from DWD.dwd_gnd_ec_tblmarket_bymonth where Extend_Market is not null group by 1,2)t2\n", + "left join (select Market,BU,Extend_Market,MAX(Extend_Market_Ratio) as Extend_Market_Ratio from DWD.dwd_gnd_ec_tblmarket_bymonth where Extend_Market is not null group by 1,2,3)t2\n", "on t1.Market = t2.Extend_Market\n", "where t2.Market is not null" ] @@ -508,12 +508,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778479009600, + "finishTime": 1778669628644, "inputWidgets": {}, "nuid": "015ef590-887b-4dfa-bfa1-ebd05effc2cf", "showTitle": false, - "startTime": 1778478993870, - "submitTime": 1778478972058, + "startTime": 1778669615070, + "submitTime": 1778669597701, "tableResultSettingsMap": {}, "title": "" } @@ -553,12 +553,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557198314, + "finishTime": 1778669638691, "inputWidgets": {}, "nuid": "339d06b1-1c67-4249-a105-aaafb352bb38", "showTitle": false, - "startTime": 1778557189165, - "submitTime": 1778557188224, + "startTime": 1778669628648, + "submitTime": 1778669597706, "tableResultSettingsMap": {}, "title": "" } @@ -589,12 +589,12 @@ "rowLimit": 10000 }, "collapsed": true, - "finishTime": 1778557198321, + "finishTime": 1778669638698, "inputWidgets": {}, "nuid": "c686ec31-8c18-4a4a-96ca-ce5a29f2f676", "showTitle": false, - "startTime": 1778557198319, - "submitTime": 1778557188234, + "startTime": 1778669638695, + "submitTime": 1778669597711, "tableResultSettingsMap": {}, "title": "" } @@ -643,12 +643,12 @@ "rowLimit": 10000 }, "collapsed": true, - "finishTime": 1778557198329, + "finishTime": 1778669638704, "inputWidgets": {}, "nuid": "7814d185-5883-4f00-b350-0d5cab1da7f5", "showTitle": false, - "startTime": 1778557198326, - "submitTime": 1778557188239, + "startTime": 1778669638701, + "submitTime": 1778669597717, "tableResultSettingsMap": {}, "title": "" } @@ -694,12 +694,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557203672, + "finishTime": 1778669642980, "inputWidgets": {}, "nuid": "b576e313-2815-4991-a92e-82fe68cbaed9", "showTitle": false, - "startTime": 1778557198332, - "submitTime": 1778557188244, + "startTime": 1778669638708, + "submitTime": 1778669597721, "tableResultSettingsMap": {}, "title": "" } @@ -738,12 +738,12 @@ "rowLimit": 10000 }, "collapsed": true, - "finishTime": 1778557203681, + "finishTime": 1778669642990, "inputWidgets": {}, "nuid": "5fdbf78f-228d-4e26-94b8-94565feb2ddf", "showTitle": false, - "startTime": 1778557203677, - "submitTime": 1778557188250, + "startTime": 1778669642985, + "submitTime": 1778669597728, "tableResultSettingsMap": {}, "title": "" } @@ -930,12 +930,12 @@ "rowLimit": 10000 }, "collapsed": true, - "finishTime": 1778557203688, + "finishTime": 1778669642998, "inputWidgets": {}, "nuid": "b1f69228-3a47-4a76-ab21-a10e52305a56", "showTitle": false, - "startTime": 1778557203685, - "submitTime": 1778557188256, + "startTime": 1778669642994, + "submitTime": 1778669597734, "tableResultSettingsMap": {}, "title": "" } @@ -1054,12 +1054,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557219728, + "finishTime": 1778669657466, "inputWidgets": {}, "nuid": "2c5737c9-b8fe-4b8a-a4b6-f39be69af55c", "showTitle": false, - "startTime": 1778557203693, - "submitTime": 1778557188260, + "startTime": 1778669643001, + "submitTime": 1778669597739, "tableResultSettingsMap": {}, "title": "" } @@ -1221,12 +1221,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557241785, + "finishTime": 1778669677566, "inputWidgets": {}, "nuid": "9b43d6a9-6fd4-4568-bc48-7d7cb7ffe266", "showTitle": false, - "startTime": 1778557219733, - "submitTime": 1778557188268, + "startTime": 1778669657471, + "submitTime": 1778669597744, "tableResultSettingsMap": {}, "title": "" } @@ -1317,12 +1317,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557246541, + "finishTime": 1778669682213, "inputWidgets": {}, "nuid": "ebb41c4f-a6d7-4dbd-bdb1-304f0c5abae4", "showTitle": false, - "startTime": 1778557241789, - "submitTime": 1778557188277, + "startTime": 1778669677570, + "submitTime": 1778669597750, "tableResultSettingsMap": {}, "title": "" } @@ -1430,12 +1430,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557250987, + "finishTime": 1778669686953, "inputWidgets": {}, "nuid": "25bd255c-597c-4bb0-9c7a-0577e28eefee", "showTitle": false, - "startTime": 1778557246546, - "submitTime": 1778557188283, + "startTime": 1778669682218, + "submitTime": 1778669597756, "tableResultSettingsMap": {}, "title": "" } @@ -1543,12 +1543,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557268253, + "finishTime": 1778669699382, "inputWidgets": {}, "nuid": "d13a4ab2-9a37-4ac4-a886-3cf57cc9d41a", "showTitle": false, - "startTime": 1778557250991, - "submitTime": 1778557188292, + "startTime": 1778669686957, + "submitTime": 1778669597761, "tableResultSettingsMap": {}, "title": "" } @@ -1695,12 +1695,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557271279, + "finishTime": 1778669702234, "inputWidgets": {}, "nuid": "8c861c10-773a-4449-a5dc-c0340e5ec97e", "showTitle": false, - "startTime": 1778557268257, - "submitTime": 1778557188299, + "startTime": 1778669699387, + "submitTime": 1778669597766, "tableResultSettingsMap": {}, "title": "" } @@ -1722,12 +1722,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557275535, + "finishTime": 1778669705886, "inputWidgets": {}, "nuid": "e39d8c66-7469-46db-a2f4-79976266bec2", "showTitle": false, - "startTime": 1778557271284, - "submitTime": 1778557188306, + "startTime": 1778669702239, + "submitTime": 1778669597770, "tableResultSettingsMap": {}, "title": "" } @@ -1789,12 +1789,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557278550, + "finishTime": 1778669709326, "inputWidgets": {}, "nuid": "bbe40a04-e787-4133-9901-5f331baf912a", "showTitle": false, - "startTime": 1778557275539, - "submitTime": 1778557188311, + "startTime": 1778669705892, + "submitTime": 1778669597775, "tableResultSettingsMap": {}, "title": "" } @@ -1820,12 +1820,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557278560, + "finishTime": 1778669709335, "inputWidgets": {}, "nuid": "f8d0befe-3de4-48a8-ac53-cdc19c897d0f", "showTitle": false, - "startTime": 1778557278555, - "submitTime": 1778557188317, + "startTime": 1778669709331, + "submitTime": 1778669597779, "tableResultSettingsMap": {}, "title": "" } @@ -2075,12 +2075,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557283201, + "finishTime": 1778669714239, "inputWidgets": {}, "nuid": "9e6100db-d97c-41a6-8b30-4f7a774c1903", "showTitle": false, - "startTime": 1778557278565, - "submitTime": 1778557188322, + "startTime": 1778669709339, + "submitTime": 1778669597785, "tableResultSettingsMap": {}, "title": "" } @@ -2267,12 +2267,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557285684, + "finishTime": 1778669717268, "inputWidgets": {}, "nuid": "0c0fe2ec-f80e-4872-85bf-fd5d058cc8b8", "showTitle": false, - "startTime": 1778557283205, - "submitTime": 1778557188328, + "startTime": 1778669714244, + "submitTime": 1778669597790, "tableResultSettingsMap": {}, "title": "" } @@ -2336,7 +2336,10 @@ "cell_type": "markdown", "metadata": { "application/vnd.databricks.v1+cell": { - "cellMetadata": {}, + "cellMetadata": { + "byteLimit": 2048000, + "rowLimit": 10000 + }, "inputWidgets": {}, "nuid": "dc2bbed1-223b-4610-a55f-334e63050e68", "showTitle": false, @@ -2357,12 +2360,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557292166, + "finishTime": 1778669722350, "inputWidgets": {}, "nuid": "6b591466-5af8-40ef-a9b9-c4f137843f18", "showTitle": false, - "startTime": 1778557285688, - "submitTime": 1778557188343, + "startTime": 1778669717272, + "submitTime": 1778669597803, "tableResultSettingsMap": {}, "title": "" } @@ -2470,12 +2473,12 @@ "byteLimit": 2048000, "rowLimit": 10000 }, - "finishTime": 1778557292715, + "finishTime": 1778669722953, "inputWidgets": {}, "nuid": "20f3c0a6-f626-4e64-bce4-7653087adb16", "showTitle": false, - "startTime": 1778557292171, - "submitTime": 1778557188353, + "startTime": 1778669722354, + "submitTime": 1778669597808, "tableResultSettingsMap": {}, "title": "" } diff --git a/EC/1 (ec)blob_to_dwd.sql b/EC/1 (ec)blob_to_dwd.sql index 4e9708f..0a8fe4b 100644 --- a/EC/1 (ec)blob_to_dwd.sql +++ b/EC/1 (ec)blob_to_dwd.sql @@ -15,9 +15,9 @@ -- MAGIC ) -- MAGIC # 基础路径 -- MAGIC # 测试环境 --- MAGIC base_path_0 = f"abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/ODS/GND/UserUpload/" +-- MAGIC # base_path_0 = f"abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/ODS/GND/UserUpload/" -- MAGIC # 生产环境 --- MAGIC # base_path_0 = f"abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/ODS/GND/UserUpload/" +-- MAGIC base_path_0 = f"abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/ODS/GND/UserUpload/" -- MAGIC base_path = base_path_0 + today_path -- MAGIC print(base_path) -- MAGIC @@ -100,4 +100,4 @@ -- MAGIC else: -- MAGIC print("未找到批次或路径不存在。") -- MAGIC --- MAGIC \ No newline at end of file +-- MAGIC diff --git a/Retail/18 DM_TD_EXT_DTP_MARKET_RATIO.sql b/Retail/18 DM_TD_EXT_DTP_MARKET_RATIO.sql index 9aadbf4..41d36ee 100644 --- a/Retail/18 DM_TD_EXT_DTP_MARKET_RATIO.sql +++ b/Retail/18 DM_TD_EXT_DTP_MARKET_RATIO.sql @@ -9,9 +9,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_ratio'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_ratio'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_ratio'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_ratio'; -- COMMAND ---------- @@ -27,4 +27,4 @@ SELECT FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_INSERT_DT, FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_UPDATE_DT FROM DM.DM_TD_EXT_DTP_PACK2MARKET -WHERE UPPER(MARKET) NOT LIKE '%ALL%' \ No newline at end of file +WHERE UPPER(MARKET) NOT LIKE '%ALL%' diff --git a/Retail/19 DM_TD_EXT_DTP_MARKET_BRAND_RATIO.sql b/Retail/19 DM_TD_EXT_DTP_MARKET_BRAND_RATIO.sql index 5a192b3..d98ba47 100644 --- a/Retail/19 DM_TD_EXT_DTP_MARKET_BRAND_RATIO.sql +++ b/Retail/19 DM_TD_EXT_DTP_MARKET_BRAND_RATIO.sql @@ -17,9 +17,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_brand_ratio'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_brand_ratio'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_brand_ratio'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_brand_ratio'; -- COMMAND ---------- @@ -157,4 +157,4 @@ LEFT JOIN ( --COUNTINGUNIT--MOLECULE FROM DWD.dwd_gnd_ims_tblbrandratio WHERE UPPER(TYPE) = 'COUNTINGUNIT' AND UPPER(LEVEL) = 'MOLECULE' ) T7 ON T1.MARKET = T7.MARKET -AND T1.CMPS_CODE = T7.CMPS_COD \ No newline at end of file +AND T1.CMPS_CODE = T7.CMPS_COD diff --git a/Retail/20 DM_TD_EXT_DTP_MARKET_PACK_MAPPING.sql b/Retail/20 DM_TD_EXT_DTP_MARKET_PACK_MAPPING.sql index 824fd4c..f5cf33a 100644 --- a/Retail/20 DM_TD_EXT_DTP_MARKET_PACK_MAPPING.sql +++ b/Retail/20 DM_TD_EXT_DTP_MARKET_PACK_MAPPING.sql @@ -24,9 +24,9 @@ -- ETL_UPDATE_DT TIMESTAMP -- ) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_pack_mapping'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_pack_mapping'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_pack_mapping'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_dtp_market_pack_mapping'; -- COMMAND ---------- @@ -85,4 +85,4 @@ SELECT PDOT_BRAND_END, FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_INSERT_DT, FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_UPDATE_DT -FROM DTP_MARKET_PACK_MAPPING \ No newline at end of file +FROM DTP_MARKET_PACK_MAPPING diff --git a/THC/06 DM_TD_EXT_THC_PACK2MARKET.sql b/THC/06 DM_TD_EXT_THC_PACK2MARKET.sql index 452a49b..6e54622 100644 --- a/THC/06 DM_TD_EXT_THC_PACK2MARKET.sql +++ b/THC/06 DM_TD_EXT_THC_PACK2MARKET.sql @@ -39,9 +39,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; -- COMMAND ---------- @@ -50,9 +50,9 @@ -- MARKET STRING, -- PACK_CODE STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_keycompetitor'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_keycompetitor'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_keycompetitor'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_keycompetitor'; -- COMMAND ---------- @@ -61,9 +61,9 @@ -- PACK_CODE STRING, -- CLASS STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_class'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_class'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_class'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market_class'; -- COMMAND ---------- @@ -323,4 +323,4 @@ LEFT JOIN DWD.DWD_GND_TBLCLASS T2 AND (T2.NFC1_CODE IS NULL OR T1.APP1_CODE = T2.NFC1_CODE) AND (T2.NFC2_CODE IS NULL OR T1.APP2_CODE = T2.NFC2_CODE) AND (T2.NFC3_CODE IS NULL OR T1.APP3_CODE = T2.NFC3_CODE) - AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) \ No newline at end of file + AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) diff --git a/UNIONALL/DM_TF_EXT_RETAIL_MARKET_SALES_NIAD.sql b/UNIONALL/DM_TF_EXT_RETAIL_MARKET_SALES_NIAD.sql index b4a38a4..b91146f 100644 --- a/UNIONALL/DM_TF_EXT_RETAIL_MARKET_SALES_NIAD.sql +++ b/UNIONALL/DM_TF_EXT_RETAIL_MARKET_SALES_NIAD.sql @@ -43,9 +43,9 @@ -- ) -- USING delta -- PARTITIONED BY (DATA_SOURCE) --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_market_sales'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_market_sales'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_market_sales'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_market_sales'; -- COMMAND ---------- diff --git a/UNIONALL/DM_TF_EXT_UNIONALL_MARKET_SALES.sql b/UNIONALL/DM_TF_EXT_UNIONALL_MARKET_SALES.sql index 7109188..a1c6b80 100644 --- a/UNIONALL/DM_TF_EXT_UNIONALL_MARKET_SALES.sql +++ b/UNIONALL/DM_TF_EXT_UNIONALL_MARKET_SALES.sql @@ -44,9 +44,9 @@ -- ) -- USING delta -- PARTITIONED BY (DATA_SOURCE) --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; -- COMMAND ---------- diff --git a/UNIONALL/DM_TF_EXT_UNIONALL_SALES.sql b/UNIONALL/DM_TF_EXT_UNIONALL_SALES.sql index d8a0317..055a22d 100644 --- a/UNIONALL/DM_TF_EXT_UNIONALL_SALES.sql +++ b/UNIONALL/DM_TF_EXT_UNIONALL_SALES.sql @@ -32,9 +32,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; -- COMMAND ---------- diff --git a/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql b/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql index d9ff07b..761a644 100644 --- a/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql +++ b/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING.sql @@ -51,9 +51,9 @@ -- -- ETL_UPDATE_DT TIMESTAMP -- ) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; -- COMMAND ---------- @@ -341,9 +341,6 @@ WHERE -- COMMAND ---------- create or replace table tmp.tmp_tf_ext_aia_target_inst --- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/TMP/tmp_tf_ext_aia_target_inst'; --- 上面是生产环境location，下面是测试环境location -LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/TMP/tmp_tf_ext_aia_target_inst' as select distinct MARKET, diff --git a/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING_NIAD.sql b/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING_NIAD.sql index 7e0a145..930029e 100644 --- a/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING_NIAD.sql +++ b/UNIONALL/DM_TF_EXT_UNIONALL_SALES_MAPPING_NIAD.sql @@ -32,9 +32,9 @@ -- DIGITAL_SPREAD_RATE STRING, -- WEIGHTED_SPREAD_RATE STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping_niad'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping_niad'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping_niad'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping_niad'; -- COMMAND ---------- diff --git a/XIEHE/07 DM_TD_EXT_XIEHE_PACK_PROPERTY.sql b/XIEHE/07 DM_TD_EXT_XIEHE_PACK_PROPERTY.sql index 44f423d..490bd6b 100644 --- a/XIEHE/07 DM_TD_EXT_XIEHE_PACK_PROPERTY.sql +++ b/XIEHE/07 DM_TD_EXT_XIEHE_PACK_PROPERTY.sql @@ -69,9 +69,9 @@ -- ETL_UPDATE_DT TIMESTAMP -- ) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; -- COMMAND ---------- @@ -143,4 +143,4 @@ SELECT NULL AS REPLENISH_FALG, FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_INSERT_DT, FROM_UTC_TIMESTAMP(CURRENT_TIMESTAMP(),'UTC+8') AS ETL_UPDATE_DT -FROM DM.DM_XIEHE_PACK_PROPERTY; \ No newline at end of file +FROM DM.DM_XIEHE_PACK_PROPERTY; diff --git a/XIEHE/08 DM_TD_EXT_XIEHE_PACK2MARKET.sql b/XIEHE/08 DM_TD_EXT_XIEHE_PACK2MARKET.sql index 0a83f6e..70288f0 100644 --- a/XIEHE/08 DM_TD_EXT_XIEHE_PACK2MARKET.sql +++ b/XIEHE/08 DM_TD_EXT_XIEHE_PACK2MARKET.sql @@ -39,9 +39,9 @@ -- ETL_INSERT_DT TIMESTAMP, -- ETL_UPDATE_DT TIMESTAMP) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; -- COMMAND ---------- @@ -50,9 +50,9 @@ -- MARKET STRING, -- PACK_CODE STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_keycompetitor'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_keycompetitor'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_keycompetitor'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_keycompetitor'; -- COMMAND ---------- @@ -61,9 +61,9 @@ -- PACK_CODE STRING, -- CLASS STRING) -- USING delta --- -- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_class'; +-- LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_class'; -- -- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_class'; +-- -- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market_class'; -- COMMAND ---------- @@ -323,4 +323,4 @@ LEFT JOIN DWD.DWD_GND_TBLCLASS T2 AND (T2.NFC1_CODE IS NULL OR T1.APP1_CODE = T2.NFC1_CODE) AND (T2.NFC2_CODE IS NULL OR T1.APP2_CODE = T2.NFC2_CODE) AND (T2.NFC3_CODE IS NULL OR T1.APP3_CODE = T2.NFC3_CODE) - AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) \ No newline at end of file + AND (T2.STRENGTH IS NULL OR T1.STGH_DESC = T2.STRENGTH) diff --git a/上线脚本.sql b/上线脚本.sql deleted file mode 100644 index b1661ed..0000000 --- a/上线脚本.sql +++ /dev/null @@ -1,2461 +0,0 @@ --- Databricks notebook source --- MAGIC %md --- MAGIC # AIA - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_AIA_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_AIA_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP - ) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_aia_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_aia_sales'; - - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_AIA_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_AIA_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_AIA_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_AIA_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_aia_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC #CHC - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHC_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack_property'; - - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_CHC_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_chc_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_chc_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHC_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHC_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHC_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHC_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chc_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC #CHPA - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHPA_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_CHPA_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_chpa_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_chpa_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHPA_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHPA_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHPA_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_CHPA_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_chpa_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC # COUNTY - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_COUNTY_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_pack_property'; - - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_COUNTY_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_county_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_county_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET --- 建表SQL -CREATE OR REPLACE TABLE DM.DM_TD_EXT_COUNTY_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_COUNTY_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_COUNTY_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_COUNTY_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_county_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC # EC - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_EC_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_EC_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_ec_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_ec_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_EC_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_EC_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_EC_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_EC_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_ec_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC #RETAIL - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_PACK_PROPERTY - ( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,PACK_DTP -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_DTP_PACK_PROPERTY - ( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_dtp_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_dtp_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_RETAIL_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_sales'; - --- COMMAND ---------- - --- DBTITLE 1,SALES_DTP -CREATE OR REPLACE TABLE DM.DM_TF_EXT_RETAIL_DTP_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_dtp_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_retail_dtp_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_RETAIL_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_retail_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC # THC - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_THC_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_THC_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_thc_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_thc_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_THC_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_THC_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_THC_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_THC_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_thc_market_pack_mapping'; - --- COMMAND ---------- - --- DBTITLE 1,DM_TF_EXT_THC_MARKET_SALES_CHT -CREATE OR REPLACE TABLE DM.DM_TF_EXT_THC_MARKET_SALES_CHT ( - MARKET STRING, - KEY_COMPETITOR STRING, - CLASS STRING, - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - DATA_SOURCE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - CMPS_FLAG STRING COMMENT '分子式标签', - NEW_CODE STRING COMMENT '主数据关联CODE', - INST_CODE STRING COMMENT '内部机构编码', - AIA_HP_FLAG STRING, - DEPT_NAME STRING COMMENT '科室名称', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_TYPE STRING COMMENT '处方来源', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - VA DOUBLE, - UT DOUBLE, - CU DOUBLE, - PT DOUBLE, - SALES_UNIT_CAL DECIMAL(35,6), - SALES_UNIT_CAL_LY DECIMAL(35,6), - SALES_VALUE_CAL DECIMAL(35,6), - SALES_VALUE_CAL_LY DECIMAL(35,6), - CONUTING_UNIT DECIMAL(35,6), - CONUTING_UNIT_LY DECIMAL(35,6), - PDOT DECIMAL(35,6), - PDOT_LY DECIMAL(35,6), - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_thc_market_sales_cht'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_thc_market_sales_cht'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC #XIEHE - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_XIEHE_PACK_PROPERTY -( - MARKET_PACK_KEY STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - FAMILY_CODE STRING, - FAMILY_NAME STRING, - PROD_CODE STRING, - PROD_DESC STRING, - PROD_DESC_C STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - CMPS_DESC_C STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC_V STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MANU_DESC_C STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - CORP_DESC_C STRING, - BRANDTYPE STRING, - MARKET STRING, - KEY_COMPETITOR STRING, - IS_AZ STRING, - AZ_MAIN STRING, - AZ_RELATED STRING, - ATC1_DESC STRING, - ATC1_DESC_C STRING, - ATC2_DESC STRING, - ATC2_DESC_C STRING, - ATC3_DESC STRING, - ATC3_DESC_C STRING, - ATC4_DESC STRING, - ATC4_DESC_C STRING, - APP1_DESC STRING, - APP1_DESC_C STRING, - APP2_DESC STRING, - APP2_DESC_C STRING, - APP3_DESC STRING, - APP3_DESC_C STRING, - CLASS STRING, - MARKET_RATIO STRING, - COUNTINGUNIT STRING, - VBP_BRAND STRING, - REPLENISH_FALG STRING, - ETL_INSERT_DT STRING, - ETL_UPDATE_DT STRING -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack_property'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_XIEHE_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_xiehe_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_xiehe_sales'; - --- COMMAND ---------- - --- DBTITLE 1,PACK2MARKET -CREATE OR REPLACE TABLE DM.DM_TD_EXT_XIEHE_PACK2MARKET ( - MARKET STRING, - PACK_CODE STRING, - PACK_DESC STRING, - STGH_DESC STRING, - PACK_LCH STRING, - PROD_CODE STRING, - CMPS_CODE STRING, - CMPS_DESC STRING, - ATC1_CODE STRING, - ATC2_CODE STRING, - ATC3_CODE STRING, - ATC4_CODE STRING, - APP1_CODE STRING, - APP2_CODE STRING, - APP3_CODE STRING, - BIO_DESC STRING, - GENE_ORIG_DESC STRING, - ETH_OTC_DESC STRING, - NRDL_DESC STRING, - NRDL_ENTRY_DATE STRING, - EDL_DESC STRING, - TCM_DESC STRING, - PAED_DESC STRING, - GQCE_DESC STRING, - VBP_DESC STRING, - MANU_CODE STRING, - MANU_DESC STRING, - MNFL_CODE STRING, - MNFL_DESC STRING, - CORP_CODE STRING, - CORP_DESC STRING, - BRANDTYPE STRING, - BU STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_pack2market'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_XIEHE_MARKET_RATIO ( - MARKET STRING, - PACK_CODE STRING, - CMPS_CODE STRING, - STARTTIME STRING, - ENDTIME STRING, - MARKET_RATIO STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_BRAND_RATIO -CREATE OR REPLACE TABLE DM.DM_TD_EXT_XIEHE_MARKET_BRAND_RATIO ( - MARKET STRING, - PACK_CODE STRING, - VALUE_BRAND_RATIO FLOAT, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO FLOAT, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO FLOAT, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO FLOAT, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_brand_ratio'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_brand_ratio'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_XIEHE_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_xiehe_market_pack_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC #UNIONALL - --- COMMAND ---------- - --- DBTITLE 1,PACK -CREATE OR REPLACE TABLE DM.DM_TD_EXT_UNIONALL_PACKINFO ( - PACK_CODE STRING COMMENT '包装编码', - PACK_DESC STRING COMMENT '包装描述', - PACK_LCH STRING COMMENT '包装上市时间，示例"Y2024M05"', - PROD_CODE STRING COMMENT '产品编码', - PROD_DESC STRING COMMENT '产品描述', - PROD_DESC_C STRING COMMENT '产品中文描述', - CMPS_CODE STRING COMMENT '成分代码', - CMPS_DESC STRING COMMENT '成分描述', - CMPS_DESC_C STRING COMMENT '成分中文描述', - VBP_BATCH STRING COMMENT '带量采购批次号', - VBP_IMPLEMENTING_TIME STRING COMMENT '带量采购实施时间', - STGH_DESC STRING COMMENT '储存方式描述', - BIO_DESC STRING COMMENT '生物制药描述', - ETH_OTC_DESC STRING COMMENT '处方/非处方药描述', - NRDL_DESC STRING COMMENT '国家医保目录状态描述', - NRDL_ENTRY_DATE STRING COMMENT '国家医保目录纳入日期', - EDL_DESC STRING COMMENT '基本药物目录状态描述', - TCM_DESC STRING COMMENT '中医药分类描述', - PAED_DESC STRING COMMENT '儿童用药标志描述', - GQCE_DESC STRING COMMENT '绿色/质量/认证/应急标志描述', - MANU_CODE STRING COMMENT '生产企业编码', - MANU_DESC STRING COMMENT '生产企业名称描述', - MANU_DESC_C STRING COMMENT '生产企业名称中文描述', - MNFL_CODE STRING COMMENT '跨国/本地企业标志编码', - ATC1_CODE STRING COMMENT '解剖学治疗学化学分类1编码', - ATC1_DESC STRING COMMENT '解剖学治疗学化学分类1描述', - ATC1_DESC_C STRING COMMENT '解剖学治疗学化学分类1中文描述', - ATC2_CODE STRING COMMENT '解剖学治疗学化学分类2编码', - ATC2_DESC STRING COMMENT '解剖学治疗学化学分类2描述', - ATC2_DESC_C STRING COMMENT '解剖学治疗学化学分类2中文描述', - ATC3_CODE STRING COMMENT '解剖学治疗学化学分类3编码', - ATC3_DESC STRING COMMENT '解剖学治疗学化学分类3描述', - ATC3_DESC_C STRING COMMENT '解剖学治疗学化学分类3中文描述', - ATC4_CODE STRING COMMENT '解剖学治疗学化学分类4编码', - ATC4_DESC STRING COMMENT '解剖学治疗学化学分类4描述', - ATC4_DESC_C STRING COMMENT '解剖学治疗学化学分类4中文描述', - APP1_CODE STRING COMMENT '审批/申请分类(3个层级)', - APP1_DESC STRING COMMENT '', - APP1_DESC_C STRING COMMENT '', - APP2_CODE STRING COMMENT '', - APP2_DESC STRING COMMENT '', - APP2_DESC_C STRING COMMENT '', - APP3_CODE STRING COMMENT '', - APP3_DESC STRING COMMENT '', - APP3_DESC_C STRING COMMENT '', - GENE_ORIG_DESC STRING COMMENT '原研/仿制/中药药物来源描述', - VBP_DESC STRING COMMENT '带量采购状态(VBP-IN/VBP-OUT/Non VBP)描述', - CORP_CODE STRING COMMENT '公司编码', - GEN_RN INT COMMENT '原研/仿制排名(1-5)', - CORP_DESC STRING COMMENT '公司名称描述', - CORP_DESC_C STRING COMMENT '公司名称中文描述', - PACK_RN INT COMMENT '包装排名(按销售量)', - PROD_RN INT COMMENT '产品排名(按销售量)', - CMPS_RN INT COMMENT '成分排名(按销售量)', - DATA_SOURCE STRING COMMENT '数据来源渠道', - ATC STRING COMMENT 'ATC分类代码', - NEW_CODE STRING COMMENT '新编码', - COMMON_NAME STRING COMMENT '通用名称', - PRODUCT_NAME STRING COMMENT '产品名称', - MANU_DES_XIEHE STRING COMMENT '协和渠道生产企业名称', - PACK_DES_XIEHE STRING COMMENT '协和渠道包装描述', - DRUG_DELIVERY_ROUTE STRING COMMENT '给药途径', - NFC STRING COMMENT '国家处方集代码', - CORP_TYPE STRING COMMENT '企业类型(本地/跨国)', - LAUNCHTIME STRING COMMENT '产品上市时间', - VBP_BRAND STRING COMMENT '品牌带量采购状态汇总', - REPLENISH_FALG STRING COMMENT '后续补充标志', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_packinfo'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_packinfo'; - --- COMMAND ---------- - --- DBTITLE 1,SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_UNIONALL_SALES ( - YYYYMM STRING, - PACK_CODE STRING, - CORP_CODE STRING, - AUDIT_CODE STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(38,10), - CONUTING_UNIT_LY DECIMAL(38,10), - DATA_SOURCE STRING, - INST_CODE STRING COMMENT '内部机构编码', - CMPS_FLAG STRING COMMENT '分子式标签', - DEPT_NAME STRING COMMENT '科室名称', - PRESCRIPTION DECIMAL(38,10) COMMENT '处方张数', - PRESCRIPTION_LY DECIMAL(38,10) COMMENT '去年同期处方张数', - NEW_CODE STRING COMMENT '主数据关联CODE', - AREA STRING COMMENT '城市', - H_LEVEL STRING COMMENT '医院类型', - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_SOURCE STRING COMMENT '处方来源', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_PACK_MAPPING -CREATE OR REPLACE TABLE DM.DM_TD_EXT_UNIONALL_MARKET_PACK_MAPPING -( - PACK_CODE STRING, - MARKET STRING, - CLASS STRING, - KEY_COMPETITOR STRING, - MARKET_RATIO STRING, - STARTTIME STRING, - ENDTIME STRING, - VALUE_BRAND_RATIO STRING, - VALUE_BRAND_RATIO_START STRING, - VALUE_BRAND_RATIO_END STRING, - UNIT_BRAND_RATIO STRING, - UNIT_BRAND_START STRING, - UNIT_BRAND_END STRING, - COUNTINGUNIT_BRAND_RATIO STRING, - COUNTINGUNIT_BRAND_START STRING, - COUNTINGUNIT_BRAND_END STRING, - PDOT_BRAND_RATIO STRING, - PDOT_BRAND_START STRING, - PDOT_BRAND_END STRING, - DATASOURCE STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP -) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_pack_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_pack_mapping'; - --- COMMAND ---------- - --- DBTITLE 1,MARKET_SALES -CREATE OR REPLACE TABLE DM.DM_TF_EXT_UNIONALL_MARKET_SALES ( - MARKET STRING, - KEY_COMPETITOR STRING, - CLASS STRING, - YYYYMM STRING, - PACK_COD STRING, - CORP_COD STRING, - AUDIT_COD STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - DATA_SOURCE STRING, - PACK_FLAG STRING, - PROD_FLAG STRING, - DTP_FLAG STRING, - CMPS_FLAG STRING, - NEW_CODE STRING COMMENT '主数据关联CODE', - INST_CODE STRING COMMENT '内部机构编码', - AIA_HP_FLAG STRING, - DEPT_NAME STRING COMMENT '科室名称', - H_LEVEL STRING, - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_TYPE STRING COMMENT '处方来源', - PRESCRIPTION DECIMAL(35,10), - PRESCRIPTION_LY DECIMAL(35,10), - VA STRING, - UT STRING, - CU STRING, - PT STRING, - SALES_UNIT_CAL DECIMAL(35,6), - SALES_UNIT_CAL_LY DECIMAL(35,6), - SALES_VALUE_CAL DECIMAL(35,6), - SALES_VALUE_CAL_LY DECIMAL(35,6), - CONUTING_UNIT DECIMAL(35,6), - CONUTING_UNIT_LY DECIMAL(35,6), - PDOT DECIMAL(35,6), - PDOT_LY DECIMAL(35,6), - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP - ) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_market_sales'; - --- COMMAND ---------- - --- DBTITLE 1,SALES_MAPPING -CREATE OR REPLACE TABLE DM.DM_TF_EXT_UNIONALL_SALES_MAPPING -( - MARKET STRING, - KEY_COMPETITOR STRING, - CLASS STRING, - YYYYMM STRING, - PACK_COD STRING, - CORP_COD STRING, - AUDIT_COD STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - DATA_SOURCE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - CMPS_FLAG INT, - NEW_CODE STRING COMMENT '主数据关联CODE', - INST_CODE STRING COMMENT '内部机构编码', - AIA_HP_FLAG INT, - DEPT_NAME STRING COMMENT '科室名称', - H_LEVEL INT, - REIMBURSE STRING COMMENT '报销情况', - REIMBURSE_TYPE STRING COMMENT '报销类型', - PRESCRIPTION_TYPE STRING COMMENT '处方来源', - VA decimal(35,10), - UT decimal(35,10), - CU decimal(35,10), - PT decimal(35,10), - SALES_UNIT_CAL decimal(35,10), - SALES_UNIT_CAL_LY decimal(35,10), - SALES_VALUE_CAL decimal(35,10), - SALES_VALUE_CAL_LY decimal(35,10), - CONUTING_UNIT decimal(35,10), - CONUTING_UNIT_LY decimal(35,10), - PDOT decimal(35,10), - PDOT_LY decimal(35,10), - PRESCRIPTION INT, - PRESCRIPTION_LY INT, - AIA_REMOVE INT, - MERGEDATA_FLAG STRING, - MERGEDATA_FLAG_MKT STRING, - MERGEDATA_FLAG_CHPA_DTP INT, - MERGEDATA_FLAG_DTP_NOROC INT, - MERGED_DATA_DTP_OTHERS INT, - EGFR_FLAG INT, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_tf_ext_unionall_sales_mapping'; - --- COMMAND ---------- - --- MAGIC %md --- MAGIC # OTHER - --- COMMAND ---------- - --- DBTITLE 1,dm_td_ext_unionall_market -CREATE OR REPLACE TABLE DM.DM_TD_EXT_UNIONALL_MARKET ( - MARKET STRING, - DATA_SOURCE STRING, - TA STRING, - AZ_RELATED STRING, - MARKET_DESC STRING, - TA_RN INT, - PRD_FLAG STRING, - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market'; - --- COMMAND ---------- - --- DBTITLE 1,dm_td_ext_unionall_market_ta -CREATE OR REPLACE TABLE DM.DM_TD_EXT_UNIONALL_MARKET_TA ( - MARKET STRING COMMENT '市场', - DATA_SOURCE STRING COMMENT '数据源', - TA STRING COMMENT '治疗领域', - TA_MAP STRING COMMENT '治疗领域匹配', - TA_RN INT COMMENT '治疗领域排名', - MARKET_DESC STRING COMMENT '市场描述', - ETL_INSERT_DT TIMESTAMP, - ETL_UPDATE_DT TIMESTAMP) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/dm_td_ext_unionall_market_ta'; - --- COMMAND ---------- - --- DBTITLE 1,DM_TF_EXTERANL_SALES_MERGED_DATA_DTP_OTHERS_bymonth -CREATE OR REPLACE TABLE dm.DM_TF_EXTERANL_SALES_MERGED_DATA_DTP_OTHERS_bymonth ( - MARKET STRING, - KEY_COMPETITOR STRING, - CLASS STRING, - YYYYMM STRING, - PACK_COD STRING, - CORP_COD STRING, - AUDIT_COD STRING, - PLATFORM_TYPE STRING, - STORE_NAME STRING, - STORE_TYPE STRING, - REGION_TYPE STRING, - PACK_FLAG INT, - PROD_FLAG INT, - DTP_FLAG INT, - SALES_UNIT_CAL DECIMAL(38,10), - SALES_UNIT_CAL_LY DECIMAL(38,10), - SALES_VALUE_CAL DECIMAL(38,10), - SALES_VALUE_CAL_LY DECIMAL(38,10), - CONUTING_UNIT DECIMAL(21,0), - CONUTING_UNIT_LY DECIMAL(21,0), - PDOT DECIMAL(21,0), - PDOT_LY DECIMAL(21,0), - DATA_SOURCE STRING, - inst_code STRING, - cmps_flag STRING, - dept_name STRING, - prescription STRING, - prescription_ly STRING, - new_code STRING, - area STRING, - h_level STRING, - reimburse STRING, - reimburse_type STRING, - prescription_source STRING) -USING delta -LOCATION 'abfss://master@azcdatalakeprd.dfs.core.chinacloudapi.cn/DM/DM_TF_EXTERANL_SALES_MERGED_DATA_DTP_OTHERS_bymonth'; --- 上面是生产环境location，下面是测试环境location --- LOCATION 'abfss://master@retaildlstoragetest.dfs.core.chinacloudapi.cn/DM/DM_TF_EXTERANL_SALES_MERGED_DATA_DTP_OTHERS_bymonth'; diff --git a/数据验证.sql b/数据验证.sql deleted file mode 100644 index 1752822..0000000 --- a/数据验证.sql +++ /dev/null @@ -1,39 +0,0 @@ --- Databricks notebook source -desc dm.dm_tf_ext_aia_sales - --- COMMAND ---------- - -select DATA_SOURCE,DTP_FLAG from dm.DM_TF_EXTERANL_SALES_MERGED_DATA_DTP_OTHERS_bymonth -group by DATA_SOURCE,DTP_FLAG - --- COMMAND ---------- - -select DTP_FLAG,DATA_SOURCE from DM.DM_TF_EXT_RETAIL_DTP_SALES group by DTP_FLAG,DATA_SOURCE --- order by DATA_SOURCE - --- COMMAND ---------- - -select DATA_SOURCE,DTP_FLAG from DM.DM_TF_EXT_UNIONALL_SALES group by DATA_SOURCE,DTP_FLAG -order by DATA_SOURCE,DTP_FLAG - --- COMMAND ---------- - -select DATA_SOURCE,DTP_FLAG,count(*) from DM.dm_tf_ext_unionall_sales_mapping -group BY DATA_SOURCE,DTP_FLAG -ORDER BY DATA_SOURCE,DTP_FLAG - - --- COMMAND ---------- - -select * from DM.DM_TF_EXT_UNIONALL_SALES_MAPPING -limit 4 - --- COMMAND ---------- - -select AUDIT_CODE from DM.DM_TF_EXT_CHPA_SALES group by AUDIT_CODE --- limit 5 - --- COMMAND ---------- - -select * from DM.DM_TD_EXT_CHPA_PACK2MARKET -limit 5 \ No newline at end of file