Skip to content

[WIP] PostgreSQL function to recursive search an element into a JSONB object #7

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

[WIP] PostgreSQL function to recursive search an element into a JSONB object #7

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions migrations/1542900965_jsonb_recursive_search.down.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
DROP FUNCTION jsonb_recursive_search(object JSONB, key TEXT, INOUT result JSONB);
38 changes: 38 additions & 0 deletions migrations/1542900965_jsonb_recursive_search.up.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,38 @@
/*
*
* Usage example:
*
* SELECT *
* FROM jsonb_recursive_search(
* '{"mgname": ["British TV Shows", "Docuseries", "Documentaries", "TV Shows"], "nfinfo": {"type": "series", "title": "Inside The Freemasons", "image1": "https://occ-0-1490-1489.1.nflxso.net/art/69b67/62f10bf294eef9dc69a6df144a7d56c187669b67.jpg", "image2": "https://occ-0-1490-1489.1.nflxso.net/art/69b67/62f10bf294eef9dc69a6df144a7d56c187669b67.jpg", "runtime": "na", "updated": "2018-09-15 12:08:17", "download": "0", "matlabel": "Suitable for age 6 or older.", "matlevel": "", "released": "2017", "synopsis": "Explore the history and future of the Freemasons, a fraternal order steeped in both secrecy and tradition.", "avgrating": "0", "netflixid": "80240816", "unogsdate": "2018-09-15 01:55:53"}, "people": [], "Genreid": ["52117", "10105", "6839", "83"], "country": [{"cid": "23", "new": "2018-09-15", "subs": ["Simplified Chinese", "English", "Italian", "Traditional Chinese", "Greek"], "audio": ["British English", "French", "German", "Spanish"], "ccode": "au", "islive": "yes", "country": "Australia ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "29", "new": "2018-09-15", "subs": ["English", "Italian", "German", "French", "Brazilian Portuguese"], "audio": ["British English", "French", "Brazilian Portuguese", "German", "Spanish"], "ccode": "br", "islive": "yes", "country": "Brazil ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "33", "new": "2018-09-15", "subs": ["Spanish", "English", "Italian", "German", "French"], "audio": ["British English", "French", "Brazilian Portuguese", "German", "Spanish"], "ccode": "ca", "islive": "yes", "country": "Canada ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "307", "new": "2018-09-15", "subs": ["Polish", "English", "German"], "audio": ["British English", "German"], "ccode": "cz", "islive": "yes", "country": "Czech Republic ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "45", "new": "2018-09-15", "subs": ["English", "Arabic", "German", "European Spanish", "French"], "audio": ["British English", "French", "Brazilian Portuguese", "German", "Spanish"], "ccode": "fr", "islive": "yes", "country": "France ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "39", "new": "2018-09-15", "subs": ["English", "Dutch", "German", "French", "Turkish"], "audio": ["British English", "French", "German", "Spanish"], "ccode": "de", "islive": "yes", "country": "Germany ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "334", "new": "2018-09-15", "subs": ["English", "Romanian", "German"], "audio": ["British English", "German"], "ccode": "hu", "islive": "yes", "country": "Hungary ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "337", "new": "2018-09-15", "subs": ["English"], "audio": ["British English"], "ccode": "in", "islive": "yes", "country": "India ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "357", "new": "2018-09-15", "subs": ["English"], "audio": ["British English"], "ccode": "lt", "islive": "yes", "country": "Lithuania ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "67", "new": "2018-09-15", "subs": ["English", "Dutch", "German", "European Spanish", "French"], "audio": ["British English", "French", "German", "Spanish"], "ccode": "nl", "islive": "yes", "country": "Netherlands ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "392", "new": "2018-09-15", "subs": ["Polish", "English", "German"], "audio": ["British English", "German"], "ccode": "pl", "islive": "yes", "country": "Poland ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "402", "new": "2018-09-15", "subs": ["English", "Finnish"], "audio": ["British English"], "ccode": "ru", "islive": "yes", "country": "Russia", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "408", "new": "2018-09-15", "subs": ["Simplified Chinese", "English", "Traditional Chinese"], "audio": ["British English"], "ccode": "sg", "islive": "yes", "country": "Singapore ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "412", "new": "2018-09-15", "subs": ["Polish", "English", "German"], "audio": ["British English", "German"], "ccode": "sk", "islive": "yes", "country": "Slovakia ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "270", "new": "2018-09-15", "subs": ["English", "Romanian", "Arabic", "European Spanish", "French"], "audio": ["British English", "French", "Brazilian Portuguese", "German", "Spanish"], "ccode": "es", "islive": "yes", "country": "Spain ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}, {"cid": "73", "new": "2018-09-15", "subs": ["Norwegian", "English", "Swedish", "Finnish", "German"], "audio": ["British English", "French", "German"], "ccode": "se", "islive": "yes", "country": "Sweden ", "expires": "", "seasons": "1 seasons", "seasondet": ["1(5)"]}], "imdbinfo": {"plot": "With unique and unprecedented access to one of the world's oldest social networking societies this series asks who are the Freemasons and what do they do?", "genre": "Documentary, Reality-TV", "votes": "10", "awards": "N/A", "imdbid": "tt6743832", "rating": "7.8", "country": "UK", "runtime": "N/A", "language": "English", "metascore": "N/A"}}'::JSONB,
* 'audio'
* );
*/
CREATE FUNCTION jsonb_recursive_search(object JSONB, key TEXT, INOUT result JSONB DEFAULT '{}')
RETURNS JSONB AS
$$
DECLARE
k TEXT;
v JSONB;
BEGIN
IF jsonb_typeof(object) = 'array' THEN
PERFORM jsonb_recursive_search(value, key, result)
FROM jsonb_array_elements(object);

ELSIF jsonb_typeof(object) = 'object' THEN
FOR k, v IN SELECT * FROM jsonb_each(object)
LOOP
IF k IS NOT DISTINCT FROM key THEN
RAISE DEBUG 'key: %, value: %, type: %, result: %', k, v, jsonb_typeof(v), result;
result := jsonb_concat(result, v);
END IF;

IF jsonb_typeof(v) IN ('array', 'object') THEN
PERFORM jsonb_recursive_search(v, key, result);
END IF;
END LOOP;
END IF;

END;
$$
LANGUAGE plpgsql;