FUNCTION PIPELINED RETURN SET OF ROWS

Version imprimable

Bonjour,
Je souhait écrire une fonction qui me retourne une table d'un type que j'ai défini moi même.
j'ai cette erreur

Citation:

PLS-00302: le composant 'ID_GR' doit être déclaré.
PLS-00328: expression du mauvais type

ou ID_GR est la première colonne de mon type 'data_groupe'

Code:

1
2
3
4
5
6
7
8
9
CREATE TYPE data_groupe AS OBJECT
(
    id_gr NUMBER,
    lib_gr VARCHAR2(50),
    id_descri NUMBER,
    lib_descri VARCHAR2(50),
    id_br NUMBER,
    seuil_br DOUBLE PRECISION
    );

Code:

CREATE TYPE table_data_groupe AS TABLE OF data_groupe;

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
CREATE OR REPLACE FUNCTION get_data_groupe (id_prod IN NUMBER)
   RETURN table_data_groupe
   PIPELINED
IS
 
   out_rec    table_data_groupe
                 := table_data_groupe (NULL,
                                       NULL,
                                       NULL,
                                       NULL,
                                       NULL,
                                       NULL);
    CURSOR l_cursor IS
        SELECT g.id as id_gr,
               g.libelle as lib_gr,
               d.id as id_descri,
               d.nom as lib_descri,
               b.id as id_br,
               b.seuil_bareme as seuil_br
          FROM pnp_fournisseur f,
               pnp_entrepot e,
               pnp_produit p,
               pnp_composition_groupe cg,
               pnp_groupe g,
               pnp_groupe_descripteur gd,
               pnp_descripteur d,
               pnp_descripteur_bareme db,
               pnp_bareme b
         WHERE     p.id = id_prod
               AND f.id = cg.id_fournisseur
               AND e.id = cg.id_entrepot
               AND p.id = cg.id_produit
               AND cg.id_groupe = g.id
               AND g.id = gd.id_groupe
               AND gd.id_descripteur = d.id
               AND d.id = db.id_descripteur
               AND db.id_bareme = b.id;                                   
BEGIN
   OPEN l_cursor;        
      LOOP
        FETCH l_cursor INTO
 
            out_rec.id_gr, 
            out_rec.lib_gr,
            out_rec.id_descri,
            out_rec.lib_descri,
            out_rec.id_br,
            out_rec.seuil_br;       
        EXIT WHEN l_cursor%NOTFOUND;
        PIPE ROW(out_rec);
    END LOOP;
 
CLOSE l_cursor;
RETURN;
END;

Bonjour,

Voici un exemple :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
DROP FUNCTION func_pipelined_test;
DROP TYPE array_record_test;
DROP TYPE record_test;
 
CREATE TYPE record_test AS OBJECT ( ID_REC NUMBER
                                   ,VALUE_REC VARCHAR2(50)
                                  );
 
CREATE TYPE array_record_test AS TABLE OF record_test;
 
CREATE OR REPLACE FUNCTION func_pipelined_test 
RETURN array_record_test PIPELINED
IS
 
out_record_test array_record_test := array_record_test() ;
 
CURSOR cur_test
IS
       SELECT 1 AS ID_REC,'value 1' AS VALUE_REC FROM DUAL UNION ALL
       SELECT 2,'value 2' FROM DUAL UNION ALL
       SELECT 3,'value 3' FROM DUAL
;
 
TYPE array_test IS TABLE OF cur_test%ROWTYPE INDEX BY BINARY_INTEGER;
 
in_record_test array_test;
 
BEGIN
 
  OPEN cur_test;
  LOOP
     FETCH cur_test BULK COLLECT INTO in_record_test;              
       FOR i IN 1 .. in_record_test.COUNT
       LOOP                                    
           out_record_test.EXTEND;                        
           out_record_test(out_record_test.last) := record_test(in_record_test(i).ID_REC
                                                                ,in_record_test(i).VALUE_REC);             
           PIPE ROW(out_record_test(out_record_test.last));
       END LOOP;       
     EXIT WHEN cur_test%NOTFOUND;
  END LOOP;
  CLOSE cur_test;
 
RETURN;
EXCEPTION
       WHEN OTHERS THEN
       IF cur_test%ISOPEN THEN
          CLOSE cur_test;
       END IF;       
       RETURN;
END;
 
 
select * from TABLE(func_pipelined_test);

ligne 7, c'est le record qu'il faudrait initialiser.

Sinon, préfère les FOR LOOP, plus simples à coder/debuguer.
J'utilise les fonctions pipelined comme ceci :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
CREATE OR REPLACE FUNCTION get_data_groupe (id_prod IN NUMBER)
   RETURN table_data_groupe
   PIPELINED
IS
    CURSOR l_cursor IS
        SELECT g.ID AS id_gr, g.libelle AS lib_gr,
        				d.ID AS id_descri, d.nom AS lib_descri, 
               b.ID AS id_br, b.seuil_bareme AS seuil_br
        FROM pnp_fournisseur f,
               pnp_entrepot e,
               pnp_produit p,
               pnp_composition_groupe cg,
               pnp_groupe g,
               pnp_groupe_descripteur gd,
               pnp_descripteur d,
               pnp_descripteur_bareme db,
               pnp_bareme b
         WHERE     p.ID = id_prod
               AND f.ID = cg.id_fournisseur
               AND e.ID = cg.id_entrepot
               AND p.ID = cg.id_produit
               AND cg.id_groupe = g.ID
               AND g.ID = gd.id_groupe
               AND gd.id_descripteur = d.ID
               AND d.ID = db.id_descripteur
               AND db.id_bareme = b.ID;                                   
BEGIN
   FOR r IN l_cursor;        
   LOOP
      PIPE ROW( DATA_GROUPE(r.id_gr, r.lib_gr, r.id_descri, r.lib_descri, r.id_br, r.seuil_br);
   END LOOP;
 	RETURN;
END;

03/08/2011, 11h03
cpu64

Bonjour,
Merci pour vos réponses. J'ai opté pour la solution de McM.