Make debugging statements in SQL files more informative.
I added the CTE's name as the new first column of the `SELECT * FROM <cte>` statement.
This commit is contained in:
parent
cc7726758b
commit
f8f1433546
@ -20,7 +20,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
AND calc_status||flag <> 'CLOSEDREMAINDER' --exclude short ships when building order adjustments
|
||||
AND order_date <= ship_date
|
||||
)
|
||||
-- select * from testv
|
||||
-- select 'testv', * from testv
|
||||
--
|
||||
,flagv AS (
|
||||
SELECT
|
||||
@ -56,7 +56,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
FROM
|
||||
testv
|
||||
)
|
||||
-- select * from flagv
|
||||
-- select 'flagv', * from flagv
|
||||
--
|
||||
,GLD AS MATERIALIZED (
|
||||
SELECT
|
||||
@ -80,7 +80,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
WHERE
|
||||
N1COMP = 93
|
||||
)
|
||||
-- select * from gld
|
||||
-- select 'gld', * from gld
|
||||
--
|
||||
,mseq AS (
|
||||
SELECT * FROM
|
||||
@ -100,7 +100,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
,('12 - May',12,5,0)
|
||||
) x(m,s,cal,yr)
|
||||
)
|
||||
-- select * from mseq
|
||||
-- select 'mseq', * from mseq
|
||||
--
|
||||
,alldates AS MATERIALIZED(
|
||||
SELECT
|
||||
@ -138,7 +138,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
-- HAVING
|
||||
-- sum(CASE (SELECT flagsales FROM flagv) WHEN 'no price'THEN 1.0 ELSE value_usd END) <> 0
|
||||
)
|
||||
-- select * from alldates
|
||||
-- select 'alldates', * from alldates
|
||||
--
|
||||
,dom AS (
|
||||
SELECT
|
||||
@ -149,7 +149,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
GROUP BY
|
||||
extract(day FROM order_date)
|
||||
)
|
||||
-- select * from dom
|
||||
-- select 'dom', * from dom
|
||||
--
|
||||
---------------------may want ot look at a top-5 mix solution in the future facilitated by sum() over (order by sales desc)---------------
|
||||
,mmix AS (
|
||||
@ -170,10 +170,10 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
,seq
|
||||
,promo
|
||||
)
|
||||
-- select * from mmix
|
||||
-- select 'mmix', * from mmix
|
||||
--
|
||||
,targm AS (select s, m from mseq where m = 'target_month' )
|
||||
-- select * from targm
|
||||
-- select 'targm', * from targm
|
||||
--
|
||||
,mmixp AS (
|
||||
SELECT
|
||||
@ -187,7 +187,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
FROM
|
||||
mmix
|
||||
)
|
||||
-- select * from mmixp
|
||||
-- select 'mmixp', * from mmixp
|
||||
--
|
||||
,closest AS (
|
||||
SELECT
|
||||
@ -199,7 +199,7 @@ target AS (select target_volume vincr, target_price pincr)
|
||||
abs(seq - targm.s) ASC
|
||||
LIMIT 1
|
||||
)
|
||||
-- select * from closest
|
||||
-- select 'closest', * from closest
|
||||
--
|
||||
---------------------the role of basemix here is to get non-dated info which is then dated in the next step---------------------
|
||||
,basemix AS (
|
||||
@ -291,7 +291,7 @@ SELECT
|
||||
,o.calc_status
|
||||
,o.flag
|
||||
)
|
||||
-- select * from basemix
|
||||
-- select 'basemix', * from basemix
|
||||
--
|
||||
,vscale AS (
|
||||
SELECT
|
||||
@ -311,12 +311,12 @@ SELECT
|
||||
ELSE 0
|
||||
END AS mod_volume
|
||||
)
|
||||
-- select * from vscale
|
||||
-- select 'vscale', * from vscale
|
||||
--
|
||||
,log AS (
|
||||
INSERT INTO rlarp.osm_log(doc) SELECT $$replace_iterdef$$::jsonb doc RETURNING *
|
||||
)
|
||||
-- select * from log
|
||||
-- select 'log', * from log
|
||||
--
|
||||
,volume AS (
|
||||
SELECT
|
||||
@ -394,7 +394,7 @@ FROM
|
||||
WHERE
|
||||
m._month = (SELECT _month FROM closest)
|
||||
)
|
||||
-- select * from volume
|
||||
-- select 'volume', * from volume
|
||||
--
|
||||
,pscale AS (
|
||||
SELECT
|
||||
@ -412,7 +412,7 @@ WHERE
|
||||
(SELECT pincr::numeric FROM target) / (SELECT nullif(sum(value_loc * r_rate),0) FROM volume)
|
||||
END factor
|
||||
)
|
||||
-- select * from pscale
|
||||
-- select 'pscale', * from pscale
|
||||
--
|
||||
,price AS (
|
||||
SELECT
|
||||
@ -483,7 +483,7 @@ FROM
|
||||
WHERE
|
||||
p.factor <> 0
|
||||
)
|
||||
-- SELECT * FROM price UNION ALL SELECT * FROM volume
|
||||
-- select 'price', * from price UNION ALL SELECT 'volume', * FROM volume
|
||||
--
|
||||
, ins AS (
|
||||
INSERT INTO rlarp.osm_pool (SELECT * FROM price UNION ALL SELECT * FROM volume) RETURNING *
|
||||
@ -571,4 +571,6 @@ FROM
|
||||
,tag
|
||||
,comment
|
||||
)
|
||||
-- select 'insagg', * from insagg
|
||||
--
|
||||
SELECT json_agg(row_to_json(insagg)) x from insagg
|
||||
|
||||
@ -3,7 +3,7 @@ WITH
|
||||
the volume must be expressed in terms of units, since that is what it will be scaling
|
||||
*/
|
||||
target AS (select $$replace_request$$::json def)
|
||||
-- select * from target
|
||||
-- select 'target', * from target
|
||||
--
|
||||
,GLD AS (
|
||||
SELECT
|
||||
@ -29,7 +29,7 @@ target AS (select $$replace_request$$::json def)
|
||||
N1COMP = 93
|
||||
--AND DIGITS(N1FSYP) = '1901'
|
||||
)
|
||||
-- select * from GLD
|
||||
-- select 'GLD', * from GLD
|
||||
--
|
||||
,mseq AS (
|
||||
SELECT * FROM
|
||||
@ -49,7 +49,7 @@ target AS (select $$replace_request$$::json def)
|
||||
,('12 - May',12,5,0)
|
||||
) x(m,s,cal,yr)
|
||||
)
|
||||
-- select * from mseq
|
||||
-- select 'mseq', * from mseq
|
||||
--
|
||||
,seg AS (
|
||||
SELECT
|
||||
@ -75,7 +75,7 @@ target AS (select $$replace_request$$::json def)
|
||||
('9TO','Other')
|
||||
) X(GLEC, SEGM)
|
||||
)
|
||||
-- select * from seg
|
||||
-- select 'seg', * from seg
|
||||
--
|
||||
,copr AS (
|
||||
SELECT
|
||||
@ -97,7 +97,7 @@ target AS (select $$replace_request$$::json def)
|
||||
WHERE
|
||||
A2 = 'AA' OR A2 IS NULL
|
||||
)
|
||||
-- select * from copr
|
||||
-- select 'copr', * from copr
|
||||
--
|
||||
,alldates AS (
|
||||
SELECT
|
||||
@ -133,7 +133,7 @@ target AS (select $$replace_request$$::json def)
|
||||
-- HAVING
|
||||
-- sum(value_usd) <> 0
|
||||
)
|
||||
-- select * from alldates
|
||||
-- select 'alldates', * from alldates
|
||||
--
|
||||
,dom AS (
|
||||
SELECT
|
||||
@ -144,7 +144,7 @@ target AS (select $$replace_request$$::json def)
|
||||
GROUP BY
|
||||
extract(day FROM order_date)
|
||||
)
|
||||
-- select * from dom
|
||||
-- select 'dom', * from dom
|
||||
--
|
||||
,mmix AS (
|
||||
SELECT
|
||||
@ -171,7 +171,7 @@ target AS (select $$replace_request$$::json def)
|
||||
--,request_date-order_date
|
||||
--,ship_date - request_date
|
||||
)
|
||||
-- select * from mmix
|
||||
-- select 'mmix', * from mmix
|
||||
--
|
||||
,targm AS (
|
||||
SELECT
|
||||
@ -187,8 +187,8 @@ target AS (select $$replace_request$$::json def)
|
||||
JOIN LATERAL json_to_record(je.value) as r (amount numeric, qty numeric) ON TRUE
|
||||
LEFT OUTER JOIN mseq ON
|
||||
mseq.m = je.key
|
||||
)
|
||||
--select * from targm
|
||||
|
||||
--select 'targm', * from targm
|
||||
--
|
||||
,mmixp AS (
|
||||
SELECT
|
||||
@ -205,7 +205,7 @@ target AS (select $$replace_request$$::json def)
|
||||
FROM
|
||||
mmix
|
||||
)
|
||||
--select * from mmixp
|
||||
--select 'mmixp', * from mmixp
|
||||
--
|
||||
,mxm AS (
|
||||
SELECT
|
||||
@ -235,7 +235,7 @@ FROM
|
||||
LIMIT 1
|
||||
)
|
||||
)
|
||||
-- SELECT * FROM mxm
|
||||
-- SELECT 'mxm', * FROM mxm
|
||||
--
|
||||
,basemix AS (
|
||||
SELECT
|
||||
@ -272,12 +272,12 @@ SELECT
|
||||
LEFT OUTER JOIN gld sd ON
|
||||
sd.drange @> (make_date(mxm.yr + 2024,mxm.cal,mxm.odom) + rlag + slag)
|
||||
)
|
||||
-- SELECT * FROM basemix
|
||||
-- SELECT 'basemix', * FROM basemix
|
||||
--
|
||||
,log AS (
|
||||
INSERT INTO rlarp.osm_log(doc) SELECT $$replace_iterdef$$::jsonb doc RETURNING *
|
||||
)
|
||||
-- select * from log
|
||||
-- select 'log', * from log
|
||||
--
|
||||
,final AS (
|
||||
SELECT
|
||||
@ -404,7 +404,7 @@ FROM
|
||||
AND rx.fcur = COALESCE(bc.bvcurr,b.r_currency)
|
||||
AND rx.tcur = 'US'
|
||||
)
|
||||
-- select * from final
|
||||
-- select 'final', * from final
|
||||
--
|
||||
, ins AS (
|
||||
INSERT INTO rlarp.osm_pool SELECT * FROM final RETURNING *
|
||||
@ -492,4 +492,6 @@ FROM
|
||||
,tag
|
||||
,comment
|
||||
)
|
||||
-- select 'insagg', * from insagg
|
||||
--
|
||||
SELECT json_agg(row_to_json(insagg)) x from insagg
|
||||
|
||||
@ -98,7 +98,7 @@ target AS (select target_increment incr)
|
||||
,ship_month
|
||||
,ship_season
|
||||
)
|
||||
-- select * from basemix
|
||||
-- select 'basemix', * from basemix
|
||||
--
|
||||
,scale AS (
|
||||
SELECT
|
||||
@ -116,12 +116,12 @@ target AS (select target_increment incr)
|
||||
(SELECT incr::numeric FROM target) / (SELECT nullif(sum(value_loc * r_rate),0) FROM basemix)
|
||||
END factor
|
||||
)
|
||||
-- select * from scale
|
||||
-- select 'scale', * from scale
|
||||
--
|
||||
,log AS (
|
||||
INSERT INTO rlarp.osm_log(doc) SELECT $$replace_iterdef$$::jsonb doc RETURNING *
|
||||
)
|
||||
-- select * from log
|
||||
-- select 'log', * from log
|
||||
--
|
||||
,final AS (
|
||||
SELECT
|
||||
@ -192,7 +192,7 @@ target AS (select target_increment incr)
|
||||
WHERE
|
||||
s.factor <> 0
|
||||
)
|
||||
-- select * from final
|
||||
-- select 'final', * from final
|
||||
--
|
||||
, ins AS (
|
||||
INSERT INTO rlarp.osm_pool SELECT * FROM final RETURNING *
|
||||
@ -280,4 +280,6 @@ target AS (select target_increment incr)
|
||||
,tag
|
||||
,comment
|
||||
)
|
||||
-- select 'insagg', * from insagg
|
||||
--
|
||||
SELECT json_agg(row_to_json(insagg)) x from insagg
|
||||
|
||||
@ -14,7 +14,7 @@ target AS (select incr_qty qincr)
|
||||
AND calc_status||flag <> 'CLOSEDREMAINDER' --exclude short ships when building order adjustments
|
||||
AND order_date <= ship_date
|
||||
)
|
||||
-- select * from testv
|
||||
-- select 'testv', * from testv
|
||||
--
|
||||
,flagv AS (
|
||||
SELECT
|
||||
@ -37,7 +37,7 @@ target AS (select incr_qty qincr)
|
||||
FROM
|
||||
testv
|
||||
)
|
||||
-- select * from flagv
|
||||
-- select 'flagv', * from flagv
|
||||
--
|
||||
,basemix AS (
|
||||
SELECT
|
||||
@ -142,7 +142,7 @@ target AS (select incr_qty qincr)
|
||||
,ship_month
|
||||
,ship_season
|
||||
)
|
||||
-- select * from basemix
|
||||
-- select 'basemix', * from basemix
|
||||
--
|
||||
,scale AS (
|
||||
SELECT
|
||||
@ -162,12 +162,12 @@ target AS (select incr_qty qincr)
|
||||
ELSE 0
|
||||
END AS mod_volume
|
||||
)
|
||||
-- select * from scale
|
||||
-- select 'scale', * from scale
|
||||
--
|
||||
,log AS (
|
||||
INSERT INTO rlarp.osm_log(doc) SELECT $$replace_iterdef$$::jsonb doc RETURNING *
|
||||
)
|
||||
-- select * from log
|
||||
-- select 'log', * from log
|
||||
--
|
||||
,final AS (
|
||||
SELECT
|
||||
@ -233,7 +233,7 @@ FROM
|
||||
CROSS JOIN log
|
||||
LEFT OUTER JOIN "CMS.CUSLG".itemm i ON i.item = b.part
|
||||
)
|
||||
-- select * from final
|
||||
-- select 'final', * from final
|
||||
--
|
||||
, ins AS (
|
||||
INSERT INTO rlarp.osm_pool SELECT * FROM final RETURNING *
|
||||
@ -321,4 +321,6 @@ FROM
|
||||
,tag
|
||||
,comment
|
||||
)
|
||||
-- select 'insagg', * from insagg
|
||||
--
|
||||
SELECT json_agg(row_to_json(insagg)) x from insagg
|
||||
|
||||
@ -14,7 +14,7 @@ target AS (select target_vol vincr, target_prc pincr)
|
||||
AND calc_status||flag <> 'CLOSEDREMAINDER' --exclude short ships when building order adjustments
|
||||
AND order_date <= ship_date
|
||||
)
|
||||
-- select * from testv
|
||||
-- select 'testv', * from testv
|
||||
--
|
||||
,flagv AS (
|
||||
SELECT
|
||||
@ -37,7 +37,7 @@ target AS (select target_vol vincr, target_prc pincr)
|
||||
FROM
|
||||
testv
|
||||
)
|
||||
-- select * from flagv
|
||||
-- select 'flagv', * from flagv
|
||||
--
|
||||
,basemix AS (
|
||||
SELECT
|
||||
@ -142,7 +142,7 @@ target AS (select target_vol vincr, target_prc pincr)
|
||||
,ship_month
|
||||
,ship_season
|
||||
)
|
||||
-- select * from basemix
|
||||
-- select 'basemix', * from basemix
|
||||
--
|
||||
,vscale AS (
|
||||
SELECT
|
||||
@ -162,7 +162,7 @@ target AS (select target_vol vincr, target_prc pincr)
|
||||
ELSE 0
|
||||
END AS mod_volume
|
||||
)
|
||||
-- select * from vscale
|
||||
-- select 'vscale', * from vscale
|
||||
--
|
||||
,log AS (
|
||||
INSERT INTO rlarp.osm_log(doc) SELECT $$replace_iterdef$$::jsonb doc RETURNING *
|
||||
@ -231,7 +231,7 @@ FROM
|
||||
CROSS JOIN log
|
||||
LEFT OUTER JOIN "CMS.CUSLG".itemm i ON i.item = b.part
|
||||
)
|
||||
-- select * from volume
|
||||
-- select 'volume', * from volume
|
||||
--
|
||||
,pscale AS (
|
||||
SELECT
|
||||
@ -249,7 +249,7 @@ FROM
|
||||
(SELECT pincr::numeric FROM target) / (SELECT nullif(sum(value_loc),0) FROM volume) - 1
|
||||
END factor
|
||||
)
|
||||
-- select * from pscale
|
||||
-- select 'pscale', * from pscale
|
||||
--
|
||||
,pricing AS (
|
||||
SELECT
|
||||
@ -320,7 +320,7 @@ FROM
|
||||
WHERE
|
||||
s.factor <> 0
|
||||
)
|
||||
-- SELECT * FROM pricing UNION ALL SELECT * FROM volume
|
||||
-- select 'price', * from price UNION ALL SELECT 'volume', * FROM volume
|
||||
--
|
||||
, ins AS (
|
||||
INSERT INTO rlarp.osm_pool (SELECT * FROM pricing UNION ALL SELECT * FROM volume) RETURNING *
|
||||
@ -408,6 +408,6 @@ FROM
|
||||
,tag
|
||||
,comment
|
||||
)
|
||||
-- select * from insagg
|
||||
-- select 'insagg', * from insagg
|
||||
--
|
||||
SELECT json_agg(row_to_json(insagg)) x from insagg
|
||||
|
||||
@ -17,10 +17,10 @@ mseq AS (
|
||||
,('10 - Mar',10)
|
||||
,('11 - Apr',11)
|
||||
,('12 - May',12)
|
||||
|
||||
) x(m,s)
|
||||
)
|
||||
--select * from mseq
|
||||
-- select 'mseq', * from mseq
|
||||
--
|
||||
,base AS (
|
||||
SELECT
|
||||
order_season
|
||||
@ -46,6 +46,8 @@ GROUP BY
|
||||
,bill_cust_descr
|
||||
,ship_cust_descr
|
||||
)
|
||||
-- select 'base', * from base
|
||||
--
|
||||
, basket1 AS (
|
||||
SELECT
|
||||
part_descr
|
||||
@ -59,6 +61,8 @@ GROUP BY
|
||||
,bill_cust_descr
|
||||
,ship_cust_descr
|
||||
)
|
||||
-- select 'basket1', * from basket1
|
||||
--
|
||||
,basket AS (
|
||||
SELECT
|
||||
part_descr
|
||||
@ -70,6 +74,8 @@ GROUP BY
|
||||
ORDER BY
|
||||
mix DESC
|
||||
)
|
||||
-- select 'basket', * from basket
|
||||
--
|
||||
,months AS (
|
||||
SELECT
|
||||
order_season
|
||||
@ -128,6 +134,8 @@ GROUP BY
|
||||
ORDER BY
|
||||
mseq.s ASC
|
||||
)
|
||||
-- select 'mlist', * from mlist
|
||||
--
|
||||
,totals AS (
|
||||
SELECT
|
||||
order_season
|
||||
@ -142,6 +150,8 @@ GROUP BY
|
||||
,version
|
||||
,iter
|
||||
)
|
||||
-- select 'totals', * from totals
|
||||
--
|
||||
,tags AS (
|
||||
SELECT DISTINCT
|
||||
doc->>'tag' tag
|
||||
@ -157,6 +167,8 @@ GROUP BY
|
||||
('volume')
|
||||
) x(tag)
|
||||
)
|
||||
-- select 'tags', * from tags
|
||||
--
|
||||
,custs AS (
|
||||
SELECT
|
||||
bill_cust_descr
|
||||
@ -168,6 +180,8 @@ GROUP BY
|
||||
bill_cust_descr
|
||||
,ship_cust_descr
|
||||
)
|
||||
-- select 'custs', * from custs
|
||||
--
|
||||
SELECT
|
||||
jsonb_build_object(
|
||||
'months'
|
||||
|
||||
@ -27,7 +27,8 @@ target AS (select 'replace_new_mold' new_mold)
|
||||
coltier,
|
||||
sizc
|
||||
)
|
||||
--SELECT * FROM basemix
|
||||
-- SELECT 'basemix', * FROM basemix
|
||||
--
|
||||
,tag AS (
|
||||
SELECT
|
||||
b.part
|
||||
@ -55,7 +56,8 @@ target AS (select 'replace_new_mold' new_mold)
|
||||
CASE WHEN b.colc = i.colc THEN '1' ELSE '0' END||
|
||||
CASE WHEN substring(b.part,9,12) = substring(i.item,9,12) THEN '1' ELSE 0 END >= '111110'
|
||||
)
|
||||
--SELECT * FROM tag
|
||||
-- SELECT 'tag', * FROM tag
|
||||
--
|
||||
,rsort AS (
|
||||
SELECT
|
||||
part,
|
||||
@ -69,6 +71,8 @@ ORDER BY
|
||||
part
|
||||
,fit desc
|
||||
)
|
||||
-- select 'rsort', * from rsort
|
||||
--
|
||||
SELECT
|
||||
json_agg(row_to_json(rsort)) x
|
||||
FROM
|
||||
|
||||
Loading…
Reference in New Issue
Block a user