步骤 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 选项卡上的其他应用程序内部流。