| 409 | // Filtering (one -> one) access methods |
| 410 | |
| 411 | class SingularStream : public RecordSource |
| 412 | { |
| 413 | public: |
| 414 | SingularStream(CompilerScratch* csb, RecordSource* next); |
| 415 | |
| 416 | void close(thread_db* tdbb) const override; |
| 417 | |
| 418 | bool refetchRecord(thread_db* tdbb) const override; |
| 419 | WriteLockResult lockRecord(thread_db* tdbb) const override; |
| 420 | |
| 421 | void getChildren(Firebird::Array<const RecordSource*>& children) const override; |
| 422 | |
| 423 | void print(thread_db* tdbb, Firebird::string& plan, |
| 424 | bool detailed, unsigned level, bool recurse) const override; |
| 425 | |
| 426 | void markRecursive() override; |
| 427 | void invalidateRecords(Request* request) const override; |
| 428 | |
| 429 | void findUsedStreams(StreamList& streams, bool expandAll = false) const override; |
| 430 | bool isDependent(const StreamList& streams) const override; |
| 431 | void nullRecords(thread_db* tdbb) const override; |
| 432 | |
| 433 | protected: |
| 434 | void internalOpen(thread_db* tdbb) const override; |
| 435 | bool internalGetRecord(thread_db* tdbb) const override; |
| 436 | |
| 437 | private: |
| 438 | void process(thread_db* tdbb) const; |
| 439 | |
| 440 | NestConst<RecordSource> m_next; |
| 441 | StreamList m_streams; |
| 442 | }; |
| 443 | |
| 444 | class LockedStream : public RecordSource |
| 445 | { |