Deveel.Data.Linq.DeveelDbExecutor Class Reference

Inheritance diagram for Deveel.Data.Linq.DeveelDbExecutor:

Classes
class	TableFieldReader

Public Member Functions
	DeveelDbExecutor (IQuery context)
override object	Convert (object value, Type type)
override IEnumerable< T >	Execute< T > (QueryCommand command, Func< FieldReader, T > fnProjector, MappingEntity entity, object[] paramValues)
override IEnumerable< int >	ExecuteBatch (QueryCommand query, IEnumerable< object[]> paramSets, int batchSize, bool stream)
override IEnumerable< T >	ExecuteBatch< T > (QueryCommand query, IEnumerable< object[]> paramSets, Func< FieldReader, T > fnProjector, MappingEntity entity, int batchSize, bool stream)
override IEnumerable< T >	ExecuteDeferred< T > (QueryCommand command, Func< FieldReader, T > fnProjector, MappingEntity entity, object[] paramValues)
override int	ExecuteCommand (QueryCommand query, object[] paramValues)

Properties
override int	RowsAffected [get]

Private Member Functions
SqlQuery	GetQuery (QueryCommand command, object[] paramValues)
void	SetParameters (QueryCommand command, SqlQuery query, object[] paramValues)
void	AddParameter (SqlQuery query, QueryParameter queryParameter, object value)
SqlType	GetSqlType (Type type)
IEnumerable< T >	Project< T > (ITable result, Func< FieldReader, T > fnProjector, MappingEntity entity)

Private Attributes
IQuery	context
int	rowsAffected

Detailed Description

Definition at line 17 of file DeveelDbExecutor.cs.

Constructor & Destructor Documentation

Deveel.Data.Linq.DeveelDbExecutor.DeveelDbExecutor ( IQuery  context )

inline

Definition at line 21 of file DeveelDbExecutor.cs.

                                                {
            this.context = context;
        }

Member Function Documentation

void Deveel.Data.Linq.DeveelDbExecutor.AddParameter ( SqlQuery  query, QueryParameter  queryParameter, object  value  )

inlineprivate

Definition at line 74 of file DeveelDbExecutor.cs.

                                                                                               {
            var sqlType = GetSqlType(queryParameter.Type);
            var param = new Sql.QueryParameter(queryParameter.Name, sqlType, (ISqlObject)value);
            param.Direction = QueryParameterDirection.In;
            query.Parameters.Add(param);
        }

override object Deveel.Data.Linq.DeveelDbExecutor.Convert ( object  value, Type  type  )

inline

Definition at line 25 of file DeveelDbExecutor.cs.

                                                                {
            if (value == null) {
                return TypeHelper.GetDefault(type);
            }

            type = TypeHelper.GetNonNullableType(type);
            var vtype = value.GetType();

            if (type != vtype) {
                if (type.IsEnum) {
                    if (vtype == typeof (string))
                        return Enum.Parse(type, (string) value);

                    Type utype = Enum.GetUnderlyingType(type);
                    if (utype != vtype)
                        value = System.Convert.ChangeType(value, utype);

                    return Enum.ToObject(type, value);
                }

                return System.Convert.ChangeType(value, type);
            }

            return value;
        }

override IEnumerable<T> Deveel.Data.Linq.DeveelDbExecutor.Execute< T > ( QueryCommand  command, Func< FieldReader, T >  fnProjector, MappingEntity  entity, object[]  paramValues  )

inline

Definition at line 85 of file DeveelDbExecutor.cs.

                                                                                                                                                      {
            var query = GetQuery(command, paramValues);
            var queryResult = context.ExecuteQuery(query);

            return Project(queryResult[0], fnProjector, entity);
        }

override IEnumerable<int> Deveel.Data.Linq.DeveelDbExecutor.ExecuteBatch ( QueryCommand  query, IEnumerable< object[]>  paramSets, int  batchSize, bool  stream  )

inline

Definition at line 99 of file DeveelDbExecutor.cs.

                                                                                                                                       {
            throw new NotImplementedException();
        }

override IEnumerable<T> Deveel.Data.Linq.DeveelDbExecutor.ExecuteBatch< T > ( QueryCommand  query, IEnumerable< object[]>  paramSets, Func< FieldReader, T >  fnProjector, MappingEntity  entity, int  batchSize, bool  stream  )

inline

Definition at line 103 of file DeveelDbExecutor.cs.

                                        {
            throw new NotImplementedException();
        }

override int Deveel.Data.Linq.DeveelDbExecutor.ExecuteCommand ( QueryCommand  query, object[]  paramValues  )

inline

Definition at line 115 of file DeveelDbExecutor.cs.

                                                                                     {
            var sqlQuery = GetQuery(query, paramValues);
            var result = context.ExecuteQuery(sqlQuery);
            rowsAffected = result[0].RowCount;
            return rowsAffected;
        }

override IEnumerable<T> Deveel.Data.Linq.DeveelDbExecutor.ExecuteDeferred< T > ( QueryCommand  command, Func< FieldReader, T >  fnProjector, MappingEntity  entity, object[]  paramValues  )

inline

Definition at line 108 of file DeveelDbExecutor.cs.

                                                                                                                                                              {
            var query = GetQuery(command, paramValues);
            var queryResult = context.ExecuteQuery(query);

            return Project(queryResult[0], fnProjector, entity);
        }

SqlQuery Deveel.Data.Linq.DeveelDbExecutor.GetQuery ( QueryCommand  command, object[]  paramValues  )

inlineprivate

Definition at line 51 of file DeveelDbExecutor.cs.

                                                                              {
            var query = new SqlQuery(command.CommandText);
            SetParameters(command, query, paramValues);
            return query;
        }

SqlType Deveel.Data.Linq.DeveelDbExecutor.GetSqlType ( Type  type )

inlineprivate

Definition at line 81 of file DeveelDbExecutor.cs.

                                              {
            throw new NotImplementedException();
        }

IEnumerable<T> Deveel.Data.Linq.DeveelDbExecutor.Project< T > ( ITable  result, Func< FieldReader, T >  fnProjector, MappingEntity  entity  )

inlineprivate

Definition at line 92 of file DeveelDbExecutor.cs.

                                                                                                                 {
            var reader = new TableFieldReader(result);
            while (reader.NextRow()) {
                yield return fnProjector(reader);
            }
        }

void Deveel.Data.Linq.DeveelDbExecutor.SetParameters ( QueryCommand  command, SqlQuery  query, object[]  paramValues  )

inlineprivate

Definition at line 57 of file DeveelDbExecutor.cs.

                                                                                               {
            if (command.Parameters.Count > 0 && query.Parameters.Count == 0) {
                for (int i = 0, n = command.Parameters.Count; i < n; i++) {
                    AddParameter(query, command.Parameters[i], paramValues != null ? paramValues[i] : null);
                }
            } else if (paramValues != null) {
                var queryParams = query.Parameters.ToList();
                for (int i = 0, n = queryParams.Count; i < n; i++) {
                    var p = queryParams[i];
                    if (p.Direction == QueryParameterDirection.In
                     || p.Direction == QueryParameterDirection.InOut) {
                        p.Value = (ISqlObject) paramValues[i] ?? SqlNull.Value;
                    }
                }
            }
        }

Member Data Documentation

IQuery Deveel.Data.Linq.DeveelDbExecutor.context

private

Definition at line 18 of file DeveelDbExecutor.cs.

int Deveel.Data.Linq.DeveelDbExecutor.rowsAffected

private

Definition at line 19 of file DeveelDbExecutor.cs.

Property Documentation

override int Deveel.Data.Linq.DeveelDbExecutor.RowsAffected

get

Definition at line 122 of file DeveelDbExecutor.cs.

---

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

• /var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb-linq/Deveel.Data.Linq/DeveelDbExecutor.cs