ORACCLE 临时表

Posted by Vincent on February 24, 2010

Oracle临时表可以说是提高数据库处理性能的好方法,在没有必要存储时,只存储在Oracle临时表空间中。希望本文能对大家有所帮助。

1 、前言

目前所有使用 Oracle 作为数据库支撑平台的应用,大部分数据量比较庞大的系统,即表的数据量一般情况下都是在百万级以上的数据量。

当然在 Oracle 中创建分区是一种不错的选择,但是当你发现你的应用有多张表关联的时候,并且这些表大部分都是比较庞大,而你关联的时候发现 其中的某一张或者某几张表关联之后得到的结果集非常小并且查询得到这个结果集的速度非常快,那么这个时候我考虑在 Oracle 中创建“临时表”。

我对临时表的理解:在 Oracle 中创建一张表,这个表不用于其他的什么功能,主要用于自己的软件系统一些特有功能才用的,而当你用完之后表中 的数据就没用了。 Oracle 的临时表创建之后基本不占用表空间,如果你没有指定临时表(包括临时表的索引)存放的表空的时候,你插入到临时表的数据是存放在 ORACLE 系统的临时表空间中( TEMP )。

2 、临时表的创建

创建Oracle 临时表,可以有两种类型的临时表:

会话级的临时表

事务级的临时表 。

1) 会话级的临时表因为这这个临时表中的数据和你的当前会话有关系,当你当前SESSION 不退出的情况下,临时表中的数据就还存在,而当你退 出当前SESSION 的时候,临时表中的数据就全部没有了,当然这个时候你如果以另外一个SESSION 登陆的时候是看不到另外一个SESSION 中插入到临时表中的数据的。即两个不同的SESSION 所插入的数据是互不相干的。当某一个SESSION 退出之后临时表中的数据就被截断(truncate table ,即数据清空)了。会话级的临时表创建方法:

Create Global Temporary Table Table_Name

(Col1 Type1,Col2 Type2...) On Commit Preserve Rows ;

举例:

create global temporary table Student

(Stu_id Number(5),

Class_id Number(5),

Stu_Name Varchar2(8),

Stu_Memo varchar2(200)) on Commit Preserve Rows ;

2) 事务级临时表是指该临时表与事务相关,当进行事务提交或者事务回滚的时候,临时表中的数据将自行被截断,其他的内容和会话级的临时表的一致(包括退出 SESSION 的时候,事务级的临时表也会被自动截断)。事务级临时表的创建方法:

Create Global Temporary Table Table_Name

(Col1 Type1,Col2 Type2...) On Commit Delete Rows ;

举例:

create global temporary table Classes

(Class_id Number(5),

Class_Name Varchar2(8),

Class_Memo varchar2(200)) on Commit delete Rows ;

3) 两中类型临时表的区别

会话级临时表采用 on commit preserve rows ;而事务级则采用 on commit delete rows ;用法上,会话级别只有当会话结束临时表中的数据才会被截断,而且事务级临时表则不管是 commit 、 rollback 或者是会话结束,临时表中的数据都将被截断

4 )什么时候使用临时表

1 )、当某一个 SQL 语句关联的表在 2 张及以上,并且和一些小表关联。可以采用将大表进行分拆并且得到比较小的结果集合存放在临时表中

2 )、程序执行过程中可能需要存放一些临时的数据,这些数据在整个程序的会话过程中都需要用的等等。

3 . 例子:略

4 .临时表的不足之处

1 )不支持 lob 对象,这也许是设计者基于运行效率的考虑,但实际应用中确实需要此功能时就无法使用临时表了。

2 )不支持主外键关系

所以,由于以上原因,我们可以自己创建临时表,以弥补 oracle 临时表的不足之处

上面的都是本人经过测试的,但下面是在网上搜索到的方法,本人具体没有测试过,不过觉得可行性很强,有时间测试下。

创建方法:

1 、以常规表的形式创建临时数据表的表结构,但要在每一个表的主键中加入一个 SessionID 列以区分不同的会话。(可以有 lob 列和主外键)

2 、写一个用户注销触发器,在用户结束会话的时候删除本次会话所插入的所有记录 (SessionID 等于本次会话 ID 的记录 ) 。

3 、程序写入数据时,要顺便将当前的会话 ID(SessionID) 写入表中。

4 、程序读取数据时,只读取与当前会话 ID 相同的记录即可。

功能增强的扩展设计:

1 、可以在数据表上建立一个视图,视图对记录的筛选条件就是当前会话的SessionID 。

2 、数据表中的SessionID 列可以通过Trigger 实现,以实现对应用层的透明性。

3 、高级用户可以访问全局数据,以实现更加复杂的功能。

扩展临时表的优点:

1 、实现了与Oracle 的基于会话的临时表相同的功能。

2 、支持SDO_GEOMETRY 等lob 数据类型。

3 、支持表间的主外键连接,且主外键连接也是基于会话的。

4 、高级用户可以访问全局数据,以实现更加复杂的功能

--from:www.sucai.com/Tech/List4/20461.htm

基于临时表迁移历史数据

Create or Replace procedure sp_move_data(p_total number default 500000)
/*
作者:
时间:
目的:
*/
as
v_spname varchar2(30) := 'sp_move_data';
loopcount   integer; --循环次数
sumcount    integer; --符合条件的记录数
begcount    integer; --开始下标
endcount    integer; --结束下标
pagecount   integer; --每次移动条数
thiscount   number;
errormsg    varchar2(2000);
start_time  number;
end_time    number;
elapse_time number;
v_flag      number;
v_cnt       number; --统计每批迁移的数量

begin
--判断标识位,防止并发
select flag into v_flag
from tmp_mv_flag
where code = v_spname;

--如果flag = 0,说明没有别的进程在执行,本进程可以执行
if v_flag = 0 then
--更新flag,防止其它进程执行
update tmp_mv_flag
set flag = -2, gmt_modified = sysdate
where code = v_spname
and flag = 0;

commit;

--取出本次迁移需要的rowid,基于会话的临时表
--execute immediate 'truncate table tmp_mv_rids_sess';
insert into tmp_mv_rids_sess
(rid, rn)
select rid, rownum as rn
from (select /*+ index(x idx_move_data_table_04_fdate) */
rowid rid
from move_data_table_04_dbf x
where feedbackdate <= trunc(sysdate) - 180
order by feedbackdate)
where rownum <= p_total;

--本次需要迁移的记录总数
sumcount := sql%rowcount;
commit;

--每个事务迁100条记录
pagecount := 100;

--计算循环次数,并循环
loopcount := trunc(sumcount / pagecount) + 1;
for i in 1 .. loopcount
loop
--计算本批迁移记录的记录范围
begcount   := (i - 1) * pagecount + 1;
endcount   := i * pagecount;
start_time := dbms_utility.get_time;

--基于事务的临时表,用来保存本批迁移的rowid
--delete from tmp_mv_trans;

insert into tmp_mv_trans(rid)
select rid from tmp_mv_rids_sess t
where t.rn >= begcount
and t.rn <= endcount;

--迁数据到历史库的表
insert into his_md_table(id, rated_uid, ..)
select /*+ ordered use_nl(t f)*/
f.id, f.rated_uid, ...
from tmp_mv_trans t, move_data_table_04_dbf f
where t.rid = f.rowid
and f.feedbackdate <= trunc(sysdate) - 180;

v_cnt := sql%rowcount;

--从线上删除评价表记录
delete /*+ ordered use_nl(t) */
from move_data_table_04_dbf t
where rowid in
(select rid from tmp_mv_trans)
and t.feedbackdate <= trunc(sysdate) - 180;

--计算并记录本批迁移的记录数和花费的时间
end_time    := dbms_utility.get_time;
elapse_time := (end_time - start_time) / 100;

insert into tmp_time
(count_time, elapse_time, exec_time, exec_proc, exec_cnt, exec_tab)
values
(i, elapse_time, sysdate, v_spname, v_cnt, 'auction_feedbacks');
commit;

end loop;

--本次迁移完成,更新标识位
update tmp_mv_flag
set flag = 0, gmt_modified = sysdate
where code = v_spname;
commit;

execute immediate 'alter session close database link lnk_dbfb';
end if;
exception
when others then
rollback;

errormsg := sqlerrm;
insert into tmp_debug
(debug_id, error_msg, error_time)
values
(v_spname, errormsg, sysdate);

--执行完毕,解除锁
update tmp_mv_flag
set flag = 0, gmt_modified = sysdate
where code = v_spname;
commit;
manager.sp_write_alert(errormsg);
execute immediate 'alter session close database link lnk_dbfb';
end;
/

------涉及到表---------------

create table tmp_mv_flag(
CODE               VARCHAR2(32),
FLAG               NUMBER      ,
GMT_MODIFIED       DATE        );

create table  tmp_mv_rids_sess(
RID   VARCHAR2(32)
RN    NUMBER)
on Commit Preserve Rows ;

create index idx_fr_sess on tmp_mv_rids_sess(rn,rid);

create table tmp_mv_trans(
RID VARCHAR2(32)
)on Commit delete Rows ;


This work is licensed under a CC A-S 4.0 International License.