DBA Data[Home] [Help]

APPS.CSM_AUTO_SYNC_NFN_PKG SQL Statements

The following lines contain the word 'select', 'insert', 'update' or 'delete':

Line: 30

  SELECT *
  FROM  csm_auto_sync_nfn_inq
  WHERE tranid$$ = b_tranid
  AND   clid$$cs = b_user_name;
Line: 36

PROCEDURE INSERT_AUTO_SYNC_NFN_ACC (p_notification_id IN wf_notifications.notification_id%TYPE,
                                    p_user_id   IN fnd_user.user_id%TYPE)
IS
  l_sysdate 	DATE;
Line: 42

    CSM_ACC_PKG.Insert_Acc
    ( P_PUBLICATION_ITEM_NAMES => g_auto_sync_nfn_pubi_name
     ,P_ACC_TABLE_NAME         => g_auto_sync_nfn_acc_table_name
     ,P_SEQ_NAME               => g_auto_sync_nfn_seq_name
     ,P_PK1_NAME               => g_auto_sync_nfn_pk1_name
     ,P_PK1_NUM_VALUE          => p_notification_id
     ,P_USER_ID                => p_user_id
    );
Line: 51

  CSM_UTIL_PKG.LOG( 'Exception occurred in ' || g_object_name || '.INSERT_AUTO_SYNC_NFN_ACC: '
|| SQLERRM,' for PK ' || to_char(p_notification_id) || g_object_name || '.INSERT_AUTO_SYNC_NFN_ACC',FND_LOG.LEVEL_EXCEPTION);
Line: 55

END INSERT_AUTO_SYNC_NFN_ACC;-- end INSERT_AUTO_SYNC_NFN_ACC
Line: 67

 SELECT DISTINCT notification_id
 FROM  CSM_AUTO_SYNC_NFN
 WHERE  user_id=b_user_id;
Line: 79

   INSERT_AUTO_SYNC_NFN_ACC (l_notf_rec.notification_id, p_user_id);
Line: 97

  an inserted record is to be processed.
***/
PROCEDURE APPLY_INSERT
         (
           p_record        IN c_auto_sync_nfn_inq%ROWTYPE,
           p_error_msg     OUT NOCOPY    VARCHAR2,
           x_return_status IN OUT NOCOPY VARCHAR2,
           x_reject_row    OUT NOCOPY BOOLEAN
         ) IS


  l_notification_id    csm_auto_sync_nfn.notification_id%TYPE  ;
Line: 118

  )IS SELECT ROWID
      FROM   CSM_AUTO_SYNC_NFN
      WHERE  notification_id = b_notification_id;
Line: 124

CSM_UTIL_PKG.log( 'Entering ' || g_object_name || '.APPLY_INSERT:'
               || ' for PK ' || p_record.notification_id,
               'CSM_AUTO_SYNC_NFN.APPLY_INSERT',
               FND_LOG.LEVEL_PROCEDURE );
Line: 139

insert into csm_auto_sync_nfn(USER_ID,
NOTIFICATION_ID,
OBJECT_ID ,
OBJECT_NAME,
COMMAND_ID ,
SYNC_ID,
DML,
RESPONSE,
RESPONDED_ON,
CREATION_DATE ,
CREATED_BY,
LAST_UPDATE_DATE,
LAST_UPDATED_BY)
 values (l_user_id,l_notification_id,l_object_id,l_object_name,p_record.command_id,p_record.sync_id,p_record.dml,p_record.response,p_record.responded_on,p_record.creation_date,p_record.created_by,p_record.last_update_date,p_record.last_updated_by)
RETURNING NOTIFICATION_ID INTO l_notification_id;
Line: 156

  ** Check whether the insert was succesfull
  ***************************************************************************/
CSM_UTIL_PKG.log( 'Test message ' || l_user_id||' , '|| p_record.notification_id||' , '||p_record.object_id ||' , '||p_record.object_name||' , '||p_record.command_id ||' , '||p_record.sync_id );
Line: 188

    CSM_UTIL_PKG.log( 'Error in ' || g_object_name || '.APPLY_INSERT:'
      || ' ROOT ERROR: create statement'
      || ' for PK ' || p_record.NOTIFICATION_ID,
      g_object_name || '.APPLY_INSERT',
      FND_LOG.LEVEL_ERROR );
Line: 201

     CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_INSERT:'
       || ' for PK ' || p_record.notification_id,
       g_object_name || '.APPLY_INSERT',
       FND_LOG.LEVEL_EXCEPTION );
Line: 208

END APPLY_INSERT;
Line: 213

  an updated record is to be processed.
  For CSM 11583, we support updates on the DFF columns
***/
PROCEDURE APPLY_UPDATE
         (
           p_record        IN c_auto_sync_nfn_inq%ROWTYPE,
           p_error_msg     OUT NOCOPY    VARCHAR2,
           x_return_status IN OUT NOCOPY VARCHAR2
         )
IS
CURSOR	 c_auto_sync_nfn ( b_notification_id NUMBER ) IS
SELECT 	 *
FROM   	 csm_auto_sync_nfn
WHERE  	 notification_id = b_notification_id;
Line: 228

CURSOR c_last_update_date ( b_notification_id NUMBER)
IS
SELECT LAST_UPDATE_DATE,
       last_updated_by
FROM   csm_auto_sync_nfn
WHERE  notification_id = b_notification_id;
Line: 251

CSM_UTIL_PKG.log( 'Entering ' || g_object_name || '.APPLY_UPDATE:'
               || ' for PK ' || p_record.notification_id,
               'CSM_AUTO_SYNC_NFN.APPLY_UPDATE',
               FND_LOG.LEVEL_PROCEDURE );
Line: 287

  ** Update the record
  ***************************************************************************/

UPDATE csm_auto_sync_nfn
SET USER_ID = l_user_id,
NOTIFICATION_ID = p_record.notification_id,
OBJECT_ID  = p_record.object_id ,
OBJECT_NAME = p_record.object_name,
COMMAND_ID = p_record.command_id ,
SYNC_ID = p_record.sync_id,
DML =  p_record.dml,
RESPONSE = p_record.response,
RESPONDED_ON = p_record.responded_on,
CREATION_DATE = p_record.creation_date ,
CREATED_BY = p_record.created_by,
LAST_UPDATE_DATE = p_record.last_update_date,
LAST_UPDATED_BY	= p_record.last_updated_by
where NOTIFICATION_ID=p_record.notification_id;
Line: 309

  ** Check if the update was succesful
  ***************************************************************************/

  IF (SQL%NOTFOUND)
  THEN
    RAISE NO_DATA_FOUND;
Line: 330

     CSM_UTIL_PKG.log( 'Exception in ' || g_object_name || '.APPLY_UPDATE:'
       || ' for PK ' || p_record.notification_id,
       g_object_name || '.APPLY_UPDATE',
       FND_LOG.LEVEL_EXCEPTION );
Line: 337

END APPLY_UPDATE;
Line: 361

    APPLY_INSERT
      (
        p_record,
        p_error_msg,
        x_return_status,
        x_reject_row
      );
Line: 368

  ELSIF p_record.dmltype$$='U' THEN -- YLIAO: for 11583, we do support UPDATE
    -- Process update
    APPLY_UPDATE
      (
        p_record,
        p_error_msg,
        x_return_status
      );
Line: 380

      ( 'Delete and Update is not supported for this entity'
        || ' for PK ' || p_record.notification_id ,
        g_object_name || '.APPLY_RECORD',
        FND_LOG.LEVEL_ERROR);
Line: 453

      /*** If Yes -> delete record from inqueue ***/
        CSM_UTIL_PKG.DELETE_RECORD
        (
          p_user_name,
          p_tranid,
          r_auto_sync_nfn.seqno$$,
          r_auto_sync_nfn.notification_id,
          g_object_name,
          g_pub_name,
          l_error_msg,
          l_return_status --Introduced new variable l_return_status since Defer
        );
Line: 481

       CSM_UTIL_PKG.DELETE_RECORD
        (
          p_user_name,
          p_tranid,
          r_auto_sync_nfn.seqno$$,
          r_auto_sync_nfn.notification_id,
          g_object_name,
          g_pub_name,
          l_error_msg,
          l_return_status --Introduced new variable l_return_status since Defer
        );                --process doesn't depend on this delete_record API
Line: 497

      /*** was delete/reject successful? ***/
      IF l_return_status <> FND_API.G_RET_STS_SUCCESS THEN
        /*** If No -> rollback ***/
        CSM_UTIL_PKG.LOG
        ( 'Deleting from inqueue failed, rolling back to savepoint'
          || ' for PK ' || r_auto_sync_nfn.notification_id ,
          g_object_name || '.APPLY_CLIENT_CHANGES',
          FND_LOG.LEVEL_ERROR); -- put PK column here
Line: 511

      /*** Record was not processed successfully or delete failed
      -> defer and reject record ***/
      CSM_UTIL_PKG.LOG
      ( 'Record not processed successfully, deferring and rejecting record'
        || ' for PK ' || r_auto_sync_nfn.notification_id ,
        g_object_name || '.APPLY_CLIENT_CHANGES',
        FND_LOG.LEVEL_ERROR); -- put PK column here