????????????????????|insert into dwd_order_detail
|select
| ord.Id,
| ord.Code,
| Status
| concat(cast(ord.Id as String),if(oed.Id is null,'oed_null',cast(oed.Id
as STRING)),DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')) as uuids,
| TO_DATE(DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd')) as As_Of_Date
|from
|orders ord
|left join order_extend oed on ord.Id=oed.OrderId and oed.IsDeleted=0 and
oed.CreateTime>CAST(DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') AS TIMESTAMP)
|where ( ord.OrderTime>CAST(DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') AS
TIMESTAMP)
|or ord.ReviewTime>CAST(DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') AS
TIMESTAMP)
|or ord.RejectTime>CAST(DATE_FORMAT(LOCALTIMESTAMP,'yyyy-MM-dd') AS
TIMESTAMP)
|) and
ord.IsDeleted=0;??????????kafka??canal-json??????join??????upsert-kafka????????????????1.12??????????????????????????1.12??????1.13??????????????????????????????????XJ0120210531004794??canal-json????????????+U????????????|
+U | XJ0120210531004704 | 50 | | +U |
XJ0120210531004788 | 50 | | +U | XJ0120210531004819 |
50 | | +U | XJ0120210531004667 | 50 | | +U |
XJ0120210531004695 | 50 | | +U | XJ0120210531004776 |
50 | | +U | XJ0120210531004784 | 50 | | +U |
XJ0120210531004861 | 50 | | +U | XJ0120210531004794 |
50 | | +U | XJ0120210531004672 | 50 | | +U |
XJ0120210531004766 | 50 | | +U | XJ0120210531004806
| 50 | | +U | XJ0120210531004812 | 50 | | +U |
XJ0120210601000126 | 50 | | +U |
XJ0120210601000179 | 50 | | +U | XJ0120210531004816 |
50 | | +U | XJ0120210601000927 | 50
|??????join????upsert kakfa??????upsert kafka????????????????????| +I |
XJ0120210531004794 | 50 | | -U | XJ0120210531004794 |
50
|????????????????????????????orders??order_extend????????????????????????????-U????????????????????????????????????????????????
