class ActiveRecord::ConnectionAdapters::PostgreSQLAdapter

def session_auth=(user)

Set the authorized user for this session
def session_auth=(user)
  clear_cache!
  execute("SET SESSION AUTHORIZATION #{user}")
end