| 1 | //===----------------------------------------------------------------------===// |
| 2 | // DuckDB |
| 3 | // |
| 4 | // duckdb/parser/column_list.hpp |
| 5 | // |
| 6 | // |
| 7 | //===----------------------------------------------------------------------===// |
| 8 | |
| 9 | #pragma once |
| 10 | |
| 11 | #include "duckdb/parser/column_definition.hpp" |
| 12 | #include "duckdb/common/field_writer.hpp" |
| 13 | |
| 14 | namespace duckdb { |
| 15 | |
| 16 | //! A set of column definitions |
| 17 | class ColumnList { |
| 18 | public: |
| 19 | class ColumnListIterator; |
| 20 | |
| 21 | public: |
| 22 | DUCKDB_API ColumnList(bool allow_duplicate_names = false); |
| 23 | |
| 24 | DUCKDB_API void AddColumn(ColumnDefinition column); |
| 25 | void Finalize(); |
| 26 | |
| 27 | DUCKDB_API const ColumnDefinition &GetColumn(LogicalIndex index) const; |
| 28 | DUCKDB_API const ColumnDefinition &GetColumn(PhysicalIndex index) const; |
| 29 | DUCKDB_API const ColumnDefinition &GetColumn(const string &name) const; |
| 30 | DUCKDB_API ColumnDefinition &GetColumnMutable(LogicalIndex index); |
| 31 | DUCKDB_API ColumnDefinition &GetColumnMutable(PhysicalIndex index); |
| 32 | DUCKDB_API ColumnDefinition &GetColumnMutable(const string &name); |
| 33 | DUCKDB_API vector<string> GetColumnNames() const; |
| 34 | DUCKDB_API vector<LogicalType> GetColumnTypes() const; |
| 35 | |
| 36 | DUCKDB_API bool ColumnExists(const string &name) const; |
| 37 | |
| 38 | DUCKDB_API LogicalIndex GetColumnIndex(string &column_name) const; |
| 39 | DUCKDB_API PhysicalIndex LogicalToPhysical(LogicalIndex index) const; |
| 40 | DUCKDB_API LogicalIndex PhysicalToLogical(PhysicalIndex index) const; |
| 41 | |
| 42 | idx_t LogicalColumnCount() const { |
| 43 | return columns.size(); |
| 44 | } |
| 45 | idx_t PhysicalColumnCount() const { |
| 46 | return physical_columns.size(); |
| 47 | } |
| 48 | bool empty() const { |
| 49 | return columns.empty(); |
| 50 | } |
| 51 | |
| 52 | ColumnList Copy() const; |
| 53 | void Serialize(FieldWriter &writer) const; |
| 54 | static ColumnList Deserialize(FieldReader &reader); |
| 55 | |
| 56 | DUCKDB_API ColumnListIterator Logical() const; |
| 57 | DUCKDB_API ColumnListIterator Physical() const; |
| 58 | |
| 59 | void SetAllowDuplicates(bool allow_duplicates) { |
| 60 | allow_duplicate_names = allow_duplicates; |
| 61 | } |
| 62 | |
| 63 | private: |
| 64 | vector<ColumnDefinition> columns; |
| 65 | //! A map of column name to column index |
| 66 | case_insensitive_map_t<column_t> name_map; |
| 67 | //! The set of physical columns |
| 68 | vector<idx_t> physical_columns; |
| 69 | //! Allow duplicate names or not |
| 70 | bool allow_duplicate_names; |
| 71 | |
| 72 | private: |
| 73 | void AddToNameMap(ColumnDefinition &column); |
| 74 | |
| 75 | public: |
| 76 | // logical iterator |
| 77 | class ColumnListIterator { |
| 78 | public: |
| 79 | ColumnListIterator(const ColumnList &list, bool physical) : list(list), physical(physical) { |
| 80 | } |
| 81 | |
| 82 | private: |
| 83 | const ColumnList &list; |
| 84 | bool physical; |
| 85 | |
| 86 | private: |
| 87 | class ColumnLogicalIteratorInternal { |
| 88 | public: |
| 89 | ColumnLogicalIteratorInternal(const ColumnList &list, bool physical, idx_t pos, idx_t end) |
| 90 | : list(list), physical(physical), pos(pos), end(end) { |
| 91 | } |
| 92 | |
| 93 | const ColumnList &list; |
| 94 | bool physical; |
| 95 | idx_t pos; |
| 96 | idx_t end; |
| 97 | |
| 98 | public: |
| 99 | ColumnLogicalIteratorInternal &operator++() { |
| 100 | pos++; |
| 101 | return *this; |
| 102 | } |
| 103 | bool operator!=(const ColumnLogicalIteratorInternal &other) const { |
| 104 | return pos != other.pos || end != other.end || &list != &other.list; |
| 105 | } |
| 106 | const ColumnDefinition &operator*() const { |
| 107 | if (physical) { |
| 108 | return list.GetColumn(index: PhysicalIndex(pos)); |
| 109 | } else { |
| 110 | return list.GetColumn(index: LogicalIndex(pos)); |
| 111 | } |
| 112 | } |
| 113 | }; |
| 114 | |
| 115 | public: |
| 116 | idx_t Size() { |
| 117 | return physical ? list.PhysicalColumnCount() : list.LogicalColumnCount(); |
| 118 | } |
| 119 | |
| 120 | ColumnLogicalIteratorInternal begin() { |
| 121 | return ColumnLogicalIteratorInternal(list, physical, 0, Size()); |
| 122 | } |
| 123 | ColumnLogicalIteratorInternal end() { |
| 124 | return ColumnLogicalIteratorInternal(list, physical, Size(), Size()); |
| 125 | } |
| 126 | }; |
| 127 | }; |
| 128 | |
| 129 | } // namespace duckdb |
| 130 | |