dbms: added missing files.

dbms/include/DB/Columns/ColumnArray.h

@@ -0,0 +1,107 @@
+#ifndef DBMS_CORE_COLUMN_ARRAY_H
+#define DBMS_CORE_COLUMN_ARRAY_H
+
+#include <Poco/SharedPtr.h>
+
+#include <DB/Core/Exception.h>
+#include <DB/Core/ErrorCodes.h>
+
+#include <DB/Columns/IColumn.h>
+
+
+namespace DB
+{
+
+using Poco::SharedPtr;
+
+/** Cтолбeц значений типа массив.
+  * В памяти он представлен, как один столбец вложенного типа, размер которого равен сумме размеров всех массивов,
+  *  и как массив смещений в нём, который позволяет достать каждый элемент.
+  */
+class ColumnArray : public IColumn
+{
+public:
+	/** По индексу i находится смещение до начала i + 1 -го элемента. */
+	typedef std::vector<size_t> Offsets_t;
+
+	/** Создать пустой столбец массивов, с типом значений, как в столбце nested_column */
+	ColumnArray(SharedPtr<IColumn> nested_column)
+		: data(nested_column)
+	{
+		data->clear();
+	}
+	
+	size_t size() const
+	{
+		return offsets.size();
+	}
+	
+	Field operator[](size_t n) const
+	{
+		size_t offset = n == 0 ? 0 : offsets[n - 1];
+		size_t size = offsets[n] - offset;
+		Array res(size);
+		
+		for (size_t i = 0; i < size; ++i)
+			res[i] = (*data)[offset + i];
+			
+		return res;
+	}
+
+	void cut(size_t start, size_t length)
+	{
+		if (start + length > offsets.size())
+			throw Exception("Parameter out of bound in IColumnArray::cut() method.",
+				ErrorCodes::PARAMETER_OUT_OF_BOUND);
+
+		if (start == 0)
+			offsets.resize(length);
+		else
+		{
+			Offsets_t tmp(length);
+			memcpy(&tmp[0], &offsets[start], length * sizeof(offsets[0]));
+			tmp.swap(offsets);
+		}
+
+		size_t nested_offset = start == 0 ? 0 : offsets[start - 1];
+		size_t nested_length = offsets[start + length] - nested_offset;
+		
+		data->cut(nested_offset, nested_length);
+	}
+
+	void clear()
+	{
+		data->clear();
+		offsets.clear();
+	}
+
+	/** Более эффективные методы манипуляции */
+	IColumn & getData()
+	{
+		return *data;
+	}
+
+	const IColumn & getData() const
+	{
+		return *data;
+	}
+
+	Offsets_t & getOffsets()
+	{
+		return offsets;
+	}
+
+	const Offsets_t & getOffsets() const
+	{
+		return offsets;
+	}
+
+protected:
+	SharedPtr<IColumn> data;
+	Offsets_t offsets;
+};
+
+
+}
+
+#endif

dbms/include/DB/Columns/ColumnFixedArray.h

@@ -0,0 +1,71 @@
+#ifndef DBMS_CORE_COLUMN_FIXED_ARRAY_H
+#define DBMS_CORE_COLUMN_FIXED_ARRAY_H
+
+#include <Poco/SharedPtr.h>
+
+#include <DB/Core/Exception.h>
+#include <DB/Core/ErrorCodes.h>
+
+#include <DB/Columns/IColumn.h>
+
+
+namespace DB
+{
+
+using Poco::SharedPtr;
+
+/** Cтолбeц значений типа "массив фиксированного размера".
+  */
+class ColumnFixedArray : public IColumn
+{
+public:
+	/** Создать пустой столбец массивов фиксированного размера n, со типом значений, как в столбце nested_column */
+	ColumnVector(SharedPtr<IColumn> nested_column, size_t n_)
+		: data(nested_column), n(n_)
+	{
+		data.clear();
+	}
+	
+	size_t size() const
+	{
+		return data->size() / n;
+	}
+	
+	Field operator[](size_t index) const
+	{
+		Array res;
+		for (size_t i = n * index; i < n * (index + 1); ++i)
+			res[i] = (*data)[n * index + i];
+		return res;
+	}
+
+	void cut(size_t start, size_t length)
+	{
+		data->cut(n * start, n * length);
+	}
+
+	void clear()
+	{
+		data.clear();
+	}
+
+	/** Более эффективные методы манипуляции */
+	IColumn & getData()
+	{
+		return *data;
+	}
+
+	const IColumn & getData() const
+	{
+		return *data;
+	}
+
+private:
+	SharedPtr<IColumn> data;
+	const size_t n;
+};
+
+
+}
+
+#endif

dbms/include/DB/Columns/ColumnNullable.h

@@ -0,0 +1,97 @@
+#ifndef DBMS_CORE_COLUMN_NULLABLE_H
+#define DBMS_CORE_COLUMN_NULLABLE_H
+
+#include <Poco/SharedPtr.h>
+
+#include <DB/Core/Exception.h>
+#include <DB/Core/ErrorCodes.h>
+
+#include <DB/Columns/IColumn.h>
+
+
+namespace DB
+{
+
+using Poco::SharedPtr;
+
+/** Cтолбeц значений, которые могут принимать значения некоторого типа или NULL.
+  * В памяти он представлен, как столбец вложенного типа,
+  *  а также как массив флагов, является ли соответствующий элемент NULL-ом.
+  */
+class ColumnNullable : public IColumn
+{
+public:
+	typedef char Flag_t;
+	typedef std::vector<Flag_t> Nulls_t;
+
+	/** Создать пустой столбец, с типом значений, как в столбце nested_column */
+	ColumnVector(SharedPtr<IColumn> nested_column)
+		: data(nested_column)
+	{
+		data.clear();
+	}
+	
+	size_t size() const
+	{
+		return data->size();
+	}
+	
+	Field operator[](size_t n) const
+	{
+		return nulls[n] ? boost::none : (*data)[n];
+	}
+
+	void cut(size_t start, size_t length)
+	{
+		if (start + length > nulls.size())
+			throw Exception("Parameter out of bound in IColumnNullable::cut() method.",
+				ErrorCodes::PARAMETER_OUT_OF_BOUND);
+
+		if (start == 0)
+			nulls.resize(length);
+		else
+		{
+			Nulls_t tmp(length);
+			memcpy(&tmp[0], &nulls[start], length * sizeof(nulls[0]));
+			tmp.swap(nulls);
+		}
+	
+		data->cut(start, length);
+	}
+
+	void clear()
+	{
+		data.clear();
+		nulls.clear();
+	}
+
+	/** Более эффективные методы манипуляции */
+	IColumn & getData()
+	{
+		return *data;
+	}
+
+	const IColumn & getData() const
+	{
+		return *data;
+	}
+
+	Nulls_t & getNulls()
+	{
+		return nulls;
+	}
+
+	const Nulls_t & getNulls() const
+	{
+		return nulls;
+	}
+
+private:
+	SharedPtr<IColumn> data;
+	Nulls_t nulls;
+};
+
+
+}
+
+#endif