Fix SQL statements

cloudfoundry-community · Sep 26, 2024 · 03354e1 · 03354e1
1 parent 1426876
commit 03354e1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/jetstream/repository/sessiondata/psql_sessiondata.go b/src/jetstream/repository/sessiondata/psql_sessiondata.go
@@ -19,13 +19,13 @@ var insertSessionDataValue = `INSERT INTO session_data (session, groupName, name
 var deleteSessionGroupData = `DELETE FROM session_data WHERE session=$1 AND groupName=$2`
 
 // Expire data for sessions that no longer exist
-var expireSessionData = `UPDATE session_data SET expired=true WHERE session NOT IN (SELECT id from sessions)`
+var expireSessionData = `UPDATE session_data SET expired=true WHERE session NOT IN (SELECT id::varchar from http_sessions)`
 
 // Delete data for sessions that no longer exist
 var deleteSessionData = `DELETE FROM session_data WHERE expired=true AND keep_on_expire=false`
 
 // Check if a session valid
-var isValidSession = `SELECT id, expires_on from sessions WHERE id=$1`
+var isValidSession = `SELECT id, expires_on from http_sessions WHERE id=$1`
 
 // SessionDataRepository is a RDB-backed Session Data repository
 type SessionDataRepository struct {