mysql 实现 connect by start with

一前言

1、mysql没有层级查询方法而 oracle通过connect by start with语法可以实现层级查询

2、mysql实现层级查询的方式很多，有使用存储过程函数嵌套调用亦有使用临时表进行层级查询

3、本文使用一种变量循环赋值方式进行，可以套用模版

二实验

-- 创建测试表
-- DROP TABLE IF EXISTS `test_tree`;
CREATE TABLE `test_tree` (`id` varchar(10) DEFAULT NULL,`name` varchar(10) DEFAULT NULL,`pId` varchar(10) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- 创建测试数据（根节点默认-1）
INSERT INTO `test_tree` VALUES ('1', '中国', '-1');
INSERT INTO `test_tree` VALUES ('2', '福建省', '1');
INSERT INTO `test_tree` VALUES ('3', '海南省', '1');
INSERT INTO `test_tree` VALUES ('4', '泉州市', '2');
INSERT INTO `test_tree` VALUES ('5', '福州市', '2');
INSERT INTO `test_tree` VALUES ('6', '泉港区', '4');
INSERT INTO `test_tree` VALUES ('7', '惠安县', '4');

-- 模版 表名代替test_tree  用id替换以下id 用pid替换以下 用其他从属字段替换name
SELECTname,id,pid,@le:= IF (pid = -1 ,0,IF( LOCATE( CONCAT('|',pid,':'),@pathlevel) > 0,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathlevel,CONCAT('|',pid,':'),-1),'|',1) +1,@le+1) ) levels,@pathlevel:= CONCAT(@pathlevel,'|',id,':', @le ,'|') pathlevel,@pathnodes:= IF( pid =-1,',root', CONCAT_WS(',',IF( LOCATE( CONCAT('|',pid,':'),@pathall) > 0 ,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathall,CONCAT('|',pid,':'),-1),'|',1),@pathnodes ) ,pid ) )paths,@pathall:=CONCAT(@pathall,'|',id,':', @pathnodes ,'|') pathall
FROM test_tree,
(SELECT @le:=0,@pathlevel:='', @pathall:='',@pathnodes:=''
)  vv
ORDER BY pid,id-- 结合instr(paths,'想要查所有子集的父级id')>0 验证
SELECT
name,
id,
pid,
levels,
paths
FROM (SELECTname,id,pid,@le:= IF (pid = -1 ,0,IF( LOCATE( CONCAT('|',pid,':'),@pathlevel) > 0,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathlevel,CONCAT('|',pid,':'),-1),'|',1) +1,@le+1) ) levels,@pathlevel:= CONCAT(@pathlevel,'|',id,':', @le ,'|') pathlevel,@pathnodes:= IF( pid =-1,',root', CONCAT_WS(',',IF( LOCATE( CONCAT('|',pid,':'),@pathall) > 0 ,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathall,CONCAT('|',pid,':'),-1),'|',1),@pathnodes ) ,pid ) )paths,@pathall:=CONCAT(@pathall,'|',id,':', @pathnodes ,'|') pathall FROM test_tree, (SELECT @le:=0,@pathlevel:='', @pathall:='',@pathnodes:='')  vvORDER BY pid,id
) src
WHERE instr(paths,'-1')>0
ORDER BY pid

三验证结果

1、数据

2 查询中国

SELECT
name,
id,
pid,
levels,
paths
FROM (SELECTname,id,pid,@le:= IF (pid = -1 ,0,IF( LOCATE( CONCAT('|',pid,':'),@pathlevel) > 0,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathlevel,CONCAT('|',pid,':'),-1),'|',1) +1,@le+1) ) levels,@pathlevel:= CONCAT(@pathlevel,'|',id,':', @le ,'|') pathlevel,@pathnodes:= IF( pid =-1,',root', CONCAT_WS(',',IF( LOCATE( CONCAT('|',pid,':'),@pathall) > 0 ,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathall,CONCAT('|',pid,':'),-1),'|',1),@pathnodes ) ,pid ) )paths,@pathall:=CONCAT(@pathall,'|',id,':', @pathnodes ,'|') pathall FROM test_tree, (SELECT @le:=0,@pathlevel:='', @pathall:='',@pathnodes:='')  vvORDER BY pid,id
) src
WHERE instr(paths,'1')>0
ORDER BY pid

3 查询福建省

SELECT
name,
id,
pid,
levels,
paths
FROM (SELECTname,id,pid,@le:= IF (pid = -1 ,0,IF( LOCATE( CONCAT('|',pid,':'),@pathlevel) > 0,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathlevel,CONCAT('|',pid,':'),-1),'|',1) +1,@le+1) ) levels,@pathlevel:= CONCAT(@pathlevel,'|',id,':', @le ,'|') pathlevel,@pathnodes:= IF( pid =-1,',root', CONCAT_WS(',',IF( LOCATE( CONCAT('|',pid,':'),@pathall) > 0 ,SUBSTRING_INDEX( SUBSTRING_INDEX(@pathall,CONCAT('|',pid,':'),-1),'|',1),@pathnodes ) ,pid ) )paths,@pathall:=CONCAT(@pathall,'|',id,':', @pathnodes ,'|') pathall FROM test_tree, (SELECT @le:=0,@pathlevel:='', @pathall:='',@pathnodes:='')  vvORDER BY pid,id
) src
WHERE instr(paths,'2')>0
ORDER BY pid

mysql 实现 connect by start with相关推荐

mysql 的connect 设置无法点next_技术分享 | MySQL 使用 MariaDB 审计插件
作者:姚远专注于 Oracle.MySQL 数据库多年,Oracle 10G 和 12C OCM,MySQL 5.6 ,5.7,8.0 OCP.现在鼎甲科技任顾问,为同事和客户提供数据库培训和技术支 ...
nodejs连接mysql报connect ECONNREFUSED错误的解决方法
通过AMH面板安装的mysql,用nodejs连接mysql时候结果报[connect ECONNREFUSED]连接错误. 解决方法:添加socketPath 有些mysql 安装的时候不是mysq ...
Solving a “communications link failure” with jdbc and mysql :Cannot connect to database server Commu
当出现: Cannot connect to database server Communications link failure 错误时,可以考虑下面的文章: http://stackoverfl ...
mysql connec_mysql++ Connect
对于一个简单的数据库应用,对于数据库的访问不是很频繁,这时在需要访问数据库时,新创建一个连接,用完后就关闭它,这样做也不会带来什么明显的性能上的开销.但是对于一个复杂的数据库应用,情况就完全不同了,频 ...
安装 Python MySQL 驱动（mysql-connector-python、MySQL-python）
1. 安装由于 MySQL 服务器以独立的进程运行,并通过网络对外服务,所以,需要支持 Python 的MySQL 驱动来连接到 MySQL 服务器. 目前,有两个MySQL驱动: mysql-co ...
mysql connector python linux_MySQL Connector/Python 安装、测试
安装Connector/Python: # wget http://cdn.mysql.com/Downloads/Connector-Python/mysql-connector-python-1. ...
Mysql 基于 Amoeba 的读写分离(2)
<?xml version="1.0" encoding="gbk"?> <!DOCTYPE amoeba:configuration SYS ...
mysql分库分表分页查询语句_MySQL分库分表分库后的查询(8th)
前言这边我们以使用python程序要展示一下再分库分表后,我们需要如何对数据库进行操作. python操作数据库我们这边还是沿用之前的那5中:场景1:购买者下订单#!/usr/bin/env py ...
python连接MySQL并进行数据查询
python连接MySQL并进行数据查询 #建立数据库的连接 mydb = mysql.connector.connect(host="0.0.0.0",user="ro ...

mysql 实现 connect by start with

mysql 实现 connect by start with相关推荐

最新文章

热门文章