Deveel.Data.Sql.Cursors.Cursor Class Reference

Inheritance diagram for Deveel.Data.Sql.Cursors.Cursor:

Classes
class	CursorArgumentPreparer

Public Member Functions
void	Open (IRequest context, params SqlExpression[] args)
void	Close ()
void	FetchInto (FetchContext context)
void	Dispose ()

Package Functions
	Cursor (CursorInfo cursorInfo)

Properties
CursorInfo	CursorInfo [get, private set]
CursorStatus	Status [get]
CursorState	State [get, private set]
ObjectName IDbObject.	FullName [get]
DbObjectType IDbObject.	ObjectType [get]
SqlQueryExpression	QueryExpression [get]
Properties inherited from Deveel.Data.Sql.IDbObject
ObjectName	FullName [get]
	Gets the fully qualified name of the object used to resolve it uniquely within the database. More...
DbObjectType	ObjectType [get]
	Gets the type of database object that the implementation is for More...

Private Member Functions
	~Cursor ()
void	AssertNotDisposed ()
SqlQueryExpression	PrepareQuery (SqlExpression[] args)
Dictionary< string, SqlExpression >	BuildArgs (IEnumerable< CursorParameter > parameters, SqlExpression[] args)
ITable	Evaluate (IRequest context, SqlExpression[] args)
void	FetchIntoVatiable (IRequest request, Row row, string varName)
void	FetchIntoReference (IRequest request, Row row, ObjectName reference)
void	Dispose (bool disposing)

Detailed Description

Definition at line 26 of file Cursor.cs.

Constructor & Destructor Documentation

Deveel.Data.Sql.Cursors.Cursor.Cursor ( CursorInfo  cursorInfo )

inlinepackage

Definition at line 27 of file Cursor.cs.

                                               {
            if (cursorInfo == null)
                throw new ArgumentNullException("cursorInfo");

            CursorInfo = cursorInfo;
            State = new CursorState(this);
        }

Deveel.Data.Sql.Cursors.Cursor.~Cursor ( )

inlineprivate

Definition at line 35 of file Cursor.cs.

                  {
            Dispose(false);
        }

Member Function Documentation

void Deveel.Data.Sql.Cursors.Cursor.AssertNotDisposed ( )

inlineprivate

Definition at line 59 of file Cursor.cs.

                                         {
            if (Status == CursorStatus.Disposed)
                throw new ObjectDisposedException("Cursor");
        }

Dictionary<string, SqlExpression> Deveel.Data.Sql.Cursors.Cursor.BuildArgs ( IEnumerable< CursorParameter >  parameters, SqlExpression[]  args  )

inlineprivate

Definition at line 75 of file Cursor.cs.

                                                                                                                           {
            var orderedParams = parameters.OrderBy(x => x.Offset).ToArray();
            if (args == null || args.Length != orderedParams.Length)
                throw new ArgumentException();

            var result = new Dictionary<string, SqlExpression>();
            for (int i = 0; i < orderedParams.Length; i++) {
                var param = orderedParams[i];
                var arg = args[i];
                result[param.ParameterName] = arg;
            }

            return result;
        }

void Deveel.Data.Sql.Cursors.Cursor.Close ( )

inline

Definition at line 113 of file Cursor.cs.

                            {
            lock (this) {
                AssertNotDisposed();
                State.Close();
            }
        }

void Deveel.Data.Sql.Cursors.Cursor.Dispose ( )

inline

Definition at line 158 of file Cursor.cs.

                              {
            Dispose(true);
            GC.SuppressFinalize(this);
        }

void Deveel.Data.Sql.Cursors.Cursor.Dispose ( bool  disposing )

inlineprivate

Definition at line 163 of file Cursor.cs.

                                             {
            if (disposing) {
                if (State != null)
                    State.Dispose();
            }

            State = null;
        }

ITable Deveel.Data.Sql.Cursors.Cursor.Evaluate ( IRequest  context, SqlExpression[]  args  )

inlineprivate

Definition at line 90 of file Cursor.cs.

                                                                        {
            try {
                var prepared = PrepareQuery(args);
                var queryPlan = context.Query.Context.QueryPlanner().PlanQuery(new QueryInfo(context, prepared));
                return queryPlan.Evaluate(context);
            } catch (Exception) {

                throw;
            }
        }

void Deveel.Data.Sql.Cursors.Cursor.FetchInto ( FetchContext  context )

inline

Definition at line 120 of file Cursor.cs.

                                                    {
            if (context == null)
                throw new ArgumentNullException("context");

            if (!CursorInfo.IsScroll &&
                context.Direction != FetchDirection.Next)
                throw new ArgumentException(String.Format("Cursor '{0}' is not SCROLL: can fetch only NEXT value.", CursorInfo.CursorName));

            var table = State.Result;
            if (!CursorInfo.IsInsensitive)
                table = Evaluate(context.Request, State.OpenArguments);

            var fetchRow = State.FetchRowFrom(table, context.Direction, context.Offset);

            if (context.IsGlobalReference) {
                var reference = ((SqlReferenceExpression) context.Reference).ReferenceName;
                FetchIntoReference(context.Request, fetchRow, reference);
            } else if (context.IsVariableReference) {
                var varName = ((SqlVariableReferenceExpression) context.Reference).VariableName;
                FetchIntoVatiable(context.Request, fetchRow, varName);
            }
        }

void Deveel.Data.Sql.Cursors.Cursor.FetchIntoReference ( IRequest  request, Row  row, ObjectName  reference  )

inlineprivate

Definition at line 147 of file Cursor.cs.

                                                                                         {
            if (reference == null)
                throw new ArgumentNullException("reference");

            var table = request.Query.GetMutableTable(reference);
            if (table == null)
                throw new ObjectNotFoundException(reference);

            throw new NotImplementedException();
        }

void Deveel.Data.Sql.Cursors.Cursor.FetchIntoVatiable ( IRequest  request, Row  row, string  varName  )

inlineprivate

Definition at line 143 of file Cursor.cs.

                                                                                  {
            throw new NotImplementedException();
        }

void Deveel.Data.Sql.Cursors.Cursor.Open ( IRequest  context, params SqlExpression[]  args  )

inline

Definition at line 101 of file Cursor.cs.

                                                                        {
            lock (this) {
                AssertNotDisposed();

                ITable result = null;
                if (CursorInfo.IsInsensitive)
                    result = Evaluate(context, args);

                State.Open(result, args);
            }
        }

SqlQueryExpression Deveel.Data.Sql.Cursors.Cursor.PrepareQuery ( SqlExpression[]  args )

inlineprivate

Definition at line 64 of file Cursor.cs.

                                                                      {
            SqlQueryExpression query = CursorInfo.QueryExpression;
            if (CursorInfo.Parameters.Count > 0) {
                var cursorArgs = BuildArgs(CursorInfo.Parameters, args);
                var preparer = new CursorArgumentPreparer(cursorArgs);
                query = query.Prepare(preparer) as SqlQueryExpression;
            }

            return query;
        }

Property Documentation

CursorInfo Deveel.Data.Sql.Cursors.Cursor.CursorInfo

getprivate set

Definition at line 39 of file Cursor.cs.

ObjectName IDbObject. Deveel.Data.Sql.Cursors.Cursor.FullName

getprivate

Definition at line 47 of file Cursor.cs.

DbObjectType IDbObject. Deveel.Data.Sql.Cursors.Cursor.ObjectType

getprivate

Definition at line 51 of file Cursor.cs.

SqlQueryExpression Deveel.Data.Sql.Cursors.Cursor.QueryExpression

get

Definition at line 55 of file Cursor.cs.

CursorState Deveel.Data.Sql.Cursors.Cursor.State

getprivate set

Definition at line 45 of file Cursor.cs.

CursorStatus Deveel.Data.Sql.Cursors.Cursor.Status

get

Definition at line 41 of file Cursor.cs.

---

The documentation for this class was generated from the following file:

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Sql.Cursors/Cursor.cs