3: --
4: PG_DEBUG varchar2(1) := NVL(FND_PROFILE.value('AFLOG_ENABLED'), 'N');
5:
6: PROCEDURE insert_p(
7: p_dist_rec IN ar_distributions%ROWTYPE,
8: p_line_id OUT NOCOPY ar_distributions.line_id%TYPE ) IS
9: l_line_id ar_distributions.line_id%TYPE;
10: exp_null_insert exception;
11: pragma exception_init(exp_null_insert, -1400);
4: PG_DEBUG varchar2(1) := NVL(FND_PROFILE.value('AFLOG_ENABLED'), 'N');
5:
6: PROCEDURE insert_p(
7: p_dist_rec IN ar_distributions%ROWTYPE,
8: p_line_id OUT NOCOPY ar_distributions.line_id%TYPE ) IS
9: l_line_id ar_distributions.line_id%TYPE;
10: exp_null_insert exception;
11: pragma exception_init(exp_null_insert, -1400);
12: BEGIN
5:
6: PROCEDURE insert_p(
7: p_dist_rec IN ar_distributions%ROWTYPE,
8: p_line_id OUT NOCOPY ar_distributions.line_id%TYPE ) IS
9: l_line_id ar_distributions.line_id%TYPE;
10: exp_null_insert exception;
11: pragma exception_init(exp_null_insert, -1400);
12: BEGIN
13: IF PG_DEBUG in ('Y', 'C') THEN
13: IF PG_DEBUG in ('Y', 'C') THEN
14: arp_standard.debug( 'arp_distributions_pkg.insert_p()+' );
15: END IF;
16: --
17: SELECT ar_distributions_s.nextval
18: INTO l_line_id
19: FROM dual;
20: --
21: IF PG_DEBUG in ('Y', 'C') THEN
60: arp_standard.debug( 'REF_MF_DIST_FLAG ' || p_dist_rec.ref_mf_dist_flag);
61: --HYU--}
62: END IF;
63:
64: INSERT INTO ar_distributions (
65: line_id,
66: source_id,
67: source_table,
68: source_type,
176: RAISE;
177: END insert_p;
178: --
179: PROCEDURE update_p(
180: p_dist_rec IN ar_distributions%ROWTYPE ) IS
181: BEGIN
182: IF PG_DEBUG in ('Y', 'C') THEN
183: arp_standard.debug( 'arp_distributions_pkg.update_p()+' );
184: END IF;
182: IF PG_DEBUG in ('Y', 'C') THEN
183: arp_standard.debug( 'arp_distributions_pkg.update_p()+' );
184: END IF;
185: --
186: UPDATE ar_distributions SET
187: source_id = p_dist_rec.source_id,
188: source_table = p_dist_rec.source_table,
189: source_type = p_dist_rec.source_type,
190: source_type_secondary = p_dist_rec.source_type_secondary,
240: RAISE;
241: END update_p;
242: --
243: PROCEDURE delete_p(
244: p_line_id IN ar_distributions.line_id%TYPE ) IS
245: BEGIN
246: IF PG_DEBUG in ('Y', 'C') THEN
247: arp_standard.debug( 'arp_distributions_pkg.delete_p()+' );
248: END IF;
246: IF PG_DEBUG in ('Y', 'C') THEN
247: arp_standard.debug( 'arp_distributions_pkg.delete_p()+' );
248: END IF;
249: --
250: DELETE FROM ar_distributions
251: WHERE line_id = p_line_id;
252: --
253: IF PG_DEBUG in ('Y', 'C') THEN
254: arp_standard.debug( 'arp_distributions_pkg.delete_p()-' );
261: RAISE;
262: END delete_p;
263: --
264: PROCEDURE lock_p(
265: p_line_id IN ar_distributions.line_id%TYPE ) IS
266: l_line_id ar_distributions.line_id%TYPE;
267: BEGIN
268: IF PG_DEBUG in ('Y', 'C') THEN
269: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
262: END delete_p;
263: --
264: PROCEDURE lock_p(
265: p_line_id IN ar_distributions.line_id%TYPE ) IS
266: l_line_id ar_distributions.line_id%TYPE;
267: BEGIN
268: IF PG_DEBUG in ('Y', 'C') THEN
269: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
270: END IF;
269: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
270: END IF;
271: SELECT line_id
272: INTO l_line_id
273: FROM ar_distributions
274: WHERE line_id = p_line_id
275: FOR UPDATE OF line_id;
276: --
277: IF PG_DEBUG in ('Y', 'C') THEN
285: RAISE;
286: END lock_p;
287: --
288: PROCEDURE fetch_p(
289: p_line_id IN ar_distributions.line_id%TYPE,
290: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
291: BEGIN
292: IF PG_DEBUG in ('Y', 'C') THEN
293: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
286: END lock_p;
287: --
288: PROCEDURE fetch_p(
289: p_line_id IN ar_distributions.line_id%TYPE,
290: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
291: BEGIN
292: IF PG_DEBUG in ('Y', 'C') THEN
293: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
294: END IF;
293: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
294: END IF;
295: SELECT *
296: INTO p_dist_rec
297: FROM ar_distributions
298: WHERE line_id = p_line_id;
299: IF PG_DEBUG in ('Y', 'C') THEN
300: arp_standard.debug( 'arp_distributions_pkg.fetch_p()-' );
301: END IF;
309: RAISE;
310: END fetch_p;
311: --
312: PROCEDURE fetch_pk(
313: p_source_id IN ar_distributions.source_id%TYPE,
314: p_source_table IN ar_distributions.source_table%TYPE,
315: p_source_type IN ar_distributions.source_type%TYPE,
316: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
317: BEGIN
310: END fetch_p;
311: --
312: PROCEDURE fetch_pk(
313: p_source_id IN ar_distributions.source_id%TYPE,
314: p_source_table IN ar_distributions.source_table%TYPE,
315: p_source_type IN ar_distributions.source_type%TYPE,
316: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
317: BEGIN
318: IF PG_DEBUG in ('Y', 'C') THEN
311: --
312: PROCEDURE fetch_pk(
313: p_source_id IN ar_distributions.source_id%TYPE,
314: p_source_table IN ar_distributions.source_table%TYPE,
315: p_source_type IN ar_distributions.source_type%TYPE,
316: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
317: BEGIN
318: IF PG_DEBUG in ('Y', 'C') THEN
319: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
312: PROCEDURE fetch_pk(
313: p_source_id IN ar_distributions.source_id%TYPE,
314: p_source_table IN ar_distributions.source_table%TYPE,
315: p_source_type IN ar_distributions.source_type%TYPE,
316: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
317: BEGIN
318: IF PG_DEBUG in ('Y', 'C') THEN
319: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
320: END IF;
319: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
320: END IF;
321: SELECT *
322: INTO p_dist_rec
323: FROM ar_distributions
324: WHERE source_id = p_source_id
325: AND source_table = p_source_table
326: AND source_type = p_source_type;
327: IF PG_DEBUG in ('Y', 'C') THEN
337: RAISE;
338: END fetch_pk;
339: --
340: PROCEDURE lock_fetch_pk(
341: p_source_id IN ar_distributions.source_id%TYPE,
342: p_source_table IN ar_distributions.source_table%TYPE,
343: p_source_type IN ar_distributions.source_type%TYPE,
344: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
345: BEGIN
338: END fetch_pk;
339: --
340: PROCEDURE lock_fetch_pk(
341: p_source_id IN ar_distributions.source_id%TYPE,
342: p_source_table IN ar_distributions.source_table%TYPE,
343: p_source_type IN ar_distributions.source_type%TYPE,
344: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
345: BEGIN
346: IF PG_DEBUG in ('Y', 'C') THEN
339: --
340: PROCEDURE lock_fetch_pk(
341: p_source_id IN ar_distributions.source_id%TYPE,
342: p_source_table IN ar_distributions.source_table%TYPE,
343: p_source_type IN ar_distributions.source_type%TYPE,
344: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
345: BEGIN
346: IF PG_DEBUG in ('Y', 'C') THEN
347: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
340: PROCEDURE lock_fetch_pk(
341: p_source_id IN ar_distributions.source_id%TYPE,
342: p_source_table IN ar_distributions.source_table%TYPE,
343: p_source_type IN ar_distributions.source_type%TYPE,
344: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
345: BEGIN
346: IF PG_DEBUG in ('Y', 'C') THEN
347: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
348: END IF;
347: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
348: END IF;
349: SELECT *
350: INTO p_dist_rec
351: FROM ar_distributions
352: WHERE source_id = p_source_id
353: AND source_table = p_source_table
354: AND source_type = p_source_type
355: FOR UPDATE OF line_id;
367: RAISE;
368: END lock_fetch_pk;
369: --
370: PROCEDURE nowaitlock_fetch_pk(
371: p_source_id IN ar_distributions.source_id%TYPE,
372: p_source_table IN ar_distributions.source_table%TYPE,
373: p_source_type IN ar_distributions.source_type%TYPE,
374: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
375: BEGIN
368: END lock_fetch_pk;
369: --
370: PROCEDURE nowaitlock_fetch_pk(
371: p_source_id IN ar_distributions.source_id%TYPE,
372: p_source_table IN ar_distributions.source_table%TYPE,
373: p_source_type IN ar_distributions.source_type%TYPE,
374: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
375: BEGIN
376: IF PG_DEBUG in ('Y', 'C') THEN
369: --
370: PROCEDURE nowaitlock_fetch_pk(
371: p_source_id IN ar_distributions.source_id%TYPE,
372: p_source_table IN ar_distributions.source_table%TYPE,
373: p_source_type IN ar_distributions.source_type%TYPE,
374: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
375: BEGIN
376: IF PG_DEBUG in ('Y', 'C') THEN
377: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
370: PROCEDURE nowaitlock_fetch_pk(
371: p_source_id IN ar_distributions.source_id%TYPE,
372: p_source_table IN ar_distributions.source_table%TYPE,
373: p_source_type IN ar_distributions.source_type%TYPE,
374: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
375: BEGIN
376: IF PG_DEBUG in ('Y', 'C') THEN
377: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
378: END IF;
377: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
378: END IF;
379: SELECT *
380: INTO p_dist_rec
381: FROM ar_distributions
382: WHERE source_id = p_source_id
383: AND source_table = p_source_table
384: AND source_type = p_source_type
385: FOR UPDATE OF line_id NOWAIT;