Ошибка при попытке объединить поле в DB2 SQL - PullRequest
Новая
       62

Ошибка при попытке объединить поле в DB2 SQL

0 голосов
/ 19 сентября 2018

У меня есть запрос, который получает текущие уровни запасов из нашей базы данных.Базовый запрос работает без проблем, но мне нужно добавить в поле Ship_From.Проблема в том, что если я просто добавлю его в запрос на выборку, это приведет к дублированию строк для каждого местоположения (местоположение - единственное, что отличается между ними).Я попытался выяснить это, используя этот справочник и этот ТАК вопрос в качестве руководства.К сожалению, я застрял с запросом (ниже), сообщившим мне об ошибке:

"Произошла ошибка при выполнении запроса.

Неправильное использование ключевого слова WITH, токена QUERYNO, ГДЕ ГДЕ ПЕРЕКЛЮЧЕНИЕ ГРУППОВОГО ЗАКАЗА былоожидается.

(код SQL = -199, состояние SQL = 42601) "

Я использую QMF для Windows Версии 8.1 Fix Pack 15 (Unicode) для выполнения запроса.Единственное поле с дубликатами - Ship_from, и я хочу объединить значения в одну строку, чтобы удалить дублированные данные, как в этом примере (некоторые столбцы удалены, поскольку все они одинаковы, за исключением поля Ship_From):

Текущий: 

SUPPLIER_NAME|CONTAINER_CODE|ALLOC_QTY|   SOH   | %_Fill|Ship_from|
Supplier A   |   Pallet     |   100   |   96    |  96%  |  IOSL1  |
Supplier A   |   Pallet     |   100   |   96    |  96%  |  IHMI1  |
Supplier A   |   Pallet     |   100   |   96    |  96%  |  IHMI2  |

Желаемый: 

SUPPLIER_NAME|CONTAINER_CODE|ALLOC_QTY|   SOH   | %_Fill|     Ship_from     |
Supplier A   |   Pallet     |   100   |   96    | 96%   |IOSL1, IHMI1, IHMI2|

Код SQL: 

with X(Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill", Ship_from) as (

select distinct
    ProcFlowPlus.Sup_No,
    ProcFlowPlus.Supplier_name,
    ProcFlowPlus.CONTAINER_CODE,
    int(Allocation.ALLOC_QTY) as Alloc_Qty,
    Allocation.SAFE_STOCK_QTY,
    int(Allocation.TOT_ALLOC_REQ_QTY) as TOT_ALLOC_REQ_QTY,
    BuckStat.CONTAINER_TYPE_QTY as SOH,
    SIE_Bucket.SIE,
    int((BuckStat.CONTAINER_TYPE_QTY + SIE_Bucket.SIE) - Allocation.TOT_ALLOC_REQ_QTY) as Disc_Qty,
    concat (int((CONTAINER_TYPE_QTY + SIE_Bucket.SIE)/ Allocation.TOT_ALLOC_REQ_QTY * 100), '%') as "%_Fill",
    ProcFlowPlus.PROC_FLO_DESC as Ship_from

from
    (select distinct
        ProcFlow.PROC_FLO_ID,
        ContTrans.CONTAINER_TYPE_ID,
        ContTrans.CONTAINER_CODE,
        SupLookup.Sup_No,
        SupName.Supplier_name,
        ProcFlow.PROC_FLO_DESC
    from 
        (select distinct
            ProcFlow.SUPPLIER_ID,
            ProcFlow.PROC_FLO_ID,
            ProcFlow.PROC_FLO_DESC,
            ProcFlow.PROC_FLO_NAME
        from rcx.RXPRF1 ProcFlow
        where PLANT_ID = '50000036') as ProcFlow
        left join (select distinct
                       SUPPLIER_ID,
                       SUPPLIER_NO concat SUPPLIER_LOCATION as Sup_No
                   from rcx.RXPIR1 Suplookup
                   where PLANT_ID = '50000036'
                  ) as SupLookup on ProcFlow.SUPPLIER_ID = SupLookup.SUPPLIER_ID
        left join (select distinct
                       SupInfo.Supplier,
                       SupInfo.Supplier_name,
                       suplookup.SUPPLIER_ID
                   from 
                       (select distinct
                           SUPPLIER_ID,
                           concat(SUPPLIER_NO, SUPPLIER_LOCATION) as Sup_Num
                        from rcx.RXPIR1
                        where COMPANY_CODE like('HMI%')
                            and not SUPPLIER_NO in ('JN9999','272180','506776','081583','504880')
                        ) as SupLookup
                   left join rcx.RXSIV1 SupInfo on SupLookup.Sup_Num = SupInfo.SUPPLIER
                   where COMPANY_CODE like('HMI%')
                   ) as SupName on SupLookup.SUPPLIER_ID = SupName.SUPPLIER_ID

        left join rcx.RXPFC1 flowcont on ProcFlow.PROC_FLO_ID = flowcont.PROC_FLO_ID 
        left join rcx.RXCTY1 ContTrans on flowcont.CONTAINER_TYPE_ID = ContTrans.CONTAINER_TYPE_ID
        where not ProcFlow.PROC_FLO_NAME like '%RPR%'
            and (right(ProcFlow.PROC_FLO_DESC, 5) like ('IHMI%') 
            or right(ProcFlow.PROC_FLO_DESC, 5) like ('%IOSL%'))
        ) as ProcFlowPlus

    left join (select distinct
                  SupLookup.Sup_Num,
                  Suplookup.CONTAINER_CODE,
                  AllocationType.ALLOC_TYPE_DESC,
                  Allocation.ALLOC_QTY,
                  Allocation.SAFE_STOCK_QTY,
                  Allocation.ALLOC_QTY + Allocation.SAFE_STOCK_QTY as TOT_ALLOC_REQ_QTY

               from RCX.RXSAL1 Allocation
               inner join rcx.RXALT1 AllocationType on Allocation.ALLOC_TYPE_ID = AllocationType.ALLOC_TYPE_ID
               left join (select distinct
                              SUPPLIER_ID,
                              concat(SUPPLIER_NO, SUPPLIER_LOCATION) as Sup_Num,
                              CONTAINER_CODE,
                              CONTAINER_TYPE_ID
                         from rcx.RXPIR1    
                         where PLANT_ID= '50000036'
                         ) as SupLookup on Allocation.SUPPLIER_ID = suplookup.SUPPLIER_ID and allocation.CONTAINER_TYPE_ID = suplookup.CONTAINER_TYPE_ID
               where Allocation.PLANT_ID= '50000036'
               ) as Allocation on ProcFlowPlus.Sup_No = Allocation.Sup_Num and ProcFlowPlus.CONTAINER_CODE = Allocation.CONTAINER_CODE

    left join (select distinct
                   ProcFlowPlus.Sup_No,
                   ProcFlowPlus.CONTAINER_CODE,
                   BuckStat.CONTAINER_TYPE_QTY as SIE
               from (select distinct
                        ProcFlow.PROC_FLO_ID,
                        ContTrans.CONTAINER_TYPE_ID,
                        ContTrans.CONTAINER_CODE,
                        SupLookup.Sup_No,
                        ProcFlow.PROC_FLO_DESC
                     from (select distinct
                              ProcFlow.SUPPLIER_ID,
                              ProcFlow.PROC_FLO_ID,
                              ProcFlow.PROC_FLO_DESC,
                              ProcFlow.PROC_FLO_NAME
                          from rcx.RXPRF1 ProcFlow
                          where PLANT_ID = '50000036') as ProcFlow
                     left join (select distinct
                                   SUPPLIER_ID,
                                   SUPPLIER_NO concat SUPPLIER_LOCATION as Sup_No
                                from rcx.RXPIR1 Suplookup
                                where PLANT_ID = '50000036'
                                ) as SupLookup on ProcFlow.SUPPLIER_ID = SupLookup.SUPPLIER_ID
                     left join (select distinct
                                   SupInfo.Supplier,
                                   suplookup.SUPPLIER_ID
                                from (select distinct
                                         SUPPLIER_ID,
                                        concat(SUPPLIER_NO, SUPPLIER_LOCATION) as Sup_Num
                                      from rcx.RXPIR1
                                      where COMPANY_CODE like('HMI%')
                                          and not SUPPLIER_NO in ('JN9999','272180','506776','081583','504880')
                                       ) as SupLookup
                                left join rcx.RXSIV1 SupInfo on SupLookup.Sup_Num = SupInfo.SUPPLIER
                                where COMPANY_CODE like('HMI%')
                                ) as SupName on SupLookup.SUPPLIER_ID = SupName.SUPPLIER_ID
                     left join rcx.RXPFC1 flowcont on ProcFlow.PROC_FLO_ID = flowcont.PROC_FLO_ID 
                     left join rcx.RXCTY1 ContTrans on flowcont.CONTAINER_TYPE_ID = ContTrans.CONTAINER_TYPE_ID
                     where not ProcFlow.PROC_FLO_NAME like '%RPR%'
                         and (right(ProcFlow.PROC_FLO_DESC, 5) like ('IHMI%') or right(ProcFlow.PROC_FLO_DESC, 5) like ('%IOSL%'))) as ProcFlowPlus

                     left join rcx.RXRLN1 buckets on ProcFlowPlus.PROC_FLO_ID = buckets.PROC_FLO_ID
                     left join rcx.RXBKT1 BucketNames on buckets.TO_BUCKET_ID = BucketNames.BUCKET_ID
                     left join rcx.RXBTC1 BuckStat on buckets.TO_BUCKET_ID = BuckStat.BUCKET_ID

                     where ProcFlowPlus.Sup_No is not null
                        and BuckStat.CONTAINER_TYPE_ID = ProcFlowPlus.CONTAINER_TYPE_ID
                        and BucketNames.BUCKET_NAME like '%SIE%'
                     ) as SIE_Bucket on ProcFlowPlus.Sup_No = SIE_Bucket.Sup_No and ProcFlowPlus.CONTAINER_CODE = SIE_Bucket.CONTAINER_CODE

    left join rcx.RXRLN1 buckets on ProcFlowPlus.PROC_FLO_ID = buckets.PROC_FLO_ID
    left join rcx.RXBKT1 BucketNames on buckets.TO_BUCKET_ID = BucketNames.BUCKET_ID
    left join rcx.RXBTC1 BuckStat on buckets.TO_BUCKET_ID = BuckStat.BUCKET_ID

    where ProcFlowPlus.Supplier_name is not null
        and BuckStat.CONTAINER_TYPE_ID = ProcFlowPlus.CONTAINER_TYPE_ID
        and BucketNames.BUCKET_NAME like '%SOH%'
        and Allocation.ALLOC_QTY is not null

    order by 
        ProcFlowPlus.Sup_No asC,
        ProcFlowPlus.CONTAINER_CODE asc
) 

select Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill", 
       LISTAGG(Ship_from, ', ') within group (order by Ship_from) as Ship_from
from X
group by Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill"

-EDIT-

Обновлен код для использованияФункция LISTAGG, как предложил @ P.Vernon.Это приводит к ошибке для ключевого слова Group (недопустимое использование ключевого слова) в предложении LISTAGG Within Group.Если я удаляю функцию LISTAGG и заменяю ее просто Ship_from или полностью удаляю Ship_from, запрос выполняется должным образом.

1 Ответ

0 голосов
/ 19 сентября 2018

Использовать LISTAGG, а не рекурсию для агрегированных строк.Например, 

with X(Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill", Ship_from, curr, prev) as 
( values (1,1,1,1,1,1,1,1,1,1,'IOSL1',1,1)
        ,(1,1,1,1,1,1,1,1,1,1,'IHMI1',1,1)
        ,(1,1,1,1,1,1,1,1,1,1,'IHMI2',1,1))
select Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill"
,      LISTAGG(Ship_from, ', ') within group (order by Ship_from DESC) as Ship_from
from X
group by Sup_No, Supplier_name, CONTAINER_CODE, Alloc_Qty, SAFE_STOCK_QTY, TOT_ALLOC_REQ_QTY, SOH, SIE, Disc_Qty, "%_Fill"

вернется 

 SUP_NO    SUPPLIER_NAME   CONTAINER_CODE  ALLOC_QTY   SAFE_STOCK_QTY  TOT_ALLOC_REQ_QTY   SOH     SIE     DISC_QTY    %_Fill  SHIP_FROM
 ------     -------------   --------------  ---------   --------------  -----------------   ---     ---     --------    ------  -------------------
      1                 1                1          1                1                  1     1       1            1         1  IOSL1, IHMI2, IHMI1
...