`

oracle 管道表函数2

阅读更多

     

 

 由于上一篇关于管道表函数写的有些粗糙,追加一篇,方便大家理解。两个函数完成管道表函数数据的初始化,所以设计到一个函数中调用另一个函数获取含数据部分。

      一下是完整代码:

     

     1:创建 row类型

 

     create or replace type subwhiteblack_row_type as object
       (
        spid number,
        spname varchar(200),
        whitegroupcount number,
        whitelistcount number,
        whiteaddedcount number,
        whitenoaddedcount number,
        whitedemandcount number,
        blackcoumt number
       )

   

    2:创建table类型

    

       create or replace type subwhiteblack_table_type as table of subwhiteblack_row_type

 

    3:创建获取row数据的function

    

    CREATE OR REPLACE FUNCTION GETSUBWHITEBLACKBYID
    (
      SPID IN NUMBER ,
      SPNAME IN VARCHAR
    )
    RETURN  SUBWHITEBLACK_ROW_TYPE
    AS
     WHITELISTTOTALCOUNT NUMBER;
     WHITEGROUPCOUNT NUMBER;
     WHITEADDEDCOUNT NUMBER;
     WHITENOADDEDCOUNT NUMBER;
     WHITEDEMANDCOUNT NUMBER;
     BLACKCOUNT NUMBER;
     RESULTCOUNT NUMBER;
     ISTABLEEXIST NUMBER ;
     BASESTRSQL VARCHAR(2000);
     STRSQL VARCHAR(2000);
     CONSTANTSTR VARCHAR(20) ;
     V_SUBWHITEBLACK_ROW SUBWHITEBLACK_ROW_TYPE ;
    BEGIN
      --自定义变量初始化
      WHITELISTTOTALCOUNT := 0;
      WHITEGROUPCOUNT := 0;
      WHITEADDEDCOUNT := 0;
      WHITENOADDEDCOUNT := 0;
      WHITEDEMANDCOUNT := 0;
      BLACKCOUNT := 0;
      RESULTCOUNT := 0;
      ISTABLEEXIST := 0;
     
      --查询企业白名单组总数的SQL
      STRSQL := 'SELECT COUNT(WHITELIST.ID) FROM NM_WHITE_LIST WHITELIST WHERE 1=1 ';
      IF SPID > 0 THEN
          STRSQL := STRSQL || 'AND WHITELIST.SP_ID ='||SPID;
      END IF ;
      IF SPID <= 0 THEN
          RETURN V_SUBWHITEBLACK_ROW ;
      END IF ;
      --获得企业白名单组数,如果大于0 执行分组查询
      EXECUTE IMMEDIATE  STRSQL INTO  RESULTCOUNT ;
      IF RESULTCOUNT > 0 THEN
         STRSQL := STRSQL || ' GROUP BY WHITELIST.SP_ID ' ;
         ---获取该企业的白名单组总数
         EXECUTE IMMEDIATE  STRSQL INTO  WHITEGROUPCOUNT ;
      END IF ;
      STRSQL := 'SELECT COUNT(*) FROM ALL_TABLES TALBES WHERE TALBES.TABLE_NAME = ''NM_NET_USER_'||SPID||'''' ;
      EXECUTE IMMEDIATE STRSQL INTO ISTABLEEXIST ;
      IF ISTABLEEXIST > 0 THEN
        BASESTRSQL := 'SELECT COUNT(U.MDN) FROM NM_NET_USER_'||SPID||' U ' ;
        ---企业已填加白名单数    
        STRSQL := BASESTRSQL || ' WHERE U.STATUS IN (1,2)' ;
        EXECUTE IMMEDIATE  STRSQL INTO  WHITEADDEDCOUNT ;
        ---企业点播白名单数
        STRSQL := BASESTRSQL || ' WHERE U.STATUS = 3' ;
        EXECUTE IMMEDIATE  STRSQL INTO  WHITEDEMANDCOUNT ;
        ---企业未添加白名单数
        STRSQL := BASESTRSQL || ' WHERE U.STATUS = 4' ;
        EXECUTE IMMEDIATE  STRSQL INTO  WHITENOADDEDCOUNT ;
        ---企业白名单总数
        WHITELISTTOTALCOUNT := WHITEADDEDCOUNT + WHITEDEMANDCOUNT + WHITENOADDEDCOUNT ;
      END IF ;
      ---获取企业黑名单总数SQL
      STRSQL := 'SELECT COUNT(BLACK.ID) FROM NM_BLACK_AND_OBJECT BLACK WHERE BLACK.SP_ID ='||SPID ;
      --如果大于0 执行分组查询
      EXECUTE IMMEDIATE  STRSQL INTO  RESULTCOUNT ;
      IF RESULTCOUNT > 0 THEN
         STRSQL := STRSQL ||' GROUP BY BLACK.SP_ID'  ;
         ---获取该企业的黑名单总数
         EXECUTE IMMEDIATE STRSQL INTO BLACKCOUNT ;
      END IF ;
      V_SUBWHITEBLACK_ROW :=SUBWHITEBLACK_ROW_TYPE(SPID ,SPNAME,WHITEGROUPCOUNT,WHITELISTTOTALCOUNT,WHITEADDEDCOUNT,WHITENOADDEDCOUNT,WHITEDEMANDCOUNT,BLACKCOUNT);
     
      RETURN V_SUBWHITEBLACK_ROW ;
    END ;

 

    4:创建获取table数据function

 

           CREATE OR REPLACE FUNCTION GETSUBWHITEBLACKLIST
     (
      MAINACCOUNTID IN NUMBER,
      SUBACCOUNTNAME IN VARCHAR
     )
     RETURN SUBWHITEBLACK_TABLE_TYPE PIPELINED
     AS
     V_ROW_TYPE SUBWHITEBLACK_ROW_TYPE;
      SPID NUMBER;
      SPNAME VARCHAR(200);
      WHITEGROUPCOUNT NUMBER;
      WHITELISTCOUNT NUMBER;
      WHITEADDEDCOUNT NUMBER;
      WHITENOADDEDCOUNT NUMBER;
      WHITEDEMANDCOUNT NUMBER;
      BLACKCOUMT NUMBER;
      RESULTCOUNT NUMBER;
      ISTABLEEXIST NUMBER ;
      STRSQL VARCHAR(2000);
      CONSTANTSTR VARCHAR(20) ;
      TYPE T_CUR IS REF CURSOR;
      V_PCUR T_CUR;
      TYPE NM_SP_INFO_AAT IS TABLE OF NM_SP_INFO.ID%TYPE
      INDEX BY PLS_INTEGER;
      NM_SP_INFO_IDS NM_SP_INFO_AAT ;
      TYPE NM_SP_INFO_BBT IS TABLE OF NM_SP_INFO.SP_NAME%TYPE
      INDEX BY PLS_INTEGER;
      NM_SP_INFO_NAMES NM_SP_INFO_BBT ;
     BEGIN

       ---初始化主账户名称
       CONSTANTSTR := '主账户' ;
       IF  MAINACCOUNTID > 0 THEN
          IF SUBACCOUNTNAME IS NOT NULL AND INSTR(CONSTANTSTR,SUBACCOUNTNAME,-1,1) > 0 THEN
             V_ROW_TYPE := GETSUBWHITEBLACKBYID(MAINACCOUNTID,CONSTANTSTR);        PIPE ROW (V_ROW_TYPE);
          END IF ;
          IF SUBACCOUNTNAME IS  NULL THEN
             V_ROW_TYPE := GETSUBWHITEBLACKBYID(MAINACCOUNTID,CONSTANTSTR);
             PIPE ROW (V_ROW_TYPE);
          END IF ;
       END IF ;

       STRSQL := 'SELECT SP.ID SPID ,SP.SP_NAME NAME FROM NM_SP_INFO SP WHERE SP.ID <> 0 AND SP.OPEN_SUBACCOUNT = 1' ;
       STRSQL := STRSQL || ' AND SP.ID <>'||MAINACCOUNTID||' AND SP.SP_GRPID ='||MAINACCOUNTID ;
       IF  SUBACCOUNTNAME IS NOT NULL THEN
           STRSQL := STRSQL || ' AND SP.SP_NAME LIKE (''%'||SUBACCOUNTNAME||'%'')' ;
       END IF ;
       EXECUTE IMMEDIATE 'SELECT COUNT(*) FROM ('||STRSQL||')' INTO RESULTCOUNT ;
           --如果没有子账户信息,则退出;否则继续执行
       IF RESULTCOUNT = 0 THEN
          RETURN ;
       END IF ;
       IF RESULTCOUNT > 0 THEN
          OPEN V_PCUR FOR STRSQL;
          FETCH V_PCUR BULK COLLECT INTO NM_SP_INFO_IDS,NM_SP_INFO_NAMES;
          FOR I IN NM_SP_INFO_IDS.FIRST .. NM_SP_INFO_IDS.LAST
          LOOP

             --此处调用获取行数据的function 进行标量赋值
              V_ROW_TYPE := GETSUBWHITEBLACKBYID(NM_SP_INFO_IDS(I),NM_SP_INFO_NAMES(I));
              PIPE ROW (V_ROW_TYPE);
          END LOOP ;
          CLOSE V_PCUR ;
       END IF ;

     END ;

 

 

  5:java中调用方法

     //? 为参数站位符 , 和普通select语句没什么太大区别

     select * from table(getSubWhiteBlackList(?,?)) ;

 

 

  <a href='http://www.1diaocha.com/user/Register.aspx?account=soqian'></a>

 

   

 

 


 

 

网赚的童鞋 ,赶快注册吧

  

分享到:
评论

相关推荐

    oracle管道函数用法

    ### Oracle管道函数详解 #### 一、概述 Oracle管道函数是一种特殊类型的函数,它能够返回一个数据集合,并且能够在函数执行的过程中逐步返回结果,而不仅仅是最后的结果。这种特性使得管道函数非常适合于处理大量...

    oracle 管道函数+动态游标

    根据提供的Oracle管道函数和动态游标的代码片段及描述,我们可以深入了解其背后的技术要点与实现细节。下面将逐一解析这些知识点。 ### Oracle管道函数 管道函数(Pipe-lined Function)是Oracle中一种特殊类型的...

    Oracle中实现Split函数功能

    这个函数使用了 Oracle 的管道化函数(pipelined function)来返回拆分后的结果。函数内部使用了一个循环来拆分字符串,每次循环都会将拆分后的结果返回给调用者。 最后,我们可以使用这个函数来拆分字符串。例如,...

    oracle split函数

    本文将详细介绍两种在Oracle中实现字符串分割的方法:第一种是通过创建类型和管道函数的方式;第二种则是通过循环和子字符串处理实现的。 #### 二、第一种实现方式:创建类型和管道函数 ##### 1. 创建类型 `TY_STR...

    详解oracle管道函数的用法(一行拆为多行)

    oracle管道函数是一类特殊的函数,oracle管道函数返回值类型必须为集合 如果需要在客户端实时的输出函数执行过程中的一些信息,在oracle9i以后可以使用管道函数(pipeline function)。 关键字PIPELINED表明这是一个...

    oracle利用UTL-HTTP包访问SOAP、HTTP接口并通过管道函数解析xml响应文件用游标以表方式输出

    2. **测试管道函数**:使用模拟的 XML 文档作为输入,测试管道函数是否能正确解析数据并以表格形式输出。 ### 总结 本文档详细介绍了如何在 Oracle 数据库中使用 UTL_HTTP 包访问 SOAP 或 HTTP 接口,并通过创建...

    oracle split 函数

    通过定义集合类型和使用管道函数,我们可以方便地将分割后的字符串以表的形式返回,从而更加灵活地处理和查询数据。这种方法不仅可以提高代码的可读性和可维护性,还能有效地提升数据处理的效率。

    PostgreSQL 管道函数(Pipelined Table Function)——兼容oracle

    关键字PIPELINED表明这是一个oracle管道函数,oracle管道函数的返回值类型必须为集合,在函数中,PIPE ROW语句被用来返回该集合的单个元素,函数以一个空的RETURN 语句结束,以表明它已经完成。 由于管道

    SQLServer和Oracle常用函数对比.txt

    - **Oracle**: 使用`CONCAT`函数或双管道符号`||`。 ```sql SELECT CONCAT('11', '22', '33') AS Value FROM DUAL; ``` 24. **位置查找(CHARINDEX/INSTR)** - **SQLServer**: 使用`CHARINDEX`函数查找子字符...

    SQLServer和Oracle常用函数对比

    - Oracle使用`CONCAT()`函数或双管道`||`连接字符串。 #### 查找位置 - SQLServer使用`CHARINDEX()`函数查找子字符串的位置。 - Oracle使用`INSTR()`函数查找子字符串的位置,语法略有不同。 #### 替换子字符串 - ...

    利用函数返回oracle对象表的三种方法

    在本篇文章中,我们将探讨如何通过函数返回Oracle对象表的三种方法。首先,我们需要了解基础的Oracle对象类型定义: 1. 定义Oracle对象类型: ```sql CREATE OR REPLACE TYPE t_test AS OBJECT( EMPNO NUMBER(4), ...

    Oracle 中 table 函数的应用浅析

    该函数可以平行执行,并可持续输出数据流,被称作管道式输出。应用表函数可将数据转换分阶段处理,并省去中间结果的存储和缓冲表。 1. 用游标传递数据 利用游标 REF CURSOR 可将数据集(多行记录)传递到PL/SQL函数...

    Oracle 10g应用指导

    对子程序的调用者权限、管道表函数、传递触发器标识:new和:old以及自治事务也给出了具体的解决方法。第8 章 LOB与面向对象的数据管理. 第9章 Oracle的监听器和网络设置。包括Oracle网络体系结构,Oracle Net参数文件...

    Oracle函数大全

    2. **日期和时间函数**: - `SYSDATE`:返回当前系统的日期和时间。 - `ADD_MONTHS`:向日期添加指定月数。 - `EXTRACT`:从日期/时间值中提取部分(如年、月、日等)。 - `TO_CHAR`:将日期/时间转换为字符串...

    AntDB_Oracle兼容性开发者手册v31

    1. **数据类型**:AntDB支持与Oracle相匹配的数据类型,这意味着在Oracle中定义的表结构可以几乎原封不动地应用于AntDB,减少了数据迁移的工作量。 2. **SQL语法**:AntDB支持Oracle的SQL语法,使得开发者可以使用...

    ORACLE的存储过程的异步调用

    知识点 2: 使用 DBMS_PIPE 包实现管道通信 DBMS_PIPE 包提供了管道机制,允许用户在会话之间进行通信。通过 DBMS_PIPE 包,可以将处理情况放在管道中,以便监控存储过程的执行状态。 知识点 3: 监控存储过程的执行...

    oracle的开发技术

    8. **管道函数**:管道函数(PIPELINED)允许PL/SQL程序作为一个数据源,通过将数据流传递给其他函数或操作,提高查询效率和灵活性。 9. **递归查询**:使用递归WITH子句,Oracle可以处理复杂的递归关系,如图论中...

    给Oracle添加split和splitstr函数的方法

    在Oracle数据库中,由于默认的SQL语法并不支持像JavaScript或.NET框架中那样直接对字符串进行`split`操作,所以在处理批量操作时,需要通过自定义函数来实现类似的功能。这里介绍的方法是创建两个用户自定义函数,即...

    《剑破冰山__Oracle开发艺术_》高清PDF

    此外还有大量案例:Where In List问题解析,数据库设计和大数据量处理、数据审核、号段选取应用、分析SQL执行计划的关注点、Oracle开发误区探索、提升PL/SQL开发性能漫淡、管道函数的学习与实战应用、巧用锁特性避免...

Global site tag (gtag.js) - Google Analytics