快捷導(dǎo)航

Mysql實(shí)現(xiàn)Oracle中的Start with...Connect by方式

更新時(shí)間：2024年12月23日 08:59:01 作者：HNT_Wings

文章總結(jié)：作者在遷移數(shù)據(jù)庫(kù)時(shí),使用了Oracle的startwith進(jìn)行樹(shù)的遞歸查詢(xún),但遇到了一些問(wèn)題,通過(guò)搜索和修改,作者成功地使用存儲(chǔ)過(guò)程和預(yù)處理語(yǔ)句來(lái)實(shí)現(xiàn)動(dòng)態(tài)查詢(xún),并解決了變量聲明和預(yù)處理語(yǔ)句的問(wèn)題

Mysql Oracle中的Start with...Connect by

工作需要，遷移數(shù)據(jù)庫(kù)時(shí)發(fā)現(xiàn)使用了Oracle中的start with來(lái)進(jìn)行樹(shù)的遞歸查詢(xún)，所以自己動(dòng)手豐衣足食。

通過(guò)一番搜索后發(fā)現(xiàn)

大家的實(shí)現(xiàn)基本都是這樣的：

CREATE FUNCTION queryChildrenAreaInfo(areaId INT)
RETURNS VARCHAR(4000)
BEGIN
DECLARE sTemp VARCHAR(4000);
DECLARE sTempChd VARCHAR(4000);

SET sTemp='$';
SET sTempChd = CAST(areaId AS CHAR);

WHILE sTempChd IS NOT NULL DO
SET sTemp= CONCAT(sTemp,',',sTempChd);
SELECT GROUP_CONCAT(id) INTO sTempChd FROM t_areainfo WHERE FIND_IN_SET(parentId,sTempChd)>0;
END WHILE;
RETURN sTemp;

但是這樣的代碼沒(méi)法復(fù)用（而且我的navicat居然建立函數(shù)失敗，或者各種錯(cuò)誤，所以我使用了存儲(chǔ)過(guò)程，效果一樣），所以我們使用set和execute來(lái)進(jìn)行語(yǔ)句的拼接和執(zhí)行，

修改后

如下：

CREATE PROCEDURE getChildList
IN rootId DECIMAL(65),
IN tablesname VARCHAR(6000),
OUT sTemp VARCHAR(6000)
BEGIN
DECLARE sTempChd VARCHAR(4000);

SET sTemp='$';
SET sTempChd = CAST(rootId AS CHAR);

WHILE sTempChd IS NOT NULL DO
SET sTemp= CONCAT(sTemp,',',sTempChd);
set @sqlexe = concat("SELECT GROUP_CONCAT(id) INTO sTempChd FROM " , tablesname , " WHERE FIND_IN_SET(parentId,sTempChd)>0;")
prepare sqlexe from @sqlexe;
execute sqlexe;
END WHILE;
END;

這樣一來(lái)我們就可以將表名作為參數(shù)傳入，但是一番執(zhí)行后，你會(huì)發(fā)現(xiàn)，哦豁，它居然報(bào)了這樣一個(gè)錯(cuò)：

1327 - Undeclared variable: sTempChd；

這個(gè)低級(jí)錯(cuò)誤困擾了我半天，我不是聲明了sTempChd為declare嗎？

答案很簡(jiǎn)單

預(yù)處理語(yǔ)句（也就是我們的prepare）中，只接受@聲明的參數(shù)。因?yàn)樵诖鎯?chǔ)過(guò)程中，使用動(dòng)態(tài)語(yǔ)句，預(yù)處理時(shí)，動(dòng)態(tài)內(nèi)容必須賦給一個(gè)會(huì)話變量，也就是@形式聲明的變量，而declare聲明的是存儲(chǔ)過(guò)程變量，具體的內(nèi)容涉及到更深的知識(shí)，我暫時(shí)無(wú)法找到原因。

前文是自上而下的查詢(xún)，自下而上的查詢(xún)其實(shí)很簡(jiǎn)單，只要替換一下參數(shù)和語(yǔ)句內(nèi)容就可以了，

具體如下：

CREATE PROCEDURE `getParentList`( 
	IN rootId DECIMAL(65,0), 
	IN tablesname VARCHAR ( 500 ),
	OUT sTemp VARCHAR ( 6000 ) )
BEGIN
	DECLARE
		PARENTID DECIMAL(65);
	SET sTemp = '$';
	SET @sTempChd = cast(rootId as char);
	WHILE @sTempChd <> 0 DO
		SET sTemp = concat( sTemp, ',', @sTempChd );
		SET @sqlcmd = CONCAT("SELECT PARENTID into @sTempChd FROM " , tablesname , " WHERE CATEID = " , @sTempChd , ";");
		PREPARE stmt FROM @sqlcmd;
		EXECUTE stmt;
	END WHILE;
	DEALLOCATE PREPARE stmt;
END

別忘了，最后要執(zhí)行一下deallocate語(yǔ)句，釋放預(yù)處理sql，免得session的預(yù)處理語(yǔ)句過(guò)多，達(dá)到max_prepared_stmt_count的上限值。