您无法在动态 SQL 语句中引用本地 PL/SQL 变量,因为它超出了动态调用所使用的 SQL 上下文的范围。您可以替换您的第一个电话:
SELECT join_t(ROWIDTOCHAR(r.rowid), center_objects(idx).id) FROM ' ...
使用绑定变量:
SELECT join_t(ROWIDTOCHAR(r.rowid), :id FROM ' ...
EXECUTE IMMEDIATE ... USING center_objects(idx).id ...
但是当对象属性也可变时你不能做什么:
... ', center_objects(idx).' || blob_col1 || ')<='...
虽然 - 至少在您展示的示例中 - 唯一可用的对象属性名称是fv
,无论传递给函数的表列名称如何 - 以便可以进行硬编码;因此可以使用绑定变量:
... ', :fv)<='...
EXECUTE IMMEDIATE ... USING center_objects(idx).id, center_objects(idx).fv ...
and the kv
value 也应该是一个绑定变量,所以你最终会得到:
create or replace FUNCTION knn_join (tab_inn IN varchar2, tab_out IN varchar2,
blob_col1 IN varchar2, blob_col2 IN varchar2, dist_alg in VARCHAR2, kv in NUMBER )
RETURN join_jt
IS
center_objects blob_tt := blob_tt();
retval join_jt := join_jt ();
join_table join_jt := join_jt();
sql_stmt1 varchar2(400);
sql_stmt2 varchar2(400);
BEGIN
sql_stmt1 := 'SELECT blob_t(ROWIDTOCHAR(rowid),' || blob_col1 || ') FROM ' || tab_out;
sql_stmt2 := 'SELECT join_t(ROWIDTOCHAR(r.rowid), :id) FROM ' || tab_inn || ' r WHERE '
|| dist_alg || '_knn(r.' || blob_col2 || ', :fv)<= :kv';
dbms_output.put_line(sql_stmt1);
dbms_output.put_line(sql_stmt2);
EXECUTE IMMEDIATE sql_stmt1 BULK COLLECT INTO center_objects;
for idx in center_objects.first()..center_objects.last()
loop
EXECUTE IMMEDIATE sql_stmt2 BULK COLLECT INTO join_table
USING center_objects(idx).id, center_objects(idx).fv, kv;
for idx2 in join_table.first()..join_table.last()
loop
retval.extend();
retval(retval.count()) := join_table(idx2);
end loop;
end loop;
RETURN retval;
END;
/
据我所知,您仍然可以在动态 SQL 语句中进行连接,并消除循环和中间的需要center_objects
and join_table
收藏:
create or replace FUNCTION knn_join (tab_inn IN varchar2, tab_out IN varchar2,
blob_col1 IN varchar2, blob_col2 IN varchar2, dist_alg in VARCHAR2, kv in NUMBER )
RETURN join_jt
IS
retval join_jt;
sql_stmt varchar2(400);
BEGIN
sql_stmt := 'SELECT join_t(ROWIDTOCHAR(tinn.rowid), ROWIDTOCHAR(tout.rowid))'
|| ' FROM ' || tab_inn || ' tinn JOIN ' || tab_out || ' tout'
|| ' ON ' || dist_alg || '_knn(tinn.fv, tout.fv) <= :kv';
dbms_output.put_line(sql_stmt);
EXECUTE IMMEDIATE sql_stmt BULK COLLECT INTO retval USING kv;
RETURN retval;
END;
/
当您按照所示方式调用它时:
select * from TABLE(knn_join('london','cophirfv','fv','fv','manhattan',5));
这相当于硬编码:
SELECT join_t(ROWIDTOCHAR(tinn.rowid), ROWIDTOCHAR(tout.rowid))
FROM london tinn
JOIN cophirfv tout
ON manhattan_knn(tinn.fv, tout.fv) <= 5
...所以我想您可以首先验证该硬编码版本是否为您提供了您期望的结果。 (当然,向问题添加样本数据和预期结果会有所帮助)。
该连接条件可能会很昂贵,具体取决于函数正在执行的操作、每个表中的行数(因为每个表中的每一行都必须与另一个表中的每一行进行比较)、是否实际上有其他过滤器等。但循环版本会更糟。如果没有更多信息,无论如何,我们对此无能为力。
顺便说一句,使用varchar2
代替char
对于对象属性来说会比较正常;这也是返回的数据类型the rowidtochar()功能.