Deveel.Data.Sql.Query.QueryPlanSerializers Class Reference

Classes
class	CacheNodePointSerializer
class	CompositeNodeSerializer
class	ConstantSelectNodeSerializer
class	CreateFunctionNodeSerializer
class	DistinctNodeSerializer
class	EquiJoinNodeSerializer
class	ExhaustiveSelectNodeSerializer
class	FetchTableNodeSerializer
class	FetchViewNodeSerializer
class	GroupNodeSerializer
class	JoinNodeSerializer
class	LeftOuterJoinNodeSerializer
class	LimitNodeSerializer
class	LogicalUnionNodeSerializer
class	MarkerNodeSerializer
class	NaturalJoinNodeSerializer
class	NonCorrelatedAnyAllNodeSerializer
class	QueryPlanNodeSerializer
class	QueryPlanNodeSerializerResolver
class	RageSelectNodeSerializer
class	SimplePatternSelectNodeSerializer
class	SimpleSelectNodeSerializer
class	SingleRowTableNodeSerializer
class	SortNodeSerializer
class	SubsetNodeSerializer

Static Public Member Functions
static void	Serialize (IQueryPlanNode queryPlan, BinaryWriter writer)
static IQueryPlanNode	Deserialize (Type nodeType, Stream inputStream)
static IQueryPlanNode	Deserialize (Type nodeType, BinaryReader reader)

Static Public Attributes
static readonly IObjectSerializerResolver	Resolver = new QueryPlanNodeSerializerResolver()

Static Package Functions
static void	RegisterSerializers (ISystemContext context)

Static Private Member Functions
static void	WriteChildNode (BinaryWriter writer, IQueryPlanNode node)
static IQueryPlanNode	ReadChildNode (BinaryReader reader)
static void	WriteArray< T > (T[] arrary, BinaryWriter writer, Action< T, BinaryWriter > write)
static void	WriteObjectNames (ObjectName[] names, BinaryWriter writer)
static void	WriteExpressions (SqlExpression[] expressions, BinaryWriter writer)
static void	WriteStrings (string[] array, BinaryWriter writer)
static T[]	ReadArray< T > (BinaryReader reader, Func< BinaryReader, T > read)
static ObjectName[]	ReadObjectNames (BinaryReader reader)
static SqlExpression[]	ReadExpressions (BinaryReader reader)
static string[]	ReadStrings (BinaryReader reader)

Detailed Description

Definition at line 27 of file QueryPlanSerializers.cs.

Member Function Documentation

static IQueryPlanNode Deveel.Data.Sql.Query.QueryPlanSerializers.Deserialize ( Type  nodeType, Stream  inputStream  )

inlinestatic

Definition at line 65 of file QueryPlanSerializers.cs.

                                                                                    {
            var seriializer = Resolver.ResolveSerializer(nodeType);
            if (seriializer == null)
                throw new InvalidOperationException(String.Format("Could not find any serializer for type '{0}'.", nodeType));

            return seriializer.Deserialize(inputStream) as IQueryPlanNode;
        }

static IQueryPlanNode Deveel.Data.Sql.Query.QueryPlanSerializers.Deserialize ( Type  nodeType, BinaryReader  reader  )

inlinestatic

Definition at line 73 of file QueryPlanSerializers.cs.

                                                                                     {
            var seriializer = Resolver.ResolveSerializer(nodeType) as IObjectBinarySerializer;
            if (seriializer == null)
                throw new InvalidOperationException(String.Format("Could not find any serializer for type '{0}'.", nodeType));

            return (IQueryPlanNode) seriializer.Deserialize(reader);
        }

static T [] Deveel.Data.Sql.Query.QueryPlanSerializers.ReadArray< T > ( BinaryReader  reader, Func< BinaryReader, T >  read  )

inlinestaticprivate

Definition at line 131 of file QueryPlanSerializers.cs.

                                                                                         {
            var count = reader.ReadInt32();
            var list = new List<T>(count);
            for (int i = 0; i < count; i++) {
                var obj = read(reader);
                list.Add(obj);
            }

            return list.ToArray();
        }

static IQueryPlanNode Deveel.Data.Sql.Query.QueryPlanSerializers.ReadChildNode ( BinaryReader  reader )

inlinestaticprivate

Definition at line 93 of file QueryPlanSerializers.cs.

                                                                         {
            var state = reader.ReadByte();
            if (state == 0)
                return null;

            var typeString = reader.ReadString();
#if PCL
            var type = Type.GetType(typeString, true);
#else
            var type = Type.GetType(typeString, true, true);
#endif

            return Deserialize(type, reader);
        }

static SqlExpression [] Deveel.Data.Sql.Query.QueryPlanSerializers.ReadExpressions ( BinaryReader  reader )

inlinestaticprivate

Definition at line 146 of file QueryPlanSerializers.cs.

                                                                            {
            return ReadArray(reader, binaryReader => SqlExpression.Deserialize(reader));
        }

static ObjectName [] Deveel.Data.Sql.Query.QueryPlanSerializers.ReadObjectNames ( BinaryReader  reader )

inlinestaticprivate

Definition at line 142 of file QueryPlanSerializers.cs.

                                                                         {
            return ReadArray(reader, ObjectName.Deserialize);
        }

static string [] Deveel.Data.Sql.Query.QueryPlanSerializers.ReadStrings ( BinaryReader  reader )

inlinestaticprivate

Definition at line 150 of file QueryPlanSerializers.cs.

                                                                 {
            return ReadArray(reader, binaryReader => binaryReader.ReadString());
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.RegisterSerializers ( ISystemContext  context )

inlinestaticpackage

Definition at line 30 of file QueryPlanSerializers.cs.

                                                                         {
            context.RegisterService<CacheNodePointSerializer>();
            context.RegisterService<CompositeNodeSerializer>();
            context.RegisterService<ConstantSelectNodeSerializer>();
            context.RegisterService<CreateFunctionNodeSerializer>();
            context.RegisterService<DistinctNodeSerializer>();
            context.RegisterService<EquiJoinNodeSerializer>();
            context.RegisterService<ExhaustiveSelectNodeSerializer>();
            context.RegisterService<FetchTableNodeSerializer>();
            context.RegisterService<FetchViewNodeSerializer>();
            context.RegisterService<GroupNodeSerializer>();
            context.RegisterService<JoinNodeSerializer>();
            context.RegisterService<LeftOuterJoinNodeSerializer>();
            context.RegisterService<LogicalUnionNodeSerializer>();
            context.RegisterService<MarkerNodeSerializer>();
            context.RegisterService<NaturalJoinNodeSerializer>();
            context.RegisterService<NonCorrelatedAnyAllNodeSerializer>();
            context.RegisterService<RageSelectNodeSerializer>();
            context.RegisterService<SimplePatternSelectNodeSerializer>();
            context.RegisterService<SimpleSelectNodeSerializer>();
            context.RegisterService<SingleRowTableNodeSerializer>();
            context.RegisterService<SortNodeSerializer>();
            context.RegisterService<SubsetNodeSerializer>();
            context.RegisterService<LimitNodeSerializer>();
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.Serialize ( IQueryPlanNode  queryPlan, BinaryWriter  writer  )

inlinestatic

Definition at line 56 of file QueryPlanSerializers.cs.

                                                                                    {
            var nodeType = queryPlan.GetType();
            var seriializer = Resolver.ResolveSerializer(nodeType) as IObjectBinarySerializer;
            if (seriializer == null)
                throw new InvalidOperationException(String.Format("Could not find any serializer for type '{0}'.", nodeType));

            seriializer.Serialize(queryPlan, writer);           
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.WriteArray< T > ( T[]  arrary, BinaryWriter  writer, Action< T, BinaryWriter >  write  )

inlinestaticprivate

Definition at line 108 of file QueryPlanSerializers.cs.

                                                                                                          {
            var count = arrary == null ? 0 : arrary.Length;
            writer.Write(count);

            if (arrary != null) {
                for (int i = 0; i < count; i++) {
                    write(arrary[i], writer);
                }
            }
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.WriteChildNode ( BinaryWriter  writer, IQueryPlanNode  node  )

inlinestaticprivate

Definition at line 81 of file QueryPlanSerializers.cs.

                                                                                     {
            if (node == null) {
                writer.Write((byte) 0);
            } else {
                var nodeTypeString = node.GetType().FullName;
                writer.Write((byte)1);
                writer.Write(nodeTypeString);

                Serialize(node, writer);
            }
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.WriteExpressions ( SqlExpression[]  expressions, BinaryWriter  writer  )

inlinestaticprivate

Definition at line 123 of file QueryPlanSerializers.cs.

                                                                                               {
            WriteArray(expressions, writer, (expression, binaryWriter) => SqlExpression.Serialize(expression, binaryWriter));
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.WriteObjectNames ( ObjectName[]  names, BinaryWriter  writer  )

inlinestaticprivate

Definition at line 119 of file QueryPlanSerializers.cs.

                                                                                      {
            WriteArray(names, writer, ObjectName.Serialize);
        }

static void Deveel.Data.Sql.Query.QueryPlanSerializers.WriteStrings ( string[]  array, BinaryWriter  writer  )

inlinestaticprivate

Definition at line 127 of file QueryPlanSerializers.cs.

                                                                              {
            WriteArray(array, writer, (s, binaryWriter) => binaryWriter.Write(s));
        }

Member Data Documentation

readonly IObjectSerializerResolver Deveel.Data.Sql.Query.QueryPlanSerializers.Resolver = new QueryPlanNodeSerializerResolver()

static

Definition at line 28 of file QueryPlanSerializers.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.Query/QueryPlanSerializers.cs