136 lines
2.9 KiB
Go
136 lines
2.9 KiB
Go
package bouquins
|
|
|
|
import (
|
|
"database/sql"
|
|
)
|
|
|
|
// SUB QUERIES //
|
|
|
|
func (app *Bouquins) queryAuthors(limit, offset int, sort, order string) ([]*AuthorAdv, bool, error) {
|
|
authors := make([]*AuthorAdv, 0, limit)
|
|
stmt, err := app.psSortAuthors(AUTHORS, sort, order)
|
|
if err != nil {
|
|
return nil, false, err
|
|
}
|
|
rows, err := stmt.Query(limit+1, offset)
|
|
if err != nil {
|
|
return nil, false, err
|
|
}
|
|
defer rows.Close()
|
|
more := false
|
|
for rows.Next() {
|
|
if len(authors) == limit {
|
|
more = true
|
|
} else {
|
|
author := new(AuthorAdv)
|
|
if err := rows.Scan(&author.Id, &author.Name, &author.Count); err != nil {
|
|
return nil, false, err
|
|
}
|
|
authors = append(authors, author)
|
|
}
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return nil, false, err
|
|
}
|
|
return authors, more, nil
|
|
}
|
|
|
|
func (app *Bouquins) queryAuthorBooks(author *AuthorFull) error {
|
|
stmt, err := app.ps(AUTHOR_BOOKS)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
rows, err := stmt.Query(author.Id)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer rows.Close()
|
|
series := make(map[int64]*Series, 0)
|
|
for rows.Next() {
|
|
book := new(Book)
|
|
var seriesId sql.NullInt64
|
|
var seriesName sql.NullString
|
|
if err = rows.Scan(&book.Id, &book.Title, &book.SeriesIndex, &seriesName, &seriesId); err != nil {
|
|
return err
|
|
}
|
|
if seriesId.Valid && seriesName.Valid {
|
|
series[seriesId.Int64] = &Series{
|
|
seriesId.Int64,
|
|
seriesName.String,
|
|
}
|
|
}
|
|
author.Books = append(author.Books, book)
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return err
|
|
}
|
|
author.Series = make([]*Series, 0, len(series))
|
|
for _, s := range series {
|
|
author.Series = append(author.Series, s)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (app *Bouquins) queryAuthorAuthors(author *AuthorFull) error {
|
|
stmt, err := app.ps(AUTHOR_COAUTHORS)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
rows, err := stmt.Query(author.Id, author.Id)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer rows.Close()
|
|
for rows.Next() {
|
|
coauthor := new(Author)
|
|
if err = rows.Scan(&coauthor.Id, &coauthor.Name); err != nil {
|
|
return err
|
|
}
|
|
author.CoAuthors = append(author.CoAuthors, coauthor)
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (app *Bouquins) queryAuthor(id int64) (*AuthorFull, error) {
|
|
stmt, err := app.ps(AUTHOR)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
author := new(AuthorFull)
|
|
author.Id = id
|
|
err = stmt.QueryRow(id).Scan(&author.Name)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return author, nil
|
|
}
|
|
|
|
// DB LOADS //
|
|
|
|
func (app *Bouquins) AuthorsAdv(limit, offset int, sort, order string) ([]*AuthorAdv, bool, error) {
|
|
authors, more, err := app.queryAuthors(limit, offset, sort, order)
|
|
if err != nil {
|
|
return nil, false, err
|
|
}
|
|
return authors, more, nil
|
|
}
|
|
|
|
func (app *Bouquins) AuthorFull(id int64) (*AuthorFull, error) {
|
|
author, err := app.queryAuthor(id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
err = app.queryAuthorBooks(author)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
err = app.queryAuthorAuthors(author)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return author, nil
|
|
}
|