ピッキングリストの同期制御 ( 例) 

使用

XML リポジトリ内のピッキングリストを、同期中にSAP R/3 から CATS ノートブック に転送されたピッキングリストで上書きしないとします。その代わりに、以下のようにピッキングリストを更新します。

ｷ        ピッキングリストの行が XML リポジトリ内にすでに存在する場合は、その行を同期中に受信したピッキングリスト内の行で置換します。

ｷ        ピッキングリストの行が XML リポジトリ内に存在しない場合は、その行をピッキングリストに挿入します。

手順

...

       1.      別のクラス、ZsynchronizationInboundHandler を定義します。 このクラスでは IsynchronizationInboundHandler インタフェースを導入する必要があります。

       2.      getObjectName メソッドを導入します。

       3.      handleInboundContainer メソッドを導入します。

-         IMessageContainer クラスのインスタンスを、必要に応じて同期操作に関する出力メッセージに登録します。注記: 簡略化のため、この例ではメッセージの表示については説明しません。

-         DatabaseCustomer クラスのインスタンスを読み込みます。

-         SAP R/3 から受信したピッキングリストの各行を順次読み込み、CATS ノートブック の XML リポジトリに同じ一次キーをもつ行がないかチェックします。

ｷ         同じ一次キーをもつ行が存在した場合は、その行を削除し、受信したピッキングリストの行を XML リポジトリ内のピッキングリストに挿入します。

ｷ         同じ一次キーをもつ行が存在しない場合は、受信したピッキングリストの行を XML リポジトリ内のピッキングリストに挿入します。

Java ソースコード

package com.sap.mycats.customer.examples;

 

import  com.sap.mycats.basics.database.badi.*;

import  com.sap.mycats.basics.tools.badi.*;

import  com.sap.mycats.basics.customer.synchronization.ISynchronizationInboundHandler;

 

/**

  * This example of an ISynchronizationInboundHandler appends or updates

  * received elements.The standard handler would replace all records with the

  * received table.

 */

public class ZSynchronizationInboundHandler

     implements ISynchronizationInboundHandler

{

     public final static String ZPICKLIST_WBS = "ZPICKLIST_POSID";

 

 

     public ZSynchronizationInboundHandler () {

     }

 

 

     public String getObjectName () {

         return ZPICKLIST_WBS;

     }

 

 

     public void handleInboundContainer (ITableReadOnly anInboundContainer) {

         DatabaseCustomer database =  DatabaseCustomer.getInstance();

         for (int i = 0; i < anInboundContainer.getRowCount(); i++) {

             IRecordReadWrite record = null;

             try {

                 record = RecordFactory.createRecord(ZPICKLIST_WBS);

             } catch (Exception e) {

                 return;

             }

             record.setCorrespondingFields(anInboundContainer.getRecordReadOnly(i));

             ITableReadWrite oldRecords

                 = database.select(ZPICKLIST_WBS, "primary", record, record);

             for (int j = 0; j < oldRecords.getRowCount(); j++) {

                 database.delete(ZPICKLIST_WBS, oldRecords.getRecordReadWrite(j));

             }

             database.insert(ZPICKLIST_WBS, record);

         }

     }

}