agecem/bottin-agenda
5
0
Fork 0
Code Issues 2 Pull requests Projects Releases Packages Wiki Activity

format(db): aérer et standardiser requêtes SQL dans DataClient

Browse source
This commit is contained in:
Victor Lacasse-Beaudoin 2024-09-16 14:49:56 -04:00
parent 210b3f6524
commit 3646ea5aec
1 changed files with 35 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

39
data/dataclient.go
View file

@ -90,7 +90,24 @@ func (d *DataClient) InsertTransactions(transactions []models.Transaction) ([]mo
return rowsInserted, errors.New("Impossible d'insérer une transaction sans membre_id") return rowsInserted, errors.New("Impossible d'insérer une transaction sans membre_id")
} }
rows, err := tx.NamedQuery("INSERT INTO transactions (membre_id, given_at, is_perpetual) VALUES (:membre_id, current_timestamp, :is_perpetual) RETURNING id, membre_id, is_perpetual;", &transaction) rows, err := tx.NamedQuery(`
INSERT INTO
transactions (
membre_id,
given_at,
is_perpetual
)
VALUES
(
:membre_id,
current_timestamp,
:is_perpetual
)
RETURNING
id,
membre_id,
is_perpetual;
`, &transaction)
if err != nil { if err != nil {
return rowsInserted, err return rowsInserted, err
} }
@ -117,8 +134,16 @@ func (d *DataClient) InsertTransactions(transactions []models.Transaction) ([]mo
func (d *DataClient) GetTransaction(membreID string, is_perpetual bool) (models.Transaction, error) { func (d *DataClient) GetTransaction(membreID string, is_perpetual bool) (models.Transaction, error) {
var transaction models.Transaction var transaction models.Transaction
//err := d.DB.NamedQuery("SELECT * FROM transactions WHERE membre_id=:membre_id AND is_perpetual=:is_perpetual LIMIT 1;" err := d.DB.Get(&transaction, `
err := d.DB.Get(&transaction, "SELECT * FROM transactions WHERE membre_id = $1 AND is_perpetual = $2 LIMIT 1;", membreID, is_perpetual) SELECT
*
FROM
transactions
WHERE
membre_id = $1 AND
is_perpetual = $2
LIMIT 1;
`, membreID, is_perpetual)
if err != nil { if err != nil {
return transaction, err return transaction, err
} }
@ -132,7 +157,13 @@ func (d *DataClient) GetTransaction(membreID string, is_perpetual bool) (models.
func (d *DataClient) ListTransactions() ([]models.Transaction, error) { func (d *DataClient) ListTransactions() ([]models.Transaction, error) {
var transactions []models.Transaction var transactions []models.Transaction
if err := d.DB.Select(&transactions, "SELECT * FROM transactions LIMIT 20000;"); err != nil { if err := d.DB.Select(&transactions, `
SELECT
*
FROM
transactions
LIMIT 20000;
`); err != nil {
return transactions, err return transactions, err
} }