dbo.QBM_PDBQueuePondEnd

1 create   procedure QBM_PDBQueuePondEnd (@PondGroup varchar(38) ) as begin declare @TaskDefs QBM_YCursorBuffer declare @ElementCount int declare
2 @ElementIndex int declare @UID_Task varchar(38)    declare @PondGroupNew varchar(38) = @PondGroup declare @AnzahlPondGesamt bigint = dbo.QBM_FGITableCountAll
3('QBMDBQueuePond') declare @DebugSwitch int = 0 SET XACT_ABORT OFF BEGIN TRY     if @DebugSwitch > 0 begin print dbo.QBM_FCVDatetimeToString(GETUTCDATE
4()) + ' Anfang ' end if @AnzahlPondGesamt > 2500000 or exists ( select top 1 1 from ( select p.PondGroup, COUNT(*) as Anzahl, COUNT(distinct checksum(p.UID_Task
5 , isnull(p.Object, '') , isnull(p.SubObject, ''))) as AnzahlDistinct from QBMDBQueuePond p where p.PondGroup = @PondGroup  group by p.PondGroup ) as x
6 where x.AnzahlDistinct * 5 < x.Anzahl or x.Anzahl > 500000 ) begin if @DebugSwitch > 0 begin print 'wir verdichten' end select @PondGroupNew = NEWID()
7  insert into QBMDBQueuePond(UID_Task, Object, SubObject, GenProcID  , PondGroup, InsertDate) select UID_Task, Object , SubObject , max(GenProcID) as GenProcID
8  , @PondGroupNew as PondGroup, MAX(InsertDate) as InsertDate from QBMDBQueuePond p where p.PondGroup = @PondGroup  group by p.UID_Task, p.Object , p.SubObject
9 end insert into @TaskDefs (UID1) select x.UID_Task from ( select distinct t.UID_Task from QBMDBQueuePond t where t.PondGroup = @PondGroupNew  ) as x join
10 QBMDBQueueTaskMetric mo on x.UID_Task = mo.UID_Task order by mo.PathLength desc select @ElementCount = @@ROWCOUNT select @ElementIndex = 1     while @ElementIndex
11 <= @ElementCount begin select top 1 @UID_Task = bu.UID1       from @TaskDefs bu where bu.ElementIndex = @ElementIndex if @DebugSwitch > 0 begin print 
12dbo.QBM_FCVDatetimeToString(GETUTCDATE()) + ' Task ' + @UID_Task end exec QBM_P40B0C8AE71E45BA9C883A96_ @PondGroupNew , @UID_Task select @ElementIndex 
13+= 1 end     if @DebugSwitch > 0 begin print dbo.QBM_FCVDatetimeToString(GETUTCDATE()) + ' Kennzeichnen ' + @PondGroupNew end update QBMDBQueuePond set
14 GenProcID = 'DELETE' where PondGroup = @PondGroupNew if @PondGroup <> @PondGroupNew begin if @DebugSwitch > 0 begin print dbo.QBM_FCVDatetimeToString(GETUTCDATE
15()) + ' Kennzeichnen ' + @PondGroup end update QBMDBQueuePond set GenProcID = 'DELETE' where PondGroup = @PondGroup end END TRY BEGIN CATCH exec QBM_PSessionErrorAdd
16 default RAISERROR ('', 18, 1) WITH NOWAIT END CATCH endLabel: if @DebugSwitch > 0 begin print dbo.QBM_FCVDatetimeToString(GETUTCDATE()) + ' ferdsch ' 
17end return end 
18