Implement db searches using raw sql
This commit is contained in:
parent
09d4453665
commit
27358fe217
4 changed files with 226 additions and 109 deletions
|
|
@ -5,60 +5,91 @@ const jetquery = @import("jetzig").jetquery;
|
|||
pub fn index(request: *jetzig.Request) !jetzig.View {
|
||||
var root = try request.data(.object);
|
||||
var albums_view = try root.put("albums", .array);
|
||||
const albums = try jetzig.database.Query(.Album)
|
||||
.select(.{ .id, .name })
|
||||
.include(.albumartists, .{ .select = .{.artist_id} })
|
||||
.include(.scrobbles, .{ .select = .{.id} })
|
||||
.orderBy(.{ .name = .asc })
|
||||
.all(request.repo);
|
||||
//const albums = try request.repo.all(query);
|
||||
//const albums = try jetzig.database.Query(.Album)
|
||||
// .select(.{ .id, .name })
|
||||
// .include(.albumartists, .{ .select = .{.artist_id} })
|
||||
// .include(.scrobbles, .{ .select = .{.id} })
|
||||
// .orderBy(.{ .name = .asc })
|
||||
// .all(request.repo);
|
||||
////const albums = try request.repo.all(query);
|
||||
|
||||
for (albums) |album| {
|
||||
const query =
|
||||
\\SELECT albums.name, albums.id, COUNT(scrobbles) AS scrobbles
|
||||
\\FROM albumsongs
|
||||
\\INNER JOIN albums ON albumsongs.album_id = albums.id
|
||||
\\INNER JOIN scrobbles ON albumsongs.id = scrobbles.albumsong
|
||||
\\GROUP BY albums.id
|
||||
\\ORDER BY scrobbles DESC
|
||||
;
|
||||
|
||||
var albums_jq_result = try request.repo.executeSql(query, .{});
|
||||
defer albums_jq_result.deinit();
|
||||
|
||||
const Album = struct { name: []const u8, id: i32, scrobbles: i64 };
|
||||
|
||||
while (try albums_jq_result.postgresql.result.next()) |album_row| {
|
||||
const album = try album_row.to(Album, .{ .dupe = true, .allocator = request.allocator });
|
||||
var album_view = try albums_view.append(.object);
|
||||
|
||||
var artist_infos = try album_view.put("artist_info", .array);
|
||||
for (album.albumartists) |artist| {
|
||||
var artist_info = try artist_infos.append(.object);
|
||||
const artist_data = try jetzig.database.Query(.Artist)
|
||||
.find(artist.artist_id)
|
||||
.select(.{ .id, .name })
|
||||
.execute(request.repo);
|
||||
try artist_info.put("name", artist_data.?.name);
|
||||
try artist_info.put("id", artist_data.?.id);
|
||||
}
|
||||
|
||||
try album_view.put("name", album.name);
|
||||
try album_view.put("url", album.id);
|
||||
try album_view.put("scrobbles", (album.scrobbles).len);
|
||||
try album_view.put("scrobbles", album.scrobbles);
|
||||
}
|
||||
return request.render(.ok);
|
||||
}
|
||||
|
||||
pub fn get(id: []const u8, request: *jetzig.Request) !jetzig.View {
|
||||
const album = try jetzig.database.Query(.Album)
|
||||
.find(id)
|
||||
.select(.{ .id, .name })
|
||||
.execute(request.repo);
|
||||
var root = try request.data(.object);
|
||||
try root.put("album", album.?.name);
|
||||
var songs_view = try root.put("songs", .array);
|
||||
const query = jetzig.database.Query(.Albumsong)
|
||||
.select(.{.id})
|
||||
.include(.song, .{ .select = .{ .name, .id } })
|
||||
.join(.inner, .album)
|
||||
.where(.{ .album = .{ .id = id } });
|
||||
const album_name = try jetzig.database.Query(.Album).find(id).select(.{ .id, .name }).execute(request.repo);
|
||||
_ = try root.put("album", album_name.?.name);
|
||||
|
||||
const songs = try request.repo.all(query);
|
||||
for (songs) |song| {
|
||||
const scrobbles = try jetzig.database.Query(.Scrobble)
|
||||
.where(.{ .song_id = song.song.id })
|
||||
.count()
|
||||
.execute(request.repo);
|
||||
const query =
|
||||
\\SELECT songs.name, songs.id, COUNT(scrobbles) AS scrobbles
|
||||
\\FROM albumsongs
|
||||
\\INNER JOIN songs ON albumsongs.song_id = songs.id
|
||||
\\INNER JOIN scrobbles ON scrobbles.albumsong = albumsongs.id
|
||||
\\WHERE albumsongs.album_id = $1
|
||||
\\GROUP BY songs.id
|
||||
\\ORDER BY scrobbles DESC
|
||||
;
|
||||
|
||||
var songs_js_result = try request.repo.executeSql(query, .{id});
|
||||
defer songs_js_result.deinit();
|
||||
|
||||
const Song = struct { name: []const u8, id: i32, scrobbles: i64 };
|
||||
|
||||
while (try songs_js_result.postgresql.result.next()) |song_row| {
|
||||
const song = try song_row.to(Song, .{ .dupe = true, .allocator = request.allocator });
|
||||
var song_view = try songs_view.append(.object);
|
||||
try song_view.put("name", song.song.name);
|
||||
try song_view.put("url", song.song.id);
|
||||
try song_view.put("scrobbles", scrobbles);
|
||||
try song_view.put("name", song.name);
|
||||
try song_view.put("url", song.id);
|
||||
try song_view.put("scrobbles", song.scrobbles);
|
||||
}
|
||||
|
||||
//const album = try jetzig.database.Query(.Album)
|
||||
// .find(id)
|
||||
// .select(.{ .id, .name })
|
||||
// .execute(request.repo);
|
||||
//var root = try request.data(.object);
|
||||
//try root.put("album", album.?.name);
|
||||
//var songs_view = try root.put("songs", .array);
|
||||
//const query = jetzig.database.Query(.Albumsong)
|
||||
// .select(.{.id})
|
||||
// .include(.song, .{ .select = .{ .name, .id } })
|
||||
// .join(.inner, .album)
|
||||
// .where(.{ .album = .{ .id = id } });
|
||||
|
||||
//const songs = try request.repo.all(query);
|
||||
//for (songs) |song| {
|
||||
// const scrobbles = try jetzig.database.Query(.Scrobble)
|
||||
// .where(.{ .song_id = song.song.id })
|
||||
// .count()
|
||||
// .execute(request.repo);
|
||||
// var song_view = try songs_view.append(.object);
|
||||
// try song_view.put("name", song.song.name);
|
||||
// try song_view.put("url", song.song.id);
|
||||
// try song_view.put("scrobbles", scrobbles);
|
||||
//}
|
||||
return request.render(.ok);
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue