如何在 spark/scala 中编写或调用 -SQL 游标？

Question

是否可以在 scala/spark 中编写/调用光标？我想从 spark/scala 代码中编写或调用（SQL 游标）游标。

下面是我想从 scala 代码中调用它的游标（用 SQL 编写）。

declare
   cursor c1 is
       select DISTINCT earning_id from CN_TP_EARNINGS_ALL where rownum < 10;
   cursor c2(p_Assigned in number) is
       select SOURCE_EVENT_PERIOD_ID from  CN_TP_EARNINGS_ALL where 
       earning_id = p_Assigned;

begin
 for r1 in c1 loop
  dbms_output.put_line('------- start  --------');
  for r2 in c2(r1.earning_id) loop
     dbms_output.put_line(r2.SOURCE_EVENT_PERIOD_ID);
  end loop;
     dbms_output.put_line('------- end  -------');
 end loop;
end;

Answer 1

只需使用 C1 游标中的 SELECT 语句，然后在 Scala 中的 for 循环中处理结果集，然后在循环内使用准备好的语句来选择 C2 游标值并再次循环。