Deveel.Data.Sql.Statements.StatementExecutor Class Reference

This class is used to transform an input query to a set of statements and execute them within a given query. More...

Classes
class	QueryPreparer

Static Public Member Functions
static ITable[]	Execute (IRequest query, SqlQuery sqlQuery)
	This method transforms the input SQL query into a set of statements, prepares and executes them against the provided query. More...

Detailed Description

This class is used to transform an input query to a set of statements and execute them within a given query.

Definition at line 32 of file StatementExecutor.cs.

Member Function Documentation

static ITable [] Deveel.Data.Sql.Statements.StatementExecutor.Execute ( IRequest  query, SqlQuery  sqlQuery  )

inlinestatic

This method transforms the input SQL query into a set of statements, prepares and executes them against the provided query.

Parameters

query	The query used to prepare and execute the statements resolved from the compilation of the input query.
sqlQuery	The input SQL query with optional parameters, that is compiled into a set of statements to be executed.

The method first tries to resolve the compiled statements from the specialized cache (StatementCache) from the system, to reduce the compilation time.

Returns

Returns an array of ITable objects that represent the results of the execution of the input query.

Definition at line 49 of file StatementExecutor.cs.

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

            var sqlSouce = sqlQuery.Text;

            // TODO: find it from the cache...

            var statements = SqlStatement.Parse(sqlSouce);

            // TODO: set it in cache ...

            var preparer = new QueryPreparer(sqlQuery);

            bool statementSeen = false;

            var results = new List<ITable>();
            foreach (var statement in statements) {
                // TODO: query.RegisterQuery(statement);

                // TODO: Invoke diagnostics for the preparation...

                var prepared = statement.Prepare(preparer, query);

                ITable result;

                try {
                    var exeContext = new ExecutionContext(query);
                    prepared.Execute(exeContext);
                    if (exeContext.HasResult) {
                        result = exeContext.Result;
                    } else {
                        result = FunctionTable.ResultTable(query, 0);
                    }
                } catch(StatementException ex) {
                    // TODO: query.RegisterError(ex);
                    throw;
                } catch (Exception ex) {
                    var sex = new StatementException("An unhanded error occurred while executing the statement.", ex);
                    // TODO: query.RegisterError(sex);
                    throw sex;
                } finally {
                    statementSeen = true;
                }

                results.Add(result);
            }

            if (!statementSeen)
                throw new SqlParseException("The input query was not parsed in any statements that could be executed.");

            return results.ToArray();
        }

---

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

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