lunes, 25 de junio de 2012

Script - Generación de fechas mediante función PIPELINED

Función para la generación dinámica de fechas/horas con parámetros: fecha_inicio, fecha_fin, intervalo (en minutos):

CREATE OR REPLACE TYPE "SYSTEM"."DATE_LIST" is table of date;

CREATE OR REPLACE FUNCTION "SYSTEM"."PIPE_DATE_INTERVAL" (p_start date,p_end date, p_inc number)
return date_list pipelined is
v_intervalos number;
begin
v_intervalos:=(p_end-p_start)*24*60/p_inc;
for i in 0 ..v_intervalos-1 loop
pipe row (p_start +p_inc*i/(24*60));
end loop;
return;
end;


-- Ejemplo:

select column_value from table(system.pipe_date_interval(trunc(sysdate), sysdate,30));

Generaría una lista como la siguiente:

COLUMN_VALUE
-------------------
25/06/2012 00:00:00
25/06/2012 00:30:00
25/06/2012 01:00:00
25/06/2012 01:30:00
25/06/2012 02:00:00
25/06/2012 02:30:00
25/06/2012 03:00:00
25/06/2012 03:30:00
25/06/2012 04:00:00
25/06/2012 04:30:00
25/06/2012 05:00:00
25/06/2012 05:30:00
25/06/2012 06:00:00
25/06/2012 06:30:00
25/06/2012 07:00:00
25/06/2012 07:30:00

lunes, 18 de junio de 2012

Script - Traspaso de estadísticas Oracle entre esquemas

Script para el traspaso de estadísticas Oralce entre dos esquemas de distintas bases de datos, se supone existe una tabla intermedia llamadas "CONEXIONES" ubicada en una base de datos central "DB_CENTRAL" donde se almacenan todas los usuarios y passwords de nuestro pool de bases de datos.

El script va pidiendo el esquema de origen y destino, base de datos de origen y destino.

column FECHA new_value FECHA

select
  TO_CHAR(SYSDATE,'YYYYMMDD')   FECHA
from
  DUAL
/

host mkdir &FECHA

WHENEVER SQLERROR CONTINUE
WHENEVER OSERROR CONTINUE

set serveroutput on size 1000000
set termout on
set verify off
set feedback off
set echo off
set heading off
set pagesize 0
set pause off
set wrap on
set line 500
column lanza format a1000


conn usuario/"password"@DB_CENTRAL

define conexion_orig = ""
define conexion_dest = ""
column conexion_orig format a60 new_value Conexion_orig
column conexion_dest format a60 new_value Conexion_dest
COLUMN cadena_conexion format a60
COLUMN comentarios format a50


-- Esquemas a capturar/volcar estadísticas
accept esquema_orig_stats char prompt 'Filtro de esquema ORIGEN a capturar estadísticas: '
accept esquema_dest_stats char prompt 'Filtro de esquema DESTINO a capturar estadísticas: '

-- Mostramos las conexiones origen
accept cadena_orig char prompt 'Filtro de cadena de conexión ORIGEN (usuario SYSTEM): '

select conn_id, trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as cadena_conexion , SUBSTR(COMENTARIOS,1,50) comentarios
from
    CONEXIONES
where
    upper(usuario) like '%'||UPPER('SYSTEM')||'%' and
    upper(cadena) like '%'||UPPER('&cadena_orig')||'%' and
    (UPPER(comentarios) not like 'NO DISPONIBLE%'  AND
    UPPER(comentarios) not like 'ELIMINA%' OR
    COMENTARIOS IS NULL)
order by comentarios, trim(cadena), trim(usuario)
/

accept conn_id_orig number prompt 'Introduzca el id de la conexión ORIGEN: ';

-- Mostramos las conexiones destino
accept cadena_dest char prompt 'Filtro de cadena de conexión DESTINO (usuario SYSTEM): '

select conn_id, trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as cadena_conexion , SUBSTR(COMENTARIOS,1,50) comentarios
from
    CONEXIONES
where
    upper(usuario) like '%'||UPPER('SYSTEM')||'%' and
    upper(cadena) like '%'||UPPER('&cadena_dest')||'%' and
    (UPPER(comentarios) not like 'NO DISPONIBLE%'  AND
    UPPER(comentarios) not like 'ELIMINA%' OR
    COMENTARIOS IS NULL)
order by comentarios, trim(cadena), trim(usuario)
/

accept conn_id_dest number prompt 'Introduzca el id de la conexión DESTINO: ';

spool &FECHA\copy_stats.sql
select 'copy from '||v_from.cadena_conexion||' to '||v_to.cadena_conexion||' append &esquema_dest_stats..STATS_TABLE using SELECT * from &esquema_orig_stats..STATS_TABLE'
from
    (select conn_id, trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as cadena_conexion
    from
        CONEXIONES
    where
        conn_id=&conn_id_orig
    order by conn_id) v_from,
    (select conn_id, trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as cadena_conexion
    from
        CONEXIONES
    where
        conn_id=&conn_id_dest
    order by conn_id) v_to   
/
spool off;


-- Generamos las cadenas de conexión a origen y destino

select trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as conexion_orig
from CONEXIONES
where
    conn_id=decode(nvl(&conn_id_orig,98),0,98,nvl(&conn_id_orig,98))
/
select trim(usuario)||'/"'||trim(passw)||'"@'||trim(cadena) as conexion_dest
from CONEXIONES
where
    conn_id=decode(nvl(&conn_id_dest,98),0,98,nvl(&conn_id_dest,98))
/
-- Conexion a ORIGEN
conn &conexion_orig

-- Borrado, creación y captura de stadisticas
exec DBMS_STATS.DROP_STAT_TABLE('&esquema_orig_stats','STATS_TABLE');
EXEC DBMS_STATS.CREATE_STAT_TABLE('&esquema_orig_stats' , 'STATS_TABLE');
EXEC DBMS_STATS.EXPORT_SCHEMA_STATS('&esquema_orig_stats', 'STATS_TABLE', NULL, '&esquema_orig_stats');


-- Conexion a DESTINO
conn &conexion_dest
-- Borrado, creación de tabla de estadísticas
exec DBMS_STATS.DROP_STAT_TABLE('&esquema_dest_stats','STATS_TABLE');
EXEC DBMS_STATS.CREATE_STAT_TABLE('&esquema_dest_stats' , 'STATS_TABLE');

-- Copia de estadísticas
@&FECHA\copy_stats.sql

-- Depuramos las estadísticas cargadas
DELETE FROM &esquema_dest_stats..STATS_TABLE WHERE (C1,C4,C5) IN
(SELECT A.C1, A.C4, A.C5
FROM
    &esquema_dest_stats..STATS_TABLE A,
    DBA_TAB_COLUMNS B
WHERE
    A.C1=B.TABLE_NAME(+) AND
    A.C4=B.COLUMN_NAME(+) AND
    A.C5=B.OWNER(+) AND
    B.TABLE_NAME IS NULL);
COMMIT;

exec DBMS_STATS.IMPORT_SCHEMA_STATS('&esquema_dest_stats', 'STATS_TABLE', NULL, '&esquema_dest_stats');


martes, 5 de junio de 2012

Script - Control de Sesiones en base a Planes de Ejecución

Script para el control de sesiones activas en base a métodos de acceso en sus planes de ejecución.

En el ejemplo: Sesiones activas por más de 1 hora con MERGE JOIN CARTESIAN, el control en este caso consiste en cerrar la sesión mediante un kill immediate.

declare
cursor sql_id is
select l.sql_id from V$session l, v$sql s where SUBSTR(l.STATUS,1,10) LIKE 'ACTIV%' and
            l.sql_id is not null and
            l.username is not null and
            l.sql_id=s.sql_id and
            -- CPU_TIME > 1 hora
            s.cpu_time > (3600)*1000000 ;
v_ind number;
v_mata varchar2(1000);
begin
v_ind:=0;
for v_reg in sql_id
loop
    selecT COUNT(1) INTO v_ind
    FROM TABLE(DBMS_XPLAN.DISPLAY_cursor(v_reg.sql_id,null)) where plan_table_output like '%MERGE JOIN CARTESIAN%';
    if v_ind > 0 then
        select 'ALTER SYSTEM KILL SESSION '''||    L.SID||','||SUBSTR(TO_CHAR(L.SERIAL#),1,8)||''' immediate' into v_mata FROM V$SESSION L WHERE  L.sql_id=v_reg.sql_id and l.username is not null;
        execute immediate v_mata;
    end if;
    v_ind:=0;
end loop;
exception
    when others then null;
end;
/

lunes, 4 de junio de 2012

Script - Reescritura de Sentencias

Script para reescribir sentencias mediante el uso del paquete DBMS_ADVANCED_REWRITE.

exec sys.dbms_advanced_rewrite.drop_rewrite_equivalence('ejemplo');
exec sys.dbms_advanced_rewrite.declare_rewrite_equivalence ( -
name => 'ejemplo', -
source_stmt=> q'[select columna1, columna2 from tablaA where columna1 like 'ABCD%' ]', -
destination_stmt=> q'[select columna1, columna2 from tablaB where columna3 = 'ABCD' ]', -
validate       => false, -
rewrite_mode=>'TEXT_MATCH');

Vista donde podemos ver la equivalencia creada: DBA_REWRITE_EQUIVALENCES

ALTER SESSION SET QUERY_REWRITE_ENABLED=FORCE;
ALTER SESSION SET QUERY_REWRITE_INTEGRITY=TRUSTED;

Así cuando ejecutemos :

select columna1, columna2 from tablaA where columna1 like 'ABCD%'

Realmente se ejecutará:

select columna1, columna2 from tablaB where columna3 = 'ABCD'

Útil para situaciones en las que no se puede modificar el código de la aplicación, y el resto de opciones no fuciona (SQL_profiles, hints, parámetros, etc).

IMPORTANTE: No admite el uso de variables BIND, por lo que su ámbito de actuación está limitado a sentencias que no hacen uso de variables bind.