This commit is contained in:
24
dataBase.go
24
dataBase.go
@ -164,6 +164,30 @@ func (db *dbLayer) getPlayerByName(ctx context.Context, name string) (*Player, e
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
func (db *dbLayer) getKillsByOPlayerID(ctx context.Context, playerID string) (int, error) {
|
||||
query := "SELECT SUM(count) FROM killings WHERE player_id = $1 GROUP BY player_id"
|
||||
|
||||
rows, err := db.db.QueryContext(ctx, query, playerID)
|
||||
if err != nil {
|
||||
return 0, errors.Wrapf(err, "Failed to run db query [%s]", query)
|
||||
}
|
||||
|
||||
defer rows.Close()
|
||||
|
||||
if rows.Next() {
|
||||
var killsNum int
|
||||
|
||||
err = rows.Scan(&killsNum)
|
||||
if err != nil {
|
||||
return 0, errors.Wrap(err, "Failed to fetch data base")
|
||||
}
|
||||
|
||||
return killsNum, nil
|
||||
}
|
||||
|
||||
return 0, nil
|
||||
}
|
||||
|
||||
func (db *dbLayer) createPlayer(ctx context.Context, name string, lastOnline time.Time) (*Player, error) {
|
||||
id := uuid()
|
||||
|
||||
|
Reference in New Issue
Block a user