今天花了好久使用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存储过程函数范例,一是为了自己方便查找,今天到公司因为没有我保存的一些范例,一个简单的例子写了半个小时,如果有范例直接套几分钟肯定搞定,所以索性上传到CSDN上,何时何地都能找到我的范例了。...
- count_sch5: 该存储过程接收一个输出参数size,返回表sch中的总行数。使用了“select count(*) into size from sch”语句,将表sch中的行数赋值给size变量。 - count_sch2: 接收两个输出参数s_a和s_id,分别返回表...
- **RETURN**:结束存储过程或函数并返回一个值。 6. **事务管理**: - 使用`BEGIN TRANSACTION`, `COMMIT`和`ROLLBACK`来确保数据的一致性和完整性。 7. **视图(Views)**: 可以结合存储过程和函数一起使用...
适合sqlserver数据库初学者,实验四存储过程和函数实验
用一个函数实现两个字符串的比较,即自己写一个 strcmp 函数
4. 存储过程一般是作为一个独立的部分来执行,而函数可以作为查询语句的一个部分来调用。 创建存储过程的示例: CREATE PROCEDURE getnamebysno(in xh char(10), out name char(20)) BEGIN SELECT sname INTO ...
- **定义**:函数类似于存储过程,但它总是返回一个值。 - **语法**: ```sql CREATE [OR REPLACE] FUNCTION 函数名 (参数列表) RETURN 返回类型 IS BEGIN -- 函数体 RETURN 值; END; ``` #### 8. 包 - **...
3. **无返回值**:与函数不同,存储过程不直接返回一个具体的值,而是通过输出参数或直接修改数据库状态来实现其功能。 4. **支持多条SQL语句**:存储过程中可以包含多条SQL语句,这些语句可以是查询、更新或其他...
除了存储过程和函数外,**触发器**也是PL/SQL中的一个重要概念。触发器是一种特殊类型的存储过程,它会在特定事件发生时自动执行,如插入、更新或删除表中的数据。触发器可以用来强制实施业务规则或进行数据审计。 ...
存储过程是GBase 8S中一个重要的特性,它们是一组预编译的SQL语句集合,能够执行特定任务,并作为独立的数据库对象存在。与普通的SQL查询相比,存储过程有以下几个显著优点: 1. **模块化编程**:存储过程类似高级...
`pro_pfl_data.sql`可能包含了处理特定数据表的函数,`pro_supplement_pfl.sql`可能是对数据进行补充或更新的存储过程,而`supplement_Start.sql`可能是启动一系列数据处理操作的入口点。 学习和理解这些文件的内容...
下面通过一个具体的例子来展示如何创建和使用存储过程。 1. **创建表**: ```sql CREATE TABLE xiaozhe ( id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(10) ); INSERT INTO xiaozhe(name) VALUES ('...
触发器是数据库中的一个特殊类型的存储过程,它在特定的数据库操作(如INSERT、UPDATE、DELETE)之前或之后自动执行。触发器可以用于实现复杂的业务逻辑,如数据验证、审计日志记录或保持数据库的一致性。 例如,...
相比之下,函数(Function)更像是一个计算单元,它接收输入参数并返回一个单一的值。函数必须有返回值,而且这个返回值的类型在函数定义时就已经确定。函数通常用于进行特定的计算或数据转换,其结果可以直接在查询...
这些是平时个人兴趣爱好收集到的易飞ERP系统触发器/函数/储存过程/视图集。适合人群:系统管理员,运维专员或鼎捷顾问等
在更新过程函数视图同样会造成引用其的过程函数视图失效,通常情况下,当功能调用失效的过程函数会自动编译,但是正在运行的过程函数,是不能编译成功的,所以大量的并发用户访问数据库时,会因为一些过程函数的失效而...
【例】 创建一个存储函数,返回Book表中某本书的作者姓名。 存储函数举例 DELIMITER $$ CREATE FUNCTION author_book(b_name CHAR(20)) RETURNS CHAR(8) BEGIN RETURN (SELECT 作者 FROM Book WHERE 书名= b_name); ...
oracle笔记存储函数和存储过程,有具体的代码案例!存储函数和存储过程的知识笔记!
- **自定义函数**:用户根据需求创建的函数,例如上述的`f_get_double`,接收一个数字作为输入,返回其两倍值。 - **使用函数**:函数可以在查询语句中直接调用,例如在SELECT语句中,或者在其他函数和过程内部...