IMPORTANT: This documentation has been discontinued. Read the updated Paginations Example documentation on our new documentation portal.
This document, show some query examples to implement paginated queries in the pipeline.
Input Json Example:
{
"page" : 1,
"pageSize" : 50
}
Oracle
SELECT COL_A, COL_B
FROM (SELECT COL_A,
COL_B,
row_number() over (order by COL_A) rn
FROM XPTO.MY_TABLE )
WHERE rn BETWEEN {{ TOLONG(SUM(SUBTRACT(MULTIPLY(message.page, message.pageSize), message.pageSize), 1)) }}
AND {{ TOLONG(MULTIPLY(message.page, message.pageSize)) }}
SQL Server
SELECT col_a, col_b FROM myTabel
ORDER BY col_a
OFFSET {{ TOLONG(SUM(SUBTRACT(MULTIPLY(message.page, message.pageSize), message.pageSize), 1)) }} ROWS
FETCH NEXT {{ message.pageSize}} ROWS ONLY
Data Bricks (managed Apache Spark)
WITH CTEResults AS
(
SELECT *, ROW_NUMBER() OVER (ORDER BY query.col_1) AS RowNum FROM(
select distinct
col_1,
col_2,
col_3
from mytable
where << YOUR FILTERS HERE>>
order by col_1) query
)
SELECT *
FROM CTEResults
where RowNum > {{ TOLONG(SUBTRACT(MULTIPLY(message.page, message.pageSize), message.pageSize)) }}
and RowNum <= {{ TOLONG(MULTIPLY(message.page, message.pageSize)) }}