Deveel.Data.Sql.Statements.InsertStatement Class Reference

Inheritance diagram for Deveel.Data.Sql.Statements.InsertStatement:

Classes
class	Prepared

Public Member Functions
	InsertStatement (string tableName, IEnumerable< string > columnNames, IEnumerable< SqlExpression[]> values)
Public Member Functions inherited from Deveel.Data.Sql.Statements.SqlStatement
ITable	Execute (IRequest context)
	Prepares and evaluates this statement into a tabular result. More...

Properties
string	TableName [get, private set]
IEnumerable< string >	ColumnNames [get, private set]
IEnumerable< SqlExpression[]>	Values [get, private set]
Properties inherited from Deveel.Data.Sql.Statements.SqlStatement
SqlQuery	SourceQuery [get, set]
	Gets the SqlQuery that is the origin of this statement. More...
bool	IsFromQuery [get, private set]
	Gets a boolean value indicating if this object was formed from the parsing of a SqlQuery or if it was manually created. More...
Properties inherited from Deveel.Data.Sql.Statements.IStatement
SqlQuery	SourceQuery [get]

Private Member Functions
IStatement IPreparableStatement.	Prepare (IRequest context)

Additional Inherited Members
Static Public Member Functions inherited from Deveel.Data.Sql.Statements.SqlStatement
static IEnumerable< SqlStatement >	Parse (string sqlSource)
	Parses a given string into one of more statements. More...
static IEnumerable< SqlStatement >	Parse (IContext context, string sqlSource)
	Parses a given string into one of more statements. More...
static IEnumerable< SqlStatement >	Parse (IContext context, SqlQuery query)
Protected Member Functions inherited from Deveel.Data.Sql.Statements.SqlStatement
	SqlStatement ()
	SqlStatement (ObjectData data)
virtual void	ExecuteStatement (ExecutionContext context)
virtual void	GetData (SerializeData data)
Package Functions inherited from Deveel.Data.Sql.Statements.SqlStatement
void	SetSource (SqlQuery query)

Detailed Description

Definition at line 27 of file InsertStatement.cs.

Constructor & Destructor Documentation

Deveel.Data.Sql.Statements.InsertStatement.InsertStatement ( string  tableName, IEnumerable< string >  columnNames, IEnumerable< SqlExpression[]>  values  )

inline

Definition at line 28 of file InsertStatement.cs.

                                                                                                                       {
            if (columnNames == null)
                throw new ArgumentNullException("columnNames");
            if (values == null)
                throw new ArgumentNullException("values");
            if (String.IsNullOrEmpty(tableName))
                throw new ArgumentNullException("tableName");

            TableName = tableName;
            ColumnNames = columnNames;
            Values = values;
        }

Member Function Documentation

IStatement IPreparableStatement. Deveel.Data.Sql.Statements.InsertStatement.Prepare ( IRequest  context )

inlineprivate

Implements Deveel.Data.Sql.Statements.IPreparableStatement.

Definition at line 47 of file InsertStatement.cs.

                                                                  {
            var tableName = context.Query.ResolveTableName(TableName);

            var table = context.Query.GetTable(tableName);
            if (table == null)
                throw new InvalidOperationException();

            if (Values.Any(x => x.OfType<SqlQueryExpression>().Any()))
                throw new InvalidOperationException("Cannot set a value from a query.");

            var columnInfos = new List<ColumnInfo>();
            foreach (var name in ColumnNames) {
                var columnName = ObjectName.Parse(name);
                var colIndex = table.FindColumn(columnName);
                if (colIndex < 0)
                    throw new InvalidOperationException(String.Format("Cannot find column '{0}' in table '{1}'", columnName, table.FullName));

                columnInfos.Add(table.TableInfo[colIndex]);
            }

            var assignments = new List<SqlAssignExpression[]>();

            foreach (var valueSet in Values) {
                var valueAssign = new SqlAssignExpression[valueSet.Length];

                for (int i = 0; i < valueSet.Length; i++) {
                    var columnInfo = columnInfos[i];

                    var value = valueSet[i];
                    if (value != null) {
                        // TODO: Deference columns with a preparer
                    }

                    if (value != null) {
                        var expReturnType = value.ReturnType(context, null);
                        if (!columnInfo.ColumnType.IsComparable(expReturnType))
                            throw new InvalidOperationException();
                    }

                    valueAssign[i] = SqlExpression.Assign(SqlExpression.Reference(columnInfo.FullColumnName), value);
                }

                assignments.Add(valueAssign);
            }

            return new Prepared(tableName, assignments);
        }

Property Documentation

IEnumerable<string> Deveel.Data.Sql.Statements.InsertStatement.ColumnNames

getprivate set

Definition at line 43 of file InsertStatement.cs.

string Deveel.Data.Sql.Statements.InsertStatement.TableName

getprivate set

Definition at line 41 of file InsertStatement.cs.

IEnumerable<SqlExpression[]> Deveel.Data.Sql.Statements.InsertStatement.Values

getprivate set

Definition at line 45 of file InsertStatement.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.Statements/InsertStatement.cs