3.4단계: 애플리케이션 코드 업데이트(선택 사항)

애플리케이션 코드를 업데이트하려면

1. 다음과 같이 또 다른 애플리케이션 내 스트림을 생성합니다.

   • DESTINATION_SQL_STREAM_2라고 하는 또 다른 애플리케이션 내 스트림을 생성합니다.

   • 펌프를 생성한 다음 생성된 펌프로 DESTINATION_SQL_STREAM에서 행을 선택하여 새로 생성된 스트림에 행을 삽입합니다.

   SQL 편집기에서 다음 코드를 기존 애플리케이션 코드에 추가합니다.

   CREATE OR REPLACE STREAM "DESTINATION_SQL_STREAM_2" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "STREAM_PUMP_2" AS 
      INSERT INTO "DESTINATION_SQL_STREAM_2"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "DESTINATION_SQL_STREAM";

   코드를 저장하고 실행합니다. 추가 애플리케이션 내 스트림이 [Real-time analytics] 탭에 표시됩니다.

2. 두 개의 애플리케이션 내 스트림을 생성합니다. 주식 티커를 바탕으로 SOURCE_SQL_STREAM_001에 있는 행을 필터링한 다음 생성된 별도의 스트림에 삽입합니다.

   다음의 SQL 문을 애플리케이션 코드에 추가합니다.

   CREATE OR REPLACE STREAM "AMZN_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "AMZN_PUMP" AS 
      INSERT INTO "AMZN_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%AMZN%';
   
   CREATE OR REPLACE STREAM "TGT_STREAM" 
              (ticker_symbol VARCHAR(4), 
               change        DOUBLE, 
               price         DOUBLE);
   
   CREATE OR REPLACE PUMP "TGT_PUMP" AS 
      INSERT INTO "TGT_STREAM"
         SELECT STREAM ticker_symbol, change, price 
         FROM   "SOURCE_SQL_STREAM_001"
         WHERE  ticker_symbol SIMILAR TO '%TGT%';

   코드를 저장하고 실행합니다. 추가 애플리케이션 내 스트림이 [Real-time analytics] 탭에 표시되는지 확인합니다.