TeamPiped-mirror/Piped-Backend
1
0
Fork 0
mirror of https://github.com/TeamPiped/Piped-Backend.git synced 2024-08-14 23:51:41 +00:00
Code Issues Projects Releases Packages Wiki Activity

Implement better playlist querying.

Browse source
This commit is contained in:
Kavin 2022-11-17 00:03:41 +00:00
parent cdc5546d7a
commit 0fd90ab1c9
No known key found for this signature in database
GPG key ID: 49451E4482CC5BCD
1 changed files with 6 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
src/main/java/me/kavin/piped/server/handlers/auth/AuthPlaylistHandlers.java
View file

@ -26,7 +26,6 @@ import me.kavin.piped.utils.resp.AuthenticationFailureResponse;
import me.kavin.piped.utils.resp.InvalidRequestResponse; import me.kavin.piped.utils.resp.InvalidRequestResponse;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.hibernate.Session; import org.hibernate.Session;
import org.hibernate.StatelessSession;
import org.schabi.newpipe.extractor.Page; import org.schabi.newpipe.extractor.Page;
import org.schabi.newpipe.extractor.exceptions.ExtractionException; import org.schabi.newpipe.extractor.exceptions.ExtractionException;
import org.schabi.newpipe.extractor.playlist.PlaylistInfo; import org.schabi.newpipe.extractor.playlist.PlaylistInfo;
@ -49,13 +48,12 @@ public class AuthPlaylistHandlers {
if (StringUtils.isBlank(playlistId)) if (StringUtils.isBlank(playlistId))
ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("playlistId is a required parameter")); ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("playlistId is a required parameter"));
try (StatelessSession s = DatabaseSessionFactory.createStatelessSession()) { try (Session s = DatabaseSessionFactory.createSession()) {
var cb = s.getCriteriaBuilder(); var cb = s.getCriteriaBuilder();
var cq = cb.createQuery(me.kavin.piped.utils.obj.db.Playlist.class); var cq = cb.createQuery(me.kavin.piped.utils.obj.db.Playlist.class);
var root = cq.from(me.kavin.piped.utils.obj.db.Playlist.class); var root = cq.from(me.kavin.piped.utils.obj.db.Playlist.class);
root.fetch("videos", JoinType.LEFT) root.fetch("videos", JoinType.RIGHT)
.fetch("channel", JoinType.LEFT); .fetch("channel", JoinType.INNER);
root.fetch("owner", JoinType.LEFT);
cq.select(root); cq.select(root);
cq.where(cb.equal(root.get("playlist_id"), UUID.fromString(playlistId))); cq.where(cb.equal(root.get("playlist_id"), UUID.fromString(playlistId)));
var query = s.createQuery(cq); var query = s.createQuery(cq);
@ -89,13 +87,12 @@ public class AuthPlaylistHandlers {
if (StringUtils.isBlank(playlistId)) if (StringUtils.isBlank(playlistId))
ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("playlistId is required parameter")); ExceptionHandler.throwErrorResponse(new InvalidRequestResponse("playlistId is required parameter"));
try (StatelessSession s = DatabaseSessionFactory.createStatelessSession()) { try (Session s = DatabaseSessionFactory.createSession()) {
var cb = s.getCriteriaBuilder(); var cb = s.getCriteriaBuilder();
var cq = cb.createQuery(me.kavin.piped.utils.obj.db.Playlist.class); var cq = cb.createQuery(me.kavin.piped.utils.obj.db.Playlist.class);
var root = cq.from(me.kavin.piped.utils.obj.db.Playlist.class); var root = cq.from(me.kavin.piped.utils.obj.db.Playlist.class);
root.fetch("videos", JoinType.LEFT) root.fetch("videos", JoinType.RIGHT)
.fetch("channel", JoinType.LEFT); .fetch("channel", JoinType.INNER);
root.fetch("owner", JoinType.LEFT);
cq.select(root); cq.select(root);
cq.where(cb.equal(root.get("playlist_id"), UUID.fromString(playlistId))); cq.where(cb.equal(root.get("playlist_id"), UUID.fromString(playlistId)));
var query = s.createQuery(cq); var query = s.createQuery(cq);