写了一个聚合函数， 将字符串连接起来

blue_stone

1. 
   
2.       create or replace type connstrImpl as object
   
3.       (
   
4.         currentstr varchar2(4000),
   
5.         currentseprator varchar2(8),
   
6.         static function ODCIAggregateInitialize(sctx IN OUT connstrImpl)
   
7.           return number,
   
8.         member function ODCIAggregateIterate(self IN OUT connstrImpl,
   
9.           value IN VARCHAR2) return number,
   
10.         member function ODCIAggregateTerminate(self IN connstrImpl,
    
11.           returnValue OUT VARCHAR2, flags IN number) return number,
    
12.         member function ODCIAggregateMerge(self IN OUT connstrImpl,
    
13.           ctx2 IN connstrImpl) return number
    
14.       );
    
15.       /
    
16. 
    
17. 
    
18.       create or replace type body connstrImpl is
    
19.       static function ODCIAggregateInitialize(sctx IN OUT connstrImpl)
    
20.       return number is
    
21.       begin
    
22.         sctx := connstrImpl('','/');
    
23.         return ODCIConst.Success;
    
24.       end;
    
25.       member function ODCIAggregateIterate(self IN OUT connstrImpl, value IN VARCHAR2) return number is
    
26.       begin
    
27.         if self.currentstr is null then
    
28.           self.currentstr := value;
    
29.         else
    
30.           self.currentstr := self.currentstr ||currentseprator || value;
    
31.         end if;
    
32.         return ODCIConst.Success;
    
33.       end;
    
34.       member function ODCIAggregateTerminate(self IN connstrImpl, returnValue OUT VARCHAR2, flags IN number) return number is
    
35.       begin
    
36.         returnValue := self.currentstr;
    
37.         return ODCIConst.Success;
    
38.       end;
    
39.       member function ODCIAggregateMerge(self IN OUT connstrImpl, ctx2 IN connstrImpl) return number is
    
40.       begin
    
41.         if ctx2.currentstr is null then
    
42.           self.currentstr := self.currentstr;
    
43.         elsif self.currentstr is null then
    
44.           self.currentstr := ctx2.currentstr;
    
45.         else
    
46.           self.currentstr := self.currentstr || currentseprator || ctx2.currentstr;
    
47.         end if;
    
48.         return ODCIConst.Success;
    
49.       end;
    
50.       end;
    
51.       /
    
52. 
    
53. 
    
54. 
    
55.       CREATE OR REPLACE FUNCTION connstr (input VARCHAR2) RETURN VARCHAR2
    
56.       PARALLEL_ENABLE AGGREGATE USING connstrImpl;
    
57.       /
    

复制代码

使用示例如下:

1. 
   
2. SQL> select connstr(loc) from dept ;
   
3. 
   
4. CONNSTR(LOC)
   
5. --------------------------------------------------------------------------------
   
6. NEW YORK/DALLAS/CHICAGO/BOSTON
   
7. 
   
8. 
   

复制代码

参考了
Oracle® Data Cartridge Developer's Guide 10g Release 1 (10.1)  User-Defined Aggregate Functions