60 lines
1.5 KiB
Go
60 lines
1.5 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"log"
|
|
|
|
"git.agecem.com/bottin/agendas/queries"
|
|
"github.com/jackc/pgx/v5/pgxpool"
|
|
)
|
|
|
|
type DBClient struct {
|
|
Pool *pgxpool.Pool
|
|
}
|
|
|
|
func (d DBClient) Ping(ctx context.Context) error {
|
|
select {
|
|
case <-ctx.Done():
|
|
return ctx.Err()
|
|
default:
|
|
if d.Pool == nil {
|
|
return fmt.Errorf("db: cannot check health using nil connection pool")
|
|
}
|
|
|
|
return d.Pool.Ping(ctx)
|
|
}
|
|
}
|
|
|
|
func (d DBClient) Init(ctx context.Context) error {
|
|
//TODO check context is not closed
|
|
//TODO check *DB is not nil
|
|
log.Println("warning: DBClient [Init] not properly checked")
|
|
// Init
|
|
if _, err := d.Pool.Exec(ctx, queries.SQLSchema()); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (d DBClient) CreateTransaction(ctx context.Context, transaction Transaction) error {
|
|
//TODO check context is not closed
|
|
//TODO check *DB is not nil
|
|
//TODO CreateTransaction
|
|
return fmt.Errorf("db: CreateTransaction not implemented")
|
|
}
|
|
|
|
func (d DBClient) ReadTransaction(ctx context.Context, membreID string, isPerpetual bool) error {
|
|
//TODO check context is not closed
|
|
//TODO check *DB is not nil
|
|
//TODO ReadTransaction
|
|
return fmt.Errorf("db: ReadTransaction not implemented")
|
|
}
|
|
|
|
func (d DBClient) CountTransactions(ctx context.Context) (membresSansAgenda, membresAvecPerpetuel, membresAvecNonPerpetuel, membresAvecTout int, err error) {
|
|
//TODO check context is not closed
|
|
//TODO check *DB is not nil
|
|
//TODO CountTransactions
|
|
return 0, 0, 0, 0, fmt.Errorf("db: CountTransactions not implemented")
|
|
}
|