QueryContext.Sequences.cs

Go to the documentation of this file.

using System;

using Deveel.Data.Sql.Objects;
using Deveel.Data.Transactions;

namespace Deveel.Data.Sql.Sequences {
    public static class QueryContext {
        public static ISequence GetSequence(this IQueryContext context, ObjectName sequenceName) {
            return context.GetObject(DbObjectType.Sequence, sequenceName, AccessType.Read) as ISequence;
        }

        public static SqlNumber GetNextValue(this IQueryContext context, ObjectName sequenceName) {
            var sequence = context.GetSequence(sequenceName);
            if (sequence == null)
                throw new InvalidOperationException(String.Format("Sequence {0} was not found.", sequenceName));

            return sequence.NextValue();
        }

        public static SqlNumber GetCurrentValue(this IQueryContext context, ObjectName sequenceName) {
            var sequence = context.GetSequence(sequenceName);
            if (sequence == null)
                throw new InvalidOperationException(String.Format("Sequence {0} was not found.", sequenceName));

            return sequence.GetCurrentValue();
        }

        public static void SetCurrentValue(this IQueryContext context, ObjectName sequenceName, SqlNumber value) {
            var sequence = context.GetSequence(sequenceName);
            if (sequence == null)
                throw new InvalidOperationException(String.Format("Sequence {0} was not found.", sequenceName));

            sequence.SetValue(value);
        }
    }
}