Reactive source implementation for PostgreSQL