Explorar o código

Use prepared statement for intervals

jvoisin %!s(int64=2) %!d(string=hai) anos
pai
achega
7660910232
Modificáronse 2 ficheiros con 4 adicións e 4 borrados
  1. 2 2
      internal/storage/session.go
  2. 2 2
      internal/storage/user_session.go

+ 2 - 2
internal/storage/session.go

@@ -128,9 +128,9 @@ func (s *Storage) CleanOldSessions(days int) int64 {
 		DELETE FROM
 		DELETE FROM
 			sessions
 			sessions
 		WHERE
 		WHERE
-			created_at < now() - interval '%d days'
+			created_at < now() - $1::interval
 	`
 	`
-	result, err := s.db.Exec(fmt.Sprintf(query, days))
+	result, err := s.db.Exec(query, fmt.Sprintf("%d days", days))
 	if err != nil {
 	if err != nil {
 		return 0
 		return 0
 	}
 	}

+ 2 - 2
internal/storage/user_session.go

@@ -170,9 +170,9 @@ func (s *Storage) CleanOldUserSessions(days int) int64 {
 		DELETE FROM
 		DELETE FROM
 			user_sessions
 			user_sessions
 		WHERE
 		WHERE
-			created_at < now() - interval '%d days'
+			created_at < now() - $1::interval
 	`
 	`
-	result, err := s.db.Exec(fmt.Sprintf(query, days))
+	result, err := s.db.Exec(query, fmt.Sprintf("%d days", days))
 	if err != nil {
 	if err != nil {
 		return 0
 		return 0
 	}
 	}