KineticaColumnProperties.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;

namespace kinetica.SchemaBuilder;

    public sealed class KineticaColumnProperties
    {
        private readonly List<string> _properties;

        public KineticaColumnProperties()
        {
            _properties = new List<string>();
        }

        public KineticaColumnProperties PrimaryKey()
        {
            AddIfNotExists("primary_key");
            return this;
        }

        public KineticaColumnProperties ShardKey()
        {
            AddIfNotExists("shard_key");
            return this;
        }

        public KineticaColumnProperties Nullable()
        {
            AddIfNotExists("nullable");
            return this;
        }

        public KineticaColumnProperties Timestamp()
        {
            AddIfNotExists("timestamp");
            return this;
        }

        public KineticaColumnProperties Data()
        {
            AddIfNotExists("data");
            return this;
        }

        public KineticaColumnProperties Ipv4()
        {
            AddIfNotExists("ipv4");
            return this;
        }

        public KineticaColumnProperties Wkt()
        {
            AddIfNotExists("wkt");
            return this;
        }

        public KineticaColumnProperties CharN(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}. Must be 1, 2, 4, 8, 16, 32, 64, 128, or 256.", nameof(n))
            };
            AddIfNotExists(prop);
            return this;
        }

        public KineticaColumnProperties Int8()
        {
            AddIfNotExists("int8");
            return this;
        }

        public KineticaColumnProperties Int16()
        {
            AddIfNotExists("int16");
            return this;
        }

        public KineticaColumnProperties Date()
        {
            AddIfNotExists("date");
            return this;
        }

        public KineticaColumnProperties Time()
        {
            AddIfNotExists("time");
            return this;
        }

        public KineticaColumnProperties DateTime()
        {
            AddIfNotExists("datetime");
            return this;
        }

        public KineticaColumnProperties Decimal()
        {
            AddIfNotExists("decimal");
            return this;
        }

        public KineticaColumnProperties Uuid()
        {
            AddIfNotExists("uuid");
            return this;
        }

        public KineticaColumnProperties Ulong()
        {
            AddIfNotExists("ulong");
            return this;
        }

        public KineticaColumnProperties Boolean()
        {
            AddIfNotExists("boolean");
            return this;
        }

        public KineticaColumnProperties Json()
        {
            AddIfNotExists("json");
            return this;
        }

        public KineticaColumnProperties Array()
        {
            AddIfNotExists("array");
            return this;
        }

        public KineticaColumnProperties Vector()
        {
            AddIfNotExists("vector");
            return this;
        }

        public KineticaColumnProperties Property(string property)
        {
            if (!string.IsNullOrEmpty(property))
                AddIfNotExists(property);
            return this;
        }

        public IList<string> Build()
        {
            return new List<string>(_properties);
        }

        private void AddIfNotExists(string property)
        {
            if (!_properties.Contains(property))
                _properties.Add(property);
        }
    }