`
huangro
  • 浏览: 332522 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

plpython写的一个存储过程函数

阅读更多
今天花了好久使用plpython写了一个存储过程函数,终于解决了问题,庆祝一下,哈哈。下面把代码贴上来,可供参考:


-- Function: bazaar_denim_nav(text)

DROP FUNCTION bazaar_denim_nav(text);

CREATE OR REPLACE FUNCTION bazaar_denim_nav(text)
  RETURNS text AS
$BODY$
    import cPickle as pickle
   
    # Unpack args
    filters = [f.strip() for f in args[0].split(',')]
    filters = [f for f in filters if f]
    filters.append('designerdenimnav')

    # Work out some SQL to extract all products that match a set of filters.
    if filters:
        # Find complete list of categories we should be using.
        inClause = ','.join(['$'+str(i+1) for i in range(len(filters))])
        qNodes = plpy.prepare(
            """select lft_node, rgt_node from hierarchy where object in
            (select id from category where alphanum in (%s))""" % inClause,
            ['text']*len(filters)
            )
        nodes = list(plpy.execute(qNodes, filters))
       
        # Build query
        parts = []
        for node in nodes:
            parts.append(
                """select distinct i.id from item i
                join item_category ic on ic.item_id=i.id
                join category c on c.id=ic.category_id
                where ic.category_id in (select object from hierarchy
                where lft_node >= %s and rgt_node <= %s)""" % (node['lft_node'], node['rgt_node'])
                )
        filterSql = ' intersect '.join(parts)
        filterSql = ' '.join(filterSql.split())

    # Prepare most of the plans
    if filters:
        if len(filterSql) > 0:
            qItems = plpy.prepare("select i.id from item i inner join stock_level sl on i.id=sl.item_id where sl.in_stock>0 and i.id in (%s) order by i.id"%filterSql)
        else:
            # Nothing matches the criteria so return now
            return pickle.dumps([])
    else:
        qItems = plpy.prepare("select i.id from item i inner join stock_level sl on i.id=sl.item_id where sl.in_stock>0 order by i.id")

    # get item lists
    items = list(plpy.execute(qItems))
    itemids = [item['id'] for item in items]
    strItemIds = ', '.join([str(id) for id in itemids])

    # define get sub categories function which filter by the in_stock
    def getChildren(alphanum, strItemIds):
        if strItemIds:
            qChildren = plpy.prepare("""select distinct c.name, c.alphanum from category c inner join item_category ic on c.id=ic.category_id 
                where c.id in (select object from hierarchy where
                parent=(select h.id from hierarchy h inner join category ca on ca.id=h.object where ca.alphanum='%s'))
                and ic.item_id in (%s)"""%(alphanum, strItemIds))
            children = list(plpy.execute(qChildren))
        else:
            children = []
        return children
       
       
     # Classification list
    classification = {}
    classification['brand'] = []
    classification['type'] = []
   
    classification['brand'] = getChildren('brand', strItemIds)
    top_types = getChildren('designerdenimnav', strItemIds)
    for temp in top_types:
        t_alphanum = temp['alphanum'][1:]
        t_name = temp['name'][1:]
        t_children = getChildren(t_alphanum, strItemIds)
        classification['type'].append({'name':t_name, 'alphanum':t_alphanum, 'children': t_children})
   
   
    return pickle.dumps(classification)
   
$BODY$
  LANGUAGE 'plpythonu' VOLATILE
  COST 100;
ALTER FUNCTION bazaar_denim_nav(text) OWNER TO postgres;




分享到:
评论

相关推荐

    原创sql存储过程函数范例

    原创sql存储过程函数范例,一是为了自己方便查找,今天到公司因为没有我保存的一些范例,一个简单的例子写了半个小时,如果有范例直接套几分钟肯定搞定,所以索性上传到CSDN上,何时何地都能找到我的范例了。...

    MySQL实验报告5(存储过程与函数)(1)(1).pdf

    - count_sch5: 该存储过程接收一个输出参数size,返回表sch中的总行数。使用了“select count(*) into size from sch”语句,将表sch中的行数赋值给size变量。 - count_sch2: 接收两个输出参数s_a和s_id,分别返回表...

    sqlserver 存储过程 函数 常用知识点

    - **RETURN**:结束存储过程或函数并返回一个值。 6. **事务管理**: - 使用`BEGIN TRANSACTION`, `COMMIT`和`ROLLBACK`来确保数据的一致性和完整性。 7. **视图(Views)**: 可以结合存储过程和函数一起使用...

    实验4存储过程和函数实验

    适合sqlserver数据库初学者,实验四存储过程和函数实验

    用一个函数实现两个字符串的比较,即自己写一个 strcmp 函数

    用一个函数实现两个字符串的比较,即自己写一个 strcmp 函数

    第11章MySQL存储过程与函数.docx

    4. 存储过程一般是作为一个独立的部分来执行,而函数可以作为查询语句的一个部分来调用。 创建存储过程的示例: CREATE PROCEDURE getnamebysno(in xh char(10), out name char(20)) BEGIN SELECT sname INTO ...

    Oracle存储过程、函数和包

    - **定义**:函数类似于存储过程,但它总是返回一个值。 - **语法**: ```sql CREATE [OR REPLACE] FUNCTION 函数名 (参数列表) RETURN 返回类型 IS BEGIN -- 函数体 RETURN 值; END; ``` #### 8. 包 - **...

    存储过程和函数的区别

    3. **无返回值**:与函数不同,存储过程不直接返回一个具体的值,而是通过输出参数或直接修改数据库状态来实现其功能。 4. **支持多条SQL语句**:存储过程中可以包含多条SQL语句,这些语句可以是查询、更新或其他...

    PLSQL程序设计-存储过程函数触发器

    除了存储过程和函数外,**触发器**也是PL/SQL中的一个重要概念。触发器是一种特殊类型的存储过程,它会在特定事件发生时自动执行,如插入、更新或删除表中的数据。触发器可以用来强制实施业务规则或进行数据审计。 ...

    GBase 8S 自定义存储过程和函数.doc

    存储过程是GBase 8S中一个重要的特性,它们是一组预编译的SQL语句集合,能够执行特定任务,并作为独立的数据库对象存在。与普通的SQL查询相比,存储过程有以下几个显著优点: 1. **模块化编程**:存储过程类似高级...

    postgres 存储过程函数

    `pro_pfl_data.sql`可能包含了处理特定数据表的函数,`pro_supplement_pfl.sql`可能是对数据进行补充或更新的存储过程,而`supplement_Start.sql`可能是启动一系列数据处理操作的入口点。 学习和理解这些文件的内容...

    Mysql存储过程和函数

    下面通过一个具体的例子来展示如何创建和使用存储过程。 1. **创建表**: ```sql CREATE TABLE xiaozhe ( id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(10) ); INSERT INTO xiaozhe(name) VALUES ('...

    MySQL数据库函数,触发器,存储过程

    触发器是数据库中的一个特殊类型的存储过程,它在特定的数据库操作(如INSERT、UPDATE、DELETE)之前或之后自动执行。触发器可以用于实现复杂的业务逻辑,如数据验证、审计日志记录或保持数据库的一致性。 例如,...

    存储过程与函数的区别

    相比之下,函数(Function)更像是一个计算单元,它接收输入参数并返回一个单一的值。函数必须有返回值,而且这个返回值的类型在函数定义时就已经确定。函数通常用于进行特定的计算或数据转换,其结果可以直接在查询...

    易飞系统触发器储存过程函数视图

    这些是平时个人兴趣爱好收集到的易飞ERP系统触发器/函数/储存过程/视图集。适合人群:系统管理员,运维专员或鼎捷顾问等

    关于更新字段,存储过程,函数等数据库对象的规定与说明

    在更新过程函数视图同样会造成引用其的过程函数视图失效,通常情况下,当功能调用失效的过程函数会自动编译,但是正在运行的过程函数,是不能编译成功的,所以大量的并发用户访问数据库时,会因为一些过程函数的失效而...

    MySQL数据库:存储函数调用.pptx

    【例】 创建一个存储函数,返回Book表中某本书的作者姓名。 存储函数举例 DELIMITER $$ CREATE FUNCTION author_book(b_name CHAR(20)) RETURNS CHAR(8) BEGIN RETURN (SELECT 作者 FROM Book WHERE 书名= b_name); ...

    oracle笔记存储函数和存储过程

    oracle笔记存储函数和存储过程,有具体的代码案例!存储函数和存储过程的知识笔记!

    Oracle中的函数、存储过程、包

    - **自定义函数**:用户根据需求创建的函数,例如上述的`f_get_double`,接收一个数字作为输入,返回其两倍值。 - **使用函数**:函数可以在查询语句中直接调用,例如在SELECT语句中,或者在其他函数和过程内部...

Global site tag (gtag.js) - Google Analytics