[Home] [Help]
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
57: arp_standard.debug( 'REF_MF_DIST_FLAG ' || p_dist_rec.ref_mf_dist_flag);
58: --HYU--}
59: END IF;
60:
61: INSERT INTO ar_distributions (
62: line_id,
63: source_id,
64: source_table,
65: source_type,
171: RAISE;
172: END insert_p;
173: --
174: PROCEDURE update_p(
175: p_dist_rec IN ar_distributions%ROWTYPE ) IS
176: BEGIN
177: IF PG_DEBUG in ('Y', 'C') THEN
178: arp_standard.debug( 'arp_distributions_pkg.update_p()+' );
179: END IF;
177: IF PG_DEBUG in ('Y', 'C') THEN
178: arp_standard.debug( 'arp_distributions_pkg.update_p()+' );
179: END IF;
180: --
181: UPDATE ar_distributions SET
182: source_id = p_dist_rec.source_id,
183: source_table = p_dist_rec.source_table,
184: source_type = p_dist_rec.source_type,
185: source_type_secondary = p_dist_rec.source_type_secondary,
235: RAISE;
236: END update_p;
237: --
238: PROCEDURE delete_p(
239: p_line_id IN ar_distributions.line_id%TYPE ) IS
240: BEGIN
241: IF PG_DEBUG in ('Y', 'C') THEN
242: arp_standard.debug( 'arp_distributions_pkg.delete_p()+' );
243: END IF;
241: IF PG_DEBUG in ('Y', 'C') THEN
242: arp_standard.debug( 'arp_distributions_pkg.delete_p()+' );
243: END IF;
244: --
245: DELETE FROM ar_distributions
246: WHERE line_id = p_line_id;
247: --
248: IF PG_DEBUG in ('Y', 'C') THEN
249: arp_standard.debug( 'arp_distributions_pkg.delete_p()-' );
256: RAISE;
257: END delete_p;
258: --
259: PROCEDURE lock_p(
260: p_line_id IN ar_distributions.line_id%TYPE ) IS
261: l_line_id ar_distributions.line_id%TYPE;
262: BEGIN
263: IF PG_DEBUG in ('Y', 'C') THEN
264: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
257: END delete_p;
258: --
259: PROCEDURE lock_p(
260: p_line_id IN ar_distributions.line_id%TYPE ) IS
261: l_line_id ar_distributions.line_id%TYPE;
262: BEGIN
263: IF PG_DEBUG in ('Y', 'C') THEN
264: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
265: END IF;
264: arp_standard.debug( 'arp_distributions_pkg.lock_p()+' );
265: END IF;
266: SELECT line_id
267: INTO l_line_id
268: FROM ar_distributions
269: WHERE line_id = p_line_id
270: FOR UPDATE OF line_id;
271: --
272: IF PG_DEBUG in ('Y', 'C') THEN
280: RAISE;
281: END lock_p;
282: --
283: PROCEDURE fetch_p(
284: p_line_id IN ar_distributions.line_id%TYPE,
285: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
286: BEGIN
287: IF PG_DEBUG in ('Y', 'C') THEN
288: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
281: END lock_p;
282: --
283: PROCEDURE fetch_p(
284: p_line_id IN ar_distributions.line_id%TYPE,
285: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
286: BEGIN
287: IF PG_DEBUG in ('Y', 'C') THEN
288: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
289: END IF;
288: arp_standard.debug( 'arp_distributions_pkg.fetch_p()+' );
289: END IF;
290: SELECT *
291: INTO p_dist_rec
292: FROM ar_distributions
293: WHERE line_id = p_line_id;
294: IF PG_DEBUG in ('Y', 'C') THEN
295: arp_standard.debug( 'arp_distributions_pkg.fetch_p()-' );
296: END IF;
304: RAISE;
305: END fetch_p;
306: --
307: PROCEDURE fetch_pk(
308: p_source_id IN ar_distributions.source_id%TYPE,
309: p_source_table IN ar_distributions.source_table%TYPE,
310: p_source_type IN ar_distributions.source_type%TYPE,
311: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
312: BEGIN
305: END fetch_p;
306: --
307: PROCEDURE fetch_pk(
308: p_source_id IN ar_distributions.source_id%TYPE,
309: p_source_table IN ar_distributions.source_table%TYPE,
310: p_source_type IN ar_distributions.source_type%TYPE,
311: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
312: BEGIN
313: IF PG_DEBUG in ('Y', 'C') THEN
306: --
307: PROCEDURE fetch_pk(
308: p_source_id IN ar_distributions.source_id%TYPE,
309: p_source_table IN ar_distributions.source_table%TYPE,
310: p_source_type IN ar_distributions.source_type%TYPE,
311: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
312: BEGIN
313: IF PG_DEBUG in ('Y', 'C') THEN
314: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
307: PROCEDURE fetch_pk(
308: p_source_id IN ar_distributions.source_id%TYPE,
309: p_source_table IN ar_distributions.source_table%TYPE,
310: p_source_type IN ar_distributions.source_type%TYPE,
311: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
312: BEGIN
313: IF PG_DEBUG in ('Y', 'C') THEN
314: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
315: END IF;
314: arp_standard.debug( 'arp_distributions_pkg.fetch_pk()+' );
315: END IF;
316: SELECT *
317: INTO p_dist_rec
318: FROM ar_distributions
319: WHERE source_id = p_source_id
320: AND source_table = p_source_table
321: AND source_type = p_source_type;
322: IF PG_DEBUG in ('Y', 'C') THEN
332: RAISE;
333: END fetch_pk;
334: --
335: PROCEDURE lock_fetch_pk(
336: p_source_id IN ar_distributions.source_id%TYPE,
337: p_source_table IN ar_distributions.source_table%TYPE,
338: p_source_type IN ar_distributions.source_type%TYPE,
339: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
340: BEGIN
333: END fetch_pk;
334: --
335: PROCEDURE lock_fetch_pk(
336: p_source_id IN ar_distributions.source_id%TYPE,
337: p_source_table IN ar_distributions.source_table%TYPE,
338: p_source_type IN ar_distributions.source_type%TYPE,
339: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
340: BEGIN
341: IF PG_DEBUG in ('Y', 'C') THEN
334: --
335: PROCEDURE lock_fetch_pk(
336: p_source_id IN ar_distributions.source_id%TYPE,
337: p_source_table IN ar_distributions.source_table%TYPE,
338: p_source_type IN ar_distributions.source_type%TYPE,
339: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
340: BEGIN
341: IF PG_DEBUG in ('Y', 'C') THEN
342: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
335: PROCEDURE lock_fetch_pk(
336: p_source_id IN ar_distributions.source_id%TYPE,
337: p_source_table IN ar_distributions.source_table%TYPE,
338: p_source_type IN ar_distributions.source_type%TYPE,
339: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
340: BEGIN
341: IF PG_DEBUG in ('Y', 'C') THEN
342: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
343: END IF;
342: arp_standard.debug( 'arp_distributions_pkg.lock_fetch_pk()+' );
343: END IF;
344: SELECT *
345: INTO p_dist_rec
346: FROM ar_distributions
347: WHERE source_id = p_source_id
348: AND source_table = p_source_table
349: AND source_type = p_source_type
350: FOR UPDATE OF line_id;
362: RAISE;
363: END lock_fetch_pk;
364: --
365: PROCEDURE nowaitlock_fetch_pk(
366: p_source_id IN ar_distributions.source_id%TYPE,
367: p_source_table IN ar_distributions.source_table%TYPE,
368: p_source_type IN ar_distributions.source_type%TYPE,
369: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
370: BEGIN
363: END lock_fetch_pk;
364: --
365: PROCEDURE nowaitlock_fetch_pk(
366: p_source_id IN ar_distributions.source_id%TYPE,
367: p_source_table IN ar_distributions.source_table%TYPE,
368: p_source_type IN ar_distributions.source_type%TYPE,
369: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
370: BEGIN
371: IF PG_DEBUG in ('Y', 'C') THEN
364: --
365: PROCEDURE nowaitlock_fetch_pk(
366: p_source_id IN ar_distributions.source_id%TYPE,
367: p_source_table IN ar_distributions.source_table%TYPE,
368: p_source_type IN ar_distributions.source_type%TYPE,
369: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
370: BEGIN
371: IF PG_DEBUG in ('Y', 'C') THEN
372: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
365: PROCEDURE nowaitlock_fetch_pk(
366: p_source_id IN ar_distributions.source_id%TYPE,
367: p_source_table IN ar_distributions.source_table%TYPE,
368: p_source_type IN ar_distributions.source_type%TYPE,
369: p_dist_rec OUT NOCOPY ar_distributions%ROWTYPE ) IS
370: BEGIN
371: IF PG_DEBUG in ('Y', 'C') THEN
372: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
373: END IF;
372: arp_standard.debug( 'arp_distributions_pkg.nowaitlock_fetch_pk()+' );
373: END IF;
374: SELECT *
375: INTO p_dist_rec
376: FROM ar_distributions
377: WHERE source_id = p_source_id
378: AND source_table = p_source_table
379: AND source_type = p_source_type
380: FOR UPDATE OF line_id NOWAIT;