db: add DeleteUser

This commit is contained in:
2026-04-23 16:45:41 +02:00
parent aebc012eef
commit a51a5e17e1
2 changed files with 10 additions and 0 deletions

View File

@@ -16,6 +16,7 @@ type Querier interface {
DeleteContinueWatchingEntry(ctx context.Context, arg DeleteContinueWatchingEntryParams) error
DeleteExpiredJikanCache(ctx context.Context) error
DeleteSession(ctx context.Context, id string) error
DeleteUser(ctx context.Context, id string) error
DeleteUserSessions(ctx context.Context, userID string) error
DeleteWatchListEntry(ctx context.Context, arg DeleteWatchListEntryParams) error
EnqueueAnimeFetchRetry(ctx context.Context, arg EnqueueAnimeFetchRetryParams) error

View File

@@ -115,6 +115,15 @@ func (q *Queries) DeleteSession(ctx context.Context, id string) error {
return err
}
const deleteUser = `-- name: DeleteUser :exec
DELETE FROM user WHERE id = ?
`
func (q *Queries) DeleteUser(ctx context.Context, id string) error {
_, err := q.db.ExecContext(ctx, deleteUser, id)
return err
}
const deleteUserSessions = `-- name: DeleteUserSessions :exec
DELETE FROM session WHERE user_id = ?
`