DBA Data[Home] [Help]

APPS.JTF_FM_IH_LOGGER_PVT dependencies on DBMS_LOB

Line 93: blb_length := DBMS_LOB.GETLENGTH(CLOBSTR);

89:
90:
91: BEGIN
92: amt := 50;
93: blb_length := DBMS_LOB.GETLENGTH(CLOBSTR);
94: len := 1;
95: pos := 1;
96:
97:

Line 103: dbms_lob.read(CLOBSTR, amt, len, buf);

99:
100:
101: while (len < blb_length) loop
102:
103: dbms_lob.read(CLOBSTR, amt, len, buf);
104: DBMS_OUTPUT.PUT_line(buf);
105: len := len + amt;
106:
107: end loop;

Line 297: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);

293: raise RESOURCE_NOT_FOUND_EXCEPTION;
294: end if;
295:
296: if ((upper(l_log_interaction) = 'YES') AND (l_return_status = FND_API.G_RET_STS_SUCCESS ))then
297: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);
298: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);
299:
300: --Header
301: l_interaction := ADD_HEADER(l_header_rec.HIST_REQ_ID);

Line 298: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);

294: end if;
295:
296: if ((upper(l_log_interaction) = 'YES') AND (l_return_status = FND_API.G_RET_STS_SUCCESS ))then
297: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);
298: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);
299:
300: --Header
301: l_interaction := ADD_HEADER(l_header_rec.HIST_REQ_ID);
302:

Line 344: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);

340: l_interaction := l_interaction || 'mediaitem_identifier=' || l_quote ||l_MediaItem_Identifier|| l_quote || l_spacechar || 'address=' || l_quote ||j.EMAIL_ADDRESS|| l_quote || '>';
341: l_interaction := l_interaction || FND_GLOBAL.Local_Chr(10) ||'';
342: l_interaction := l_interaction || FND_GLOBAL.Local_Chr(10) ||'';
343:
344: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);
345: l_interaction :='';
346:
347: l_counter := l_counter + 1;
348:

Line 354: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);

350: if l_counter = TOTAL_INTERACTIONS THEN
351:
352: l_interaction := l_interaction || FND_GLOBAL.Local_Chr(10) ||'';
353:
354: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);
355: l_interaction :='';
356:
357: --Enqueue
358: JTF_IH_BULK_Q_PKG.CLOBENQUEUE(l_BulkWriterCode,l_BulkBatchType,l_header_rec.hist_req_id,l_request_line_id,l_mesg_id);

Line 360: DBMS_LOB.COPY(l_user_data.BulkInteractionRequest,l_interaction_clob, DBMS_LOB.GETLENGTH(l_interaction_clob) , 1,1);

356:
357: --Enqueue
358: JTF_IH_BULK_Q_PKG.CLOBENQUEUE(l_BulkWriterCode,l_BulkBatchType,l_header_rec.hist_req_id,l_request_line_id,l_mesg_id);
359: select user_data into l_user_data from jtf_ih_bulk_qtbl where msgid = hextoraw(l_mesg_id);
360: DBMS_LOB.COPY(l_user_data.BulkInteractionRequest,l_interaction_clob, DBMS_LOB.GETLENGTH(l_interaction_clob) , 1,1);
361: --commit;
362:
363: l_counter := 0;
364:

Line 369: DBMS_LOB.FREETEMPORARY (l_interaction_clob);

365: -- call header again on new request
366: l_interaction := ADD_HEADER(l_header_rec.HIST_REQ_ID);
367:
368: --release clob
369: DBMS_LOB.FREETEMPORARY (l_interaction_clob);
370:
371: --reinitialize clob
372: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);
373: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);

Line 372: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);

368: --release clob
369: DBMS_LOB.FREETEMPORARY (l_interaction_clob);
370:
371: --reinitialize clob
372: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);
373: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);
374:
375: end if;
376:

Line 373: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);

369: DBMS_LOB.FREETEMPORARY (l_interaction_clob);
370:
371: --reinitialize clob
372: dbms_lob.createtemporary(l_interaction_clob, TRUE,DBMS_LOB.SESSION);
373: dbms_lob.open(l_interaction_clob, dbms_lob.lob_readwrite);
374:
375: end if;
376:
377: end loop;

Line 389: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);

385: --Enqueue for interaction created from less than 1000 records
386: if l_counter < TOTAL_INTERACTIONS THEN
387:
388: l_interaction := l_interaction || FND_GLOBAL.Local_Chr(10) ||'';
389: dbms_lob.writeappend(l_interaction_clob, LENGTH(l_interaction), l_interaction);
390: l_interaction :='';
391:
392: --Enqueueu
393: JTF_IH_BULK_Q_PKG.CLOBENQUEUE(l_BulkWriterCode,l_BulkBatchType, l_header_rec.hist_req_id,l_request_line_id,l_mesg_id);

Line 396: DBMS_LOB.COPY(l_user_data.BulkInteractionRequest,l_interaction_clob, DBMS_LOB.GETLENGTH(l_interaction_clob) , 1,1);

392: --Enqueueu
393: JTF_IH_BULK_Q_PKG.CLOBENQUEUE(l_BulkWriterCode,l_BulkBatchType, l_header_rec.hist_req_id,l_request_line_id,l_mesg_id);
394: select user_data into l_user_data from jtf_ih_bulk_qtbl where msgid = hextoraw(l_mesg_id);
395:
396: DBMS_LOB.COPY(l_user_data.BulkInteractionRequest,l_interaction_clob, DBMS_LOB.GETLENGTH(l_interaction_clob) , 1,1);
397: --commit;
398:
399: end if;
400: