TypePropertiesBuilder.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;

namespace kinetica.SchemaBuilder;

    public sealed class TypePropertiesBuilder
    {
        private readonly Dictionary<string, IList<string>> _properties;

        public TypePropertiesBuilder()
        {
            _properties = new Dictionary<string, IList<string>>(StringComparer.OrdinalIgnoreCase);
        }

        public TypePropertiesBuilder Column(string name, KineticaColumnProperties props)
        {
            _properties[name] = props.Build();
            return this;
        }

        public TypePropertiesBuilder ColumnProperty(string name, string property)
        {
            if (!_properties.TryGetValue(name, out var propList))
            {
                propList = new List<string>();
                _properties[name] = propList;
            }

            if (!propList.Contains(property))
                propList.Add(property);

            return this;
        }

        public TypePropertiesBuilder PrimaryKey(string name)
        {
            return ColumnProperty(name, "primary_key");
        }

        public TypePropertiesBuilder ShardKey(string name)
        {
            return ColumnProperty(name, "shard_key");
        }

        public TypePropertiesBuilder Nullable(string name)
        {
            return ColumnProperty(name, "nullable");
        }

        public TypePropertiesBuilder Timestamp(string name)
        {
            return ColumnProperty(name, "timestamp");
        }

        public TypePropertiesBuilder Data(string name)
        {
            return ColumnProperty(name, "data");
        }

        public TypePropertiesBuilder Ipv4(string name)
        {
            return ColumnProperty(name, "ipv4");
        }

        public TypePropertiesBuilder Date(string name)
        {
            return ColumnProperty(name, "date");
        }

        public TypePropertiesBuilder DateTime(string name)
        {
            return ColumnProperty(name, "datetime");
        }

        public TypePropertiesBuilder Time(string name)
        {
            return ColumnProperty(name, "time");
        }

        public TypePropertiesBuilder Decimal(string name)
        {
            return ColumnProperty(name, "decimal");
        }

        public TypePropertiesBuilder Uuid(string name)
        {
            return ColumnProperty(name, "uuid");
        }

        public TypePropertiesBuilder Boolean(string name)
        {
            return ColumnProperty(name, "boolean");
        }

        public TypePropertiesBuilder Int8(string name)
        {
            return ColumnProperty(name, "int8");
        }

        public TypePropertiesBuilder Int16(string name)
        {
            return ColumnProperty(name, "int16");
        }

        public TypePropertiesBuilder Wkt(string name)
        {
            return ColumnProperty(name, "wkt");
        }

        public TypePropertiesBuilder CharN(string name, int n)
        {
            var prop = n switch
            {
                1 => "char1",
                2 => "char2",
                4 => "char4",
                8 => "char8",
                16 => "char16",
                32 => "char32",
                64 => "char64",
                128 => "char128",
                256 => "char256",
                _ => throw new ArgumentException($"Invalid char length: {n}", nameof(n))
            };
            return ColumnProperty(name, prop);
        }

        public IReadOnlyDictionary<string, IList<string>> Build()
        {
            return new Dictionary<string, IList<string>>(_properties, StringComparer.OrdinalIgnoreCase);
        }
    }