package body ted_http is
c_https_wallet_path constant varchar2(4000) := '/home/oracle';
c_http_version constant varchar2(100) := utl_http.http_version_1_1;
c_data_type constant varchar2(100) := 'text/html;charset=UTF-8';
c_timeout constant pls_integer := 5;
c_user_agent constant varchar2(100) := 'Fiddler';
function clob_to_blob
( p_clob in clob
)
return blob
is
v_blob blob := utl_raw.cast_to_raw('x'); v_dest_offsset integer := 1;
v_src_offsset integer := 1;
v_lang_context integer := dbms_lob.default_lang_ctx;
v_warning integer;
begin
if p_clob is not null then
dbms_lob.converttoblob
( dest_lob => v_blob
, src_clob => p_clob
, amount => dbms_lob.lobmaxsize
, dest_offset => v_dest_offsset
, src_offset => v_src_offsset
, blob_csid => dbms_lob.default_csid
, lang_context => v_lang_context
, warning => v_warning
)
;
return v_blob;
else
return null;
end if;
exception
when others then
raise_application_error(-20000,sqlerrm);
end clob_to_blob;
function clob_length_in_bytes
( p_clob in clob
)
return number
is
v_blob blob := utl_raw.cast_to_raw('x'); v_result number;
begin
if p_clob is not null then
v_blob := clob_to_blob(p_clob);
v_result := dbms_lob.getlength(v_blob);
return v_result;
else
return null;
end if;
exception
when others then
raise_application_error(-20000,sqlerrm);
end clob_length_in_bytes;
function build_http_url
( p_username in varchar2
, p_password in varchar2
, p_domain in varchar2
, p_port in number
, p_path in varchar2
, p_query_string in varchar2
, p_anchor in varchar2
)
return varchar2
is
v_result varchar2(32000);
begin
v_result := '';
if p_username is not null and p_password is not null then
v_result := v_result || p_username || ':' || p_password || '@';
end if;
v_result := v_result || p_domain;
if p_port is not null then
v_result := v_result || ':' || trim(p_port);
end if;
if p_path is not null then
v_result := v_result || p_path;
end if;
if p_query_string is not null then
v_result := v_result || '?' || p_query_string;
end if;
if p_anchor is not null then
v_result := v_result || '#' || p_anchor;
end if;
return v_result;
exception
when others then
raise_application_error(-20000,sqlerrm);
end build_http_url;
procedure http_post
( p_url_in in varchar2
, p_post_or_get in varchar2
, p_http_or_https in varchar2
, p_data_in in clob
, p_data_type in varchar2 default null
, p_proxy_in in varchar2 default null
, p_no_proxy_domains_in in varchar2 default null
, p_username_in in varchar2 default null
, p_password_in in varchar2 default null
, o_http_status_code out varchar2
, o_http_reason_phrase out varchar2
, o_http_response_body out clob
)
is
v_http_req utl_http.req;
v_http_resp utl_http.resp;
begin
if upper(p_post_or_get) not in ('POST', 'GET') then raise_application_error(-20000,'p_post_or_get must be POST or GET');
end if;
case p_http_or_https
when 'http' then
null;
when 'https' then
utl_http.set_wallet('file:' || c_https_wallet_path); else
raise_application_error(-20000,'p_http_or_https must be http or https');
end case;
if p_proxy_in is not null then
utl_http.set_proxy(proxy => p_proxy_in, no_proxy_domains => p_no_proxy_domains_in);
end if;
utl_http.set_detailed_excp_support(enable => true);
utl_http.set_response_error_check(enable => false);
v_http_req := utl_http.begin_request(url => p_url_in, method => upper(p_post_or_get), http_version => c_http_version);
if p_username_in is not null then
utl_http.set_authentication(r => v_http_req, username => p_username_in, password => p_password_in);
end if;
utl_http.set_transfer_timeout ( timeout => c_timeout );
case upper(p_post_or_get)
when 'POST' then
utl_http.set_header(r => v_http_req, name => 'User-Agent' , value => c_user_agent);
utl_http.set_header(r => v_http_req, name => 'Content-Type' , value => nvl(p_data_type, c_data_type));
utl_http.set_header(r => v_http_req, name => 'Content-Length' , value => clob_length_in_bytes(p_clob => p_data_in));
declare
v_chunk_size pls_integer default 1000;
v_clob_chunk clob;
v_offset pls_integer default 1;
begin
loop
dbms_lob.read(p_data_in, v_chunk_size, v_offset, v_clob_chunk);
v_offset := v_offset + v_chunk_size;
utl_http.write_text(v_http_req, v_clob_chunk);
end loop;
exception
when no_data_found then null;
when others then raise;
end;
else
utl_http.set_header(r => v_http_req, name => 'User-Agent', value => c_user_agent);
end case;
v_http_resp := utl_http.get_response(v_http_req);
o_http_status_code := v_http_resp.status_code;
o_http_reason_phrase := v_http_resp.reason_phrase;
dbms_lob.createtemporary(o_http_response_body, true);
declare
v_clob_chunk clob := null;
begin
loop
utl_http.read_text(v_http_resp, v_clob_chunk);
dbms_lob.append(o_http_response_body, v_clob_chunk);
end loop;
exception
when utl_http.end_of_body then null;
end;
utl_http.end_response(v_http_resp);
exception
when others then
raise;
end http_post;
function ping
( p_host_name varchar2
, p_port number default 80
)
return varchar2
is
l_tcpconnection utl_tcp.connection;
begin
l_tcpconnection := utl_tcp.open_connection
( remote_host => p_host_name
, remote_port => p_port
)
;
utl_tcp.close_connection(l_tcpconnection);
return 'Y';
exception
when utl_tcp.network_error then
dbms_output.put_line(sqlerrm);
if lower(sqlerrm) like '%does not exist%' then
return 'N';
elsif lower(sqlerrm) like '%operation timed out%' then
return 'Y';
elsif lower(sqlerrm) like '%listener%' then
return 'Y';
else
raise;
end if;
when others then
raise;
end ping;
end ted_http;