Merge 66e3c82 into 4549fb4

Author: resetius

ydb/library/benchmarks/queries/tpcds/yql/q49.sql

@@ -2,6 +2,11 @@
 
 -- NB: Subquerys
 -- start query 1 in stream 0 using template query49.tpl and seed 1819994127
+
+$todecimal = ($x) -> {
+  return cast(cast($x as string?) as decimal(15,4))
+};
+
 $non_unique = (select  channel, item, return_ratio, return_rank, currency_rank from
  (select
  'web' as channel
@@ -18,12 +23,12 @@ $non_unique = (select  channel, item, return_ratio, return_rank, currency_rank f
  	,rank() over (order by currency_ratio) as currency_rank
  	from
  	(	select ws.ws_item_sk as item
- 		,(cast(sum(coalesce(wr.wr_return_quantity,0)) as float)/
- 		cast(sum(coalesce(ws.ws_quantity,0)) as float )) as return_ratio
- 		,(cast(sum(coalesce(wr.wr_return_amt,0)) as float)/
- 		cast(sum(coalesce(ws.ws_net_paid,0)) as float )) as currency_ratio
+ 		,(sum(coalesce($todecimal(wr.wr_return_quantity),cast(0 as decimal(15,4))))/
+ 		sum(coalesce($todecimal(ws.ws_quantity),cast(0 as decimal(15,4))))) as return_ratio
+ 		,(sum(coalesce($todecimal(wr.wr_return_amt),cast(0 as decimal(15,4))))/
+ 		sum(coalesce($todecimal(ws.ws_net_paid),cast(0 as decimal(15,4))))) as currency_ratio
  		from
- 		 {{web_sales}} ws 
+ 		 {{web_sales}} ws
          left join {{web_returns}} wr
  			on (ws.ws_order_number = wr.wr_order_number and
  			ws.ws_item_sk = wr.wr_item_sk)
@@ -62,12 +67,12 @@ $non_unique = (select  channel, item, return_ratio, return_rank, currency_rank f
  	from
  	(	select
  		cs.cs_item_sk as item
- 		,(cast(sum(coalesce(cr.cr_return_quantity,0)) as float)/
- 		cast(sum(coalesce(cs.cs_quantity,0)) as float)) as return_ratio
- 		,(cast(sum(coalesce(cr.cr_return_amount,0)) as float)/
- 		cast(sum(coalesce(cs.cs_net_paid,0)) as float )) as currency_ratio
+ 		,(sum(coalesce($todecimal(cr.cr_return_quantity),cast(0 as decimal(15,4))))/
+ 		sum(coalesce($todecimal(cs.cs_quantity),cast(0 as decimal(15,4))))) as return_ratio
+ 		,(sum(coalesce($todecimal(cr.cr_return_amount),cast(0 as decimal(15,4))))/
+ 		sum(coalesce($todecimal(cs.cs_net_paid),cast(0 as decimal(15,4))))) as currency_ratio
  		from
- 		{{catalog_sales}} cs 
+ 		{{catalog_sales}} cs
         left outer join {{catalog_returns}} cr
  			on (cs.cs_order_number = cr.cr_order_number and
  			cs.cs_item_sk = cr.cr_item_sk)
@@ -105,10 +110,12 @@ $non_unique = (select  channel, item, return_ratio, return_rank, currency_rank f
  	,rank() over (order by currency_ratio) as currency_rank
  	from
  	(	select sts.ss_item_sk as item
- 		,(cast(sum(coalesce(sr.sr_return_quantity,0)) as float)/cast(sum(coalesce(sts.ss_quantity,0)) as float )) as return_ratio
- 		,(cast(sum(coalesce(sr.sr_return_amt,0)) as float)/cast(sum(coalesce(sts.ss_net_paid,0)) as float)) as currency_ratio
+ 		,(sum(coalesce($todecimal(sr.sr_return_quantity),cast(0 as decimal(15,4))))/
+        sum(coalesce($todecimal(sts.ss_quantity),cast(0 as decimal(15,4))))) as return_ratio
+ 		,(sum(coalesce($todecimal(sr.sr_return_amt),cast(0 as decimal(15,4))))/
+        sum(coalesce($todecimal(sts.ss_net_paid),cast(0 as decimal(15,4))))) as currency_ratio
  		from
- 		{{store_sales}} sts 
+ 		{{store_sales}} sts
         left outer join {{store_returns}} sr
  			on (sts.ss_ticket_number = sr.sr_ticket_number and sts.ss_item_sk = sr.sr_item_sk)
                 cross join {{date_dim}} as date_dim