66 lines
1.4 KiB
Go
66 lines
1.4 KiB
Go
package dal
|
|
|
|
import (
|
|
"database/sql"
|
|
"errors"
|
|
"log"
|
|
|
|
"git.rosemyrtle.work/personal-finance/server/internal/entity"
|
|
)
|
|
|
|
type DalImpl struct {
|
|
Db *sql.DB
|
|
}
|
|
|
|
func (dal *DalImpl) Transaction(transactionId int64) (*entity.Transaction, error) {
|
|
log.Printf("DAL::Transaction(%d)", transactionId)
|
|
|
|
if dal.Db == nil {
|
|
log.Panic("database not available")
|
|
}
|
|
|
|
rows, err := dal.Db.Query("SELECT t.id, t.date, t.description, t.amount FROM pfbudget.transactions t WHERE t.id = $1", transactionId)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
transactions := convert[entity.Transaction](rows)
|
|
if len(transactions) == 0 {
|
|
return nil, nil
|
|
}
|
|
|
|
return &transactions[0], nil
|
|
}
|
|
|
|
func (dal *DalImpl) Transactions() (entity.Transactions, error) {
|
|
if dal.Db == nil {
|
|
log.Panic("database not available")
|
|
}
|
|
|
|
rows, err := dal.Db.Query("SELECT t.id, t.date, t.description, t.amount FROM pfbudget.transactions t")
|
|
if err != nil {
|
|
return entity.Transactions{}, err
|
|
}
|
|
|
|
return convert[entity.Transaction](rows), nil
|
|
}
|
|
|
|
func (*DalImpl) Bank() (entity.Bank, error) {
|
|
return entity.Bank{}, errors.New("not implemented")
|
|
}
|
|
|
|
func (dal *DalImpl) Banks() (entity.Banks, error) {
|
|
log.Printf("DAL::Banks")
|
|
|
|
if dal.Db == nil {
|
|
log.Panic("database not available")
|
|
}
|
|
|
|
rows, err := dal.Db.Query("SELECT b.name, b.name, n.requisition_id FROM pfbudget.banks b JOIN pfbudget.banks_nordigen n ON b.name = n.name")
|
|
if err != nil {
|
|
return entity.Banks{}, err
|
|
}
|
|
|
|
return convert[entity.Bank](rows), nil
|
|
}
|