我的程序每天要读取200万至2000万条记录入库,入库的时间是由程序收到数据后决定的,程序收到的数据存在一个buf里,我需要把它解释出来入库,一般来说解释出来一个buf里估计含200条记录,我现在的做法是:
我在数据库中建立一个存储过程:ProIns,每次插入一条记录,同时记录是有主键的,如果存在相同的纪录,则不插入,过程如下: create or replace procedure ProIns (T_ID in varchar2,
P_D in varchar2) as
RecordNum Number; begin
select count(*) into RecordNum from table1 where TID = T_ID;
if RecordNum=0 then insert into table1 (TID,PD) values (T_ID,P_D); commit;
end if;
exception when others then
null; end ProIns;
/
然后我在程序中循环调用该存储过程,每次插入一条记录,这样就很慢,怎么样
提高入库性能呢?大概有以下几个特点:
1、无法保证入库的数据的唯一性;
2、数据入库时间不定;
3、一次接收到的buf中包含的纪录数不定;
4、表有关键字:t_id;
5、其他人可以在任意时候查询该表;象这种情况,怎样提高入库性能?谢谢
我在数据库中建立一个存储过程:ProIns,每次插入一条记录,同时记录是有主键的,如果存在相同的纪录,则不插入,过程如下: create or replace procedure ProIns (T_ID in varchar2,
P_D in varchar2) as
RecordNum Number; begin
select count(*) into RecordNum from table1 where TID = T_ID;
if RecordNum=0 then insert into table1 (TID,PD) values (T_ID,P_D); commit;
end if;
exception when others then
null; end ProIns;
/
然后我在程序中循环调用该存储过程,每次插入一条记录,这样就很慢,怎么样
提高入库性能呢?大概有以下几个特点:
1、无法保证入库的数据的唯一性;
2、数据入库时间不定;
3、一次接收到的buf中包含的纪录数不定;
4、表有关键字:t_id;
5、其他人可以在任意时候查询该表;象这种情况,怎样提高入库性能?谢谢
2.将你解析的数据(buffer里的)一次全部插入这个临时表table_temp
3.存储过程中改为
begin
insert into table1 (TID,PD)
select a.TID,a.PD from table_temp a
where not exists (select 'x' from
table1 b where a.TID = b.TID)
commit;
end;
/
以上只是个人想法没有经过测试,可遇见的是可以大量减少对于table1的INSERT操作
同时个人认为,效率低下主要还是调用Procedure过于频繁。
LZ可以考虑积累1~10万条,执行一次插入数据库操作。
另外,为了能够有效的减少select count(*)的次数,可以按照表的主键使用hash结构,保证准备插入数据库中的数据本身主键不会重复。
有索引的时候插入速度会明显下降,如果对日志要求不高可以使用direct-path插入,这样就不会写redo日志,可以极大的提升插入性能。
if RecordNum=0 then
insert into table1 (TID,PD) values (T_ID,P_D);
用这样的方法,造成频繁的访问,肯定要慢啊。
把连接的方法降低,速度肯定会变快的。
jdsnhan(柳荫凉) ( ) 信誉:100 Blog 加为好友 2007-5-1 10:56:39 得分: 0
select count(*) into RecordNum from table1 where TID = T_ID;
if RecordNum=0 then
insert into table1 (TID,PD) values (T_ID,P_D);
用这样的方法,造成频繁的访问,肯定要慢啊。
把连接的方法降低,速度肯定会变快的。
把连接的方法降低,速度肯定会变快的。 怎么降低呢?