Static Public Member Functions
static int	DeleteFrom (this IQuery context, ObjectName tableName, SqlQueryExpression query)

static int	DeleteFrom (this IQuery context, ObjectName tableName, SqlExpression expression)

static int	DeleteFrom (this IQuery context, ObjectName tableName, SqlExpression expression, int limit)

static int	DeleteFrom (this IQuery context, ObjectName tableName, SqlQueryExpression query, int limit)

static int	DeleteFrom (this IQuery context, ObjectName tableName, ITable deleteSet, int limit)

static int	UpdateTable (this IQuery context, ObjectName tableName, IQueryPlanNode queryPlan, IEnumerable< SqlAssignExpression > assignments, int limit)

static void	InsertIntoTable (this IQuery context, ObjectName tableName, IEnumerable< SqlAssignExpression > assignments)

static int	InsertIntoTable (this IQuery context, ObjectName tableName, IEnumerable< SqlAssignExpression[]> assignments)

static ObjectName	ResolveTableName (this IQueryContext context, ObjectName tableName)

static ObjectName	ResolveTableName (this IQueryContext context, string name)

static bool	TableExists (this IQueryContext context, ObjectName tableName)

static void	CreateTable (this IQueryContext context, TableInfo tableInfo)

static void	CreateTable (this IQueryContext context, TableInfo tableInfo, bool onlyIfNotExists)

static void	CreateTable (this IQueryContext context, TableInfo tableInfo, bool onlyIfNotExists, bool temporary)

static void	DropTables (this IQueryContext context, IEnumerable< ObjectName > tableNames)

static void	DropTables (this IQueryContext context, IEnumerable< ObjectName > tableNames, bool onlyIfExists)

static void	DropTable (this IQueryContext context, ObjectName tableName)

static void	DropTable (this IQueryContext context, ObjectName tableName, bool onlyIfExists)

static void	AlterTable (this IQueryContext context, TableInfo tableInfo)

static ITable	GetTable (this IQueryContext context, ObjectName tableName)

static IMutableTable	GetMutableTable (this IQueryContext context, ObjectName tableName)

static ITable	GetCachedTable (this IQueryContext context, string cacheKey)

static void	CacheTable (this IQueryContext context, string cacheKey, ITable table)

static void	ClearCachedTables (this IQueryContext context)

static void	AddPrimaryKey (this IQueryContext context, ObjectName tableName, string[] columnNames)

static void	AddPrimaryKey (this IQueryContext context, ObjectName tableName, string[] columnNames, string constraintName)

static void	AddPrimaryKey (this IQueryContext context, ObjectName tableName, string columnName)

static void	AddPrimaryKey (this IQueryContext context, ObjectName tableName, string columnName, string constraintName)

static void	AddForeignKey (this IQueryContext context, ObjectName table, string[] columns, ObjectName refTable, string[] refColumns, ForeignKeyAction deleteRule, ForeignKeyAction updateRule, String constraintName)

static void	AddForeignKey (this IQueryContext context, ObjectName table, string[] columns, ObjectName refTable, string[] refColumns, ForeignKeyAction deleteRule, ForeignKeyAction updateRule, ConstraintDeferrability deferred, String constraintName)

static void	AddUniqueKey (this IQueryContext context, ObjectName tableName, string[] columns)

static void	AddUniqueKey (this IQueryContext context, ObjectName tableName, string[] columns, string constraintName)

static void	AddUniqueKey (this IQueryContext context, ObjectName tableName, string[] columns, ConstraintDeferrability deferrability)

static void	AddUniqueKey (this IQueryContext context, ObjectName tableName, string[] columns, ConstraintDeferrability deferrability, string constraintName)

static void	AddCheck (this IQueryContext context, ObjectName tableName, SqlExpression expression, string constraintName)

static void	AddCheck (this IQueryContext context, ObjectName tableName, SqlExpression expression, ConstraintDeferrability deferred, string constraintName)

static void	DropAllTableConstraints (this IQueryContext context, ObjectName tableName)

static int	DropConstraint (this IQueryContext context, ObjectName tableName, string constraintName)

static void	AddConstraint (this IQueryContext context, ObjectName tableName, ConstraintInfo constraintInfo)

static bool	DropPrimaryKey (this IQueryContext context, ObjectName tableName, string constraintName)

static void	CheckConstraints (this IQueryContext context, ObjectName tableName)

static ConstraintInfo[]	GetTableCheckExpressions (this IQueryContext context, ObjectName tableName)

static ConstraintInfo[]	GetTableImportedForeignKeys (this IQueryContext context, ObjectName tableName)

static ConstraintInfo[]	GetTableForeignKeys (this IQueryContext context, ObjectName tableName)

static ConstraintInfo	GetTablePrimaryKey (this IQueryContext context, ObjectName tableName)

static ConstraintInfo[]	GetTableUniqueKeys (this IQueryContext context, ObjectName tableName)

Static Package Functions
static void	CreateSystemTable (this IQueryContext context, TableInfo tableInfo)

Static Private Member Functions
static ICache	TableCache (this IQueryContext context)

Detailed Description

Definition at line 12 of file QueryContext.Tables.Commands.cs.

Member Function Documentation

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddCheck	(	this IQueryContext	context,
		ObjectName	tableName,
		SqlExpression	expression,
		string	constraintName
	)

inlinestatic

Definition at line 256 of file QueryContextExtensions.Tables.cs.

                                                                                                                                        {
             AddCheck(context, tableName, expression, ConstraintDeferrability.InitiallyImmediate, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddCheck	(	this IQueryContext	context,
		ObjectName	tableName,
		SqlExpression	expression,
		ConstraintDeferrability	deferred,
		string	constraintName
	)

inlinestatic

Definition at line 260 of file QueryContextExtensions.Tables.cs.

                                                                                                                                                                          {
             context.Session().AddCheck(tableName, expression, deferred, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddConstraint	(	this IQueryContext	context,
		ObjectName	tableName,
		ConstraintInfo	constraintInfo
	)

inlinestatic

Definition at line 272 of file QueryContextExtensions.Tables.cs.

                                                                                                                           {
             if (constraintInfo.ConstraintType == ConstraintType.PrimaryKey) {
                 var columnNames = constraintInfo.ColumnNames;
                 if (columnNames.Length > 1)
                     throw new ArgumentException();
 
                 context.AddPrimaryKey(tableName, columnNames[0], constraintInfo.ConstraintName);
             } else if (constraintInfo.ConstraintType == ConstraintType.Unique) {
                 context.AddUniqueKey(tableName, constraintInfo.ColumnNames, constraintInfo.ConstraintName);
             } else if (constraintInfo.ConstraintType == ConstraintType.Check) {
                 context.AddCheck(tableName, constraintInfo.CheckExpression, constraintInfo.ConstraintName);
             } else if (constraintInfo.ConstraintType == ConstraintType.ForeignKey) {
                 context.AddForeignKey(tableName, constraintInfo.ColumnNames, constraintInfo.ForeignTable,
                     constraintInfo.ForeignColumnNames, constraintInfo.OnDelete, constraintInfo.OnUpdate, constraintInfo.ConstraintName);
             }
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddForeignKey	(	this IQueryContext	context,
		ObjectName	table,
		string[]	columns,
		ObjectName	refTable,
		string[]	refColumns,
		ForeignKeyAction	deleteRule,
		ForeignKeyAction	updateRule,
		String	constraintName
	)

inlinestatic

Definition at line 218 of file QueryContextExtensions.Tables.cs.

                                    {
             AddForeignKey(context, table, columns, refTable, refColumns, deleteRule, updateRule, ConstraintDeferrability.InitiallyImmediate, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddForeignKey	(	this IQueryContext	context,
		ObjectName	table,
		string[]	columns,
		ObjectName	refTable,
		string[]	refColumns,
		ForeignKeyAction	deleteRule,
		ForeignKeyAction	updateRule,
		ConstraintDeferrability	deferred,
		String	constraintName
	)

inlinestatic

Definition at line 224 of file QueryContextExtensions.Tables.cs.

                                    {
             if (!context.UserCanAlterTable(table))
                 throw new MissingPrivilegesException(context.UserName(), table, Privileges.Alter);
             if (!context.UserCanReferenceTable(refTable))
                 throw new MissingPrivilegesException(context.UserName(), refTable, Privileges.References);
 
             context.Session().AddForeignKey(table, columns, refTable, refColumns, deleteRule, updateRule, deferred, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddPrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columnNames
	)

inlinestatic

Definition at line 199 of file QueryContextExtensions.Tables.cs.

                                                                                                                  {
             AddPrimaryKey(context, tableName, columnNames, null);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddPrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columnNames,
		string	constraintName
	)

inlinestatic

Definition at line 203 of file QueryContextExtensions.Tables.cs.

                                                                                                                                         {
             if (!context.UserCanAlterTable(tableName))
                 throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Alter);
 
             context.Session().AddPrimaryKey(tableName, columnNames, ConstraintDeferrability.InitiallyImmediate, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddPrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string	columnName
	)

inlinestatic

Definition at line 210 of file QueryContextExtensions.Tables.cs.

                                                                                                               {
             AddPrimaryKey(context, tableName, columnName, null);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddPrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string	columnName,
		string	constraintName
	)

inlinestatic

Definition at line 214 of file QueryContextExtensions.Tables.cs.

                                                                                                                                      {
             context.AddPrimaryKey(tableName, new[] { columnName }, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddUniqueKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columns
	)

inlinestatic

Definition at line 235 of file QueryContextExtensions.Tables.cs.

                                                                                                             {
             AddUniqueKey(context, tableName, columns, null);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddUniqueKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columns,
		string	constraintName
	)

inlinestatic

Definition at line 239 of file QueryContextExtensions.Tables.cs.

                                                                                                                                    {
             AddUniqueKey(context, tableName, columns, ConstraintDeferrability.InitiallyImmediate, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddUniqueKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columns,
		ConstraintDeferrability	deferrability
	)

inlinestatic

Definition at line 243 of file QueryContextExtensions.Tables.cs.

                                                    {
             AddUniqueKey(context, tableName, columns, deferrability, null);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AddUniqueKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string[]	columns,
		ConstraintDeferrability	deferrability,
		string	constraintName
	)

inlinestatic

Definition at line 248 of file QueryContextExtensions.Tables.cs.

                                                                           {
             if (!context.UserCanAlterTable(tableName))
                 throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Alter);
 
             context.Session().AddUniqueKey(tableName, columns, deferrability, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.AlterTable	(	this IQueryContext	context,
		TableInfo	tableInfo
	)

inlinestatic

Definition at line 144 of file QueryContextExtensions.Tables.cs.

                                                                                        {
             context.AlterObject(tableInfo);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CacheTable	(	this IQueryContext	context,
		string	cacheKey,
		ITable	table
	)

inlinestatic

Definition at line 181 of file QueryContextExtensions.Tables.cs.

                                                                                                  {
             var tableCache = context.TableCache();
             if (tableCache == null)
                 return;
 
             tableCache.Set(cacheKey, table);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CheckConstraints	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 293 of file QueryContextExtensions.Tables.cs.

                                                                                               {
             context.Session().CheckConstraintViolations(tableName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.ClearCachedTables ( this IQueryContext context )

inlinestatic

Definition at line 189 of file QueryContextExtensions.Tables.cs.

                                                                          {
             var tableCache = context.TableCache();
             if (tableCache == null)
                 return;
 
             tableCache.Clear();
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CreateSystemTable	(	this IQueryContext	context,
		TableInfo	tableInfo
	)

inlinestaticpackage

Definition at line 71 of file QueryContextExtensions.Tables.cs.

                                                                                                 {
             if (tableInfo == null)
                 throw new ArgumentNullException("tableInfo");
 
             var tableName = tableInfo.TableName;
 
             if (!context.UserCanCreateTable(tableName))
                 throw new MissingPrivilegesException(context.User().Name, tableName, Privileges.Create);
 
             context.Session().CreateTable(tableInfo, false);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CreateTable	(	this IQueryContext	context,
		TableInfo	tableInfo
	)

inlinestatic

Definition at line 39 of file QueryContextExtensions.Tables.cs.

                                                                                         {
             CreateTable(context, tableInfo, false);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CreateTable	(	this IQueryContext	context,
		TableInfo	tableInfo,
		bool	onlyIfNotExists
	)

inlinestatic

Definition at line 43 of file QueryContextExtensions.Tables.cs.

                                                                                                               {
             CreateTable(context, tableInfo, onlyIfNotExists, false);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.CreateTable	(	this IQueryContext	context,
		TableInfo	tableInfo,
		bool	onlyIfNotExists,
		bool	temporary
	)

inlinestatic

Definition at line 47 of file QueryContextExtensions.Tables.cs.

                                                                                                                               {
             if (tableInfo == null)
                 throw new ArgumentNullException("tableInfo");
 
             var tableName = tableInfo.TableName;
 
             if (!context.UserCanCreateTable(tableName))
                 throw new MissingPrivilegesException(context.User().Name, tableName, Privileges.Create);
 
             if (context.TableExists(tableName)) {
                 if (!onlyIfNotExists)
                     throw new InvalidOperationException(
                         String.Format("The table {0} already exists and the IF NOT EXISTS clause was not specified.", tableName));
 
                 return;
             }
 
             context.Session().CreateTable(tableInfo, temporary);
 
             using (var systemContext = context.ForSystemUser()) {
                 systemContext.GrantToUserOnTable(tableInfo.TableName, context.User().Name, Privileges.TableAll);
             }
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DeleteFrom	(	this IQuery	context,
		ObjectName	tableName,
		SqlQueryExpression	query
	)

inlinestatic

Definition at line 13 of file QueryContext.Tables.Commands.cs.

                                                                                                           {
             return DeleteFrom(context, tableName, query, -1);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DeleteFrom	(	this IQuery	context,
		ObjectName	tableName,
		SqlExpression	expression
	)

inlinestatic

Definition at line 17 of file QueryContext.Tables.Commands.cs.

                                                                                                           {
             return DeleteFrom(context, tableName, expression, -1);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DeleteFrom	(	this IQuery	context,
		ObjectName	tableName,
		SqlExpression	expression,
		int	limit
	)

inlinestatic

Definition at line 21 of file QueryContext.Tables.Commands.cs.

                                                                                                                      {
             if (expression is SqlQueryExpression)
                 return context.DeleteFrom(tableName, (SqlQueryExpression)expression, limit);
 
             var table = context.GetMutableTable(tableName);
             if (table == null)
                 throw new ObjectNotFoundException(tableName);
 
             var queryExpression = new SqlQueryExpression(new List<SelectColumn> { SelectColumn.Glob("*") });
             queryExpression.FromClause.AddTable(tableName.Name);
             queryExpression.WhereExpression = expression;
 
             var planExpression = queryExpression.Evaluate(context, null);
             var plan = (SqlQueryObject)((SqlConstantExpression)planExpression).Value.Value;
             var deleteSet = plan.QueryPlan.Evaluate(context);
 
             return context.DeleteFrom(tableName, deleteSet, limit);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DeleteFrom	(	this IQuery	context,
		ObjectName	tableName,
		SqlQueryExpression	query,
		int	limit
	)

inlinestatic

Definition at line 40 of file QueryContext.Tables.Commands.cs.

                                                                                                                      {
             IQueryPlanNode plan;
 
             try {
                 var planValue = query.EvaluateToConstant(context, null);
                 if (planValue == null)
                     throw new InvalidOperationException();
 
                 if (!(planValue.Type is QueryType))
                     throw new InvalidOperationException();
 
                 plan = ((SqlQueryObject)planValue.Value).QueryPlan;
             } catch (QueryException) {
                 throw;
             } catch (SecurityException) {
                 throw;
             } catch (Exception ex) {
                 throw new InvalidOperationException(String.Format("Could not delete from table '{0}': unable to form the delete set.", tableName), ex);
             }
 
             var deleteSet = plan.Evaluate(context);
             return context.DeleteFrom(tableName, deleteSet, limit);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DeleteFrom	(	this IQuery	context,
		ObjectName	tableName,
		ITable	deleteSet,
		int	limit
	)

inlinestatic

Definition at line 64 of file QueryContext.Tables.Commands.cs.

                                                                                                              {
             if (!context.UserCanDeleteFromTable(tableName))
                 throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Delete);
 
             var table = context.GetMutableTable(tableName);
             if (table == null)
                 throw new ObjectNotFoundException(tableName);
 
             return table.Delete(deleteSet, limit);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.DropAllTableConstraints	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 264 of file QueryContextExtensions.Tables.cs.

                                                                                                      {
             context.Session().DropAllTableConstraints(tableName);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.DropConstraint	(	this IQueryContext	context,
		ObjectName	tableName,
		string	constraintName
	)

inlinestatic

Definition at line 268 of file QueryContextExtensions.Tables.cs.

                                                                                                                   {
             return context.Session().DropTableConstraint(tableName, constraintName);
         }

static bool Deveel.Data.Sql.Tables.QueryContextExtensions.DropPrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName,
		string	constraintName
	)

inlinestatic

Definition at line 289 of file QueryContextExtensions.Tables.cs.

                                                                                                                    {
             return context.Session().DropTablePrimaryKey(tableName, constraintName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.DropTable	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 136 of file QueryContextExtensions.Tables.cs.

                                                                                        {
             DropTable(context, tableName, false);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.DropTable	(	this IQueryContext	context,
		ObjectName	tableName,
		bool	onlyIfExists
	)

inlinestatic

Definition at line 140 of file QueryContextExtensions.Tables.cs.

                                                                                                           {
             context.DropTables(new[] {tableName}, onlyIfExists);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.DropTables	(	this IQueryContext	context,
		IEnumerable< ObjectName >	tableNames
	)

inlinestatic

Definition at line 83 of file QueryContextExtensions.Tables.cs.

                                                                                                       {
             DropTables(context, tableNames, false);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.DropTables	(	this IQueryContext	context,
		IEnumerable< ObjectName >	tableNames,
		bool	onlyIfExists
	)

inlinestatic

Definition at line 87 of file QueryContextExtensions.Tables.cs.

                                                                                                                          {
             var tableNameList = tableNames.ToList();
             foreach (var tableName in tableNameList) {
                 if (!context.UserCanDropObject(DbObjectType.Table, tableName))
                     throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Drop);
             }
 
             // Check there are no referential links to any tables being dropped
             foreach (var tableName in tableNameList) {
                 var refs = context.GetTableImportedForeignKeys(tableName);
 
                 foreach (var reference in refs) {
                     // If the key table isn't being dropped then error
                     if (!tableNameList.Contains(reference.TableName)) {
                         throw new ConstraintViolationException(SqlModelErrorCodes.DropTableViolation,
                             String.Format("Constraint violation ({0}) dropping table '{1}' because of referential link from '{2}'",
                                 reference.ConstraintName, tableName, reference.TableName));
                     }
                 }
             }
 
             // If the 'only if exists' flag is false, we need to check tables to drop
             // exist first.
             if (!onlyIfExists) {
                 // For each table to drop.
                 foreach (var tableName in tableNameList) {
                     // If table doesn't exist, throw an error
                     if (!context.TableExists(tableName)) {
                         throw new InvalidOperationException(String.Format("The table '{0}' does not exist and cannot be dropped.",
                             tableName));
                     }
                 }
             }
 
             foreach (var tname in tableNameList) {
                 // Does the table already exist?
                 if (context.TableExists(tname)) {
                     // Drop table in the transaction
                     context.DropObject(DbObjectType.Table, tname);
 
                     // Revoke all the grants on the table
                     context.RevokeAllGrantsOnTable(tname);
 
                     // Drop all constraints from the schema
                     context.DropAllTableConstraints(tname);
                 }
             }
         }

static ITable Deveel.Data.Sql.Tables.QueryContextExtensions.GetCachedTable	(	this IQueryContext	context,
		string	cacheKey
	)

inlinestatic

Definition at line 169 of file QueryContextExtensions.Tables.cs.

                                                                                          {
             var tableCache = context.TableCache();
             if (tableCache == null)
                 return null;
 
             object obj;
             if (!tableCache.TryGet(cacheKey, out obj))
                 return null;
 
             return obj as ITable;
         }

static IMutableTable Deveel.Data.Sql.Tables.QueryContextExtensions.GetMutableTable	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 161 of file QueryContextExtensions.Tables.cs.

                                                                                                       {
             return context.GetTable(tableName) as IMutableTable;
         }

static ITable Deveel.Data.Sql.Tables.QueryContextExtensions.GetTable	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 148 of file QueryContextExtensions.Tables.cs.

                                                                                         {
             var table = context.GetCachedTable(tableName.FullName) as ITable;
             if (table == null) {
                 table = context.Session().GetTable(tableName);
                 if (table != null) {
                     table = new UserContextTable(context, table);
                     context.CacheTable(tableName.FullName, table);
                 }
             }
 
             return table;
         }

static ConstraintInfo [] Deveel.Data.Sql.Tables.QueryContextExtensions.GetTableCheckExpressions	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 297 of file QueryContextExtensions.Tables.cs.

                                                                                                                   {
             return context.Session().QueryTableCheckExpressions(tableName);
         }

static ConstraintInfo [] Deveel.Data.Sql.Tables.QueryContextExtensions.GetTableForeignKeys	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 305 of file QueryContextExtensions.Tables.cs.

                                                                                                              {
             return context.Session().QueryTableForeignKeys(tableName);
         }

static ConstraintInfo [] Deveel.Data.Sql.Tables.QueryContextExtensions.GetTableImportedForeignKeys	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 301 of file QueryContextExtensions.Tables.cs.

                                                                                                                      {
             return context.Session().QueryTableImportedForeignKeys(tableName);
         }

static ConstraintInfo Deveel.Data.Sql.Tables.QueryContextExtensions.GetTablePrimaryKey	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 309 of file QueryContextExtensions.Tables.cs.

                                                                                                           {
             return context.Session().QueryTablePrimaryKey(tableName);
         }

static ConstraintInfo [] Deveel.Data.Sql.Tables.QueryContextExtensions.GetTableUniqueKeys	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 313 of file QueryContextExtensions.Tables.cs.

                                                                                                             {
             return context.Session().QueryTableUniqueKeys(tableName);
         }

static void Deveel.Data.Sql.Tables.QueryContextExtensions.InsertIntoTable	(	this IQuery	context,
		ObjectName	tableName,
		IEnumerable< SqlAssignExpression >	assignments
	)

inlinestatic

Definition at line 95 of file QueryContext.Tables.Commands.cs.

                                                                                                                                     {
             var columnNames =
                 assignments.Select(x => x.ReferenceExpression)
                     .Cast<SqlReferenceExpression>()
                     .Select(x => x.ReferenceName.Name).ToArray();
             if (!context.UserCanInsertIntoTable(tableName, columnNames))
                 throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Insert);
 
             var table = context.GetMutableTable(tableName);
 
             var row = table.NewRow();
             foreach (var expression in assignments) {
                 row.EvaluateAssignment(expression, context);
             }
 
             table.AddRow(row);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.InsertIntoTable	(	this IQuery	context,
		ObjectName	tableName,
		IEnumerable< SqlAssignExpression[]>	assignments
	)

inlinestatic

Definition at line 113 of file QueryContext.Tables.Commands.cs.

                                                             {
             int insertCount = 0;
 
             foreach (var assignment in assignments) {
                 context.InsertIntoTable(tableName, assignment);
                 insertCount++;
             }
 
             return insertCount;
         }

static ObjectName Deveel.Data.Sql.Tables.QueryContextExtensions.ResolveTableName	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 14 of file QueryContextExtensions.Tables.cs.

                                                                                                     {
             return context.Session().ResolveTableName(tableName);
         }

static ObjectName Deveel.Data.Sql.Tables.QueryContextExtensions.ResolveTableName	(	this IQueryContext	context,
		string	name
	)

inlinestatic

Definition at line 18 of file QueryContextExtensions.Tables.cs.

                                                                                            {
             var schema = context.CurrentSchema;
             if (String.IsNullOrEmpty(schema))
                 throw new InvalidOperationException("Default schema not specified in the context.");
 
             var objSchemaName = context.ResolveSchemaName(schema);
             if (objSchemaName == null)
                 throw new InvalidOperationException(
                     String.Format("The default schema of the session '{0}' is not defined in the database.", schema));
 
             var objName = ObjectName.Parse(name);
             if (objName.Parent == null)
                 objName = new ObjectName(objSchemaName, objName.Name);
 
             return context.ResolveTableName(objName);
         }

static ICache Deveel.Data.Sql.Tables.QueryContextExtensions.TableCache ( this IQueryContext context )

inlinestaticprivate

Definition at line 165 of file QueryContextExtensions.Tables.cs.

                                                                      {
             return context.ResolveService<ICache>("TableCache");
         }

static bool Deveel.Data.Sql.Tables.QueryContextExtensions.TableExists	(	this IQueryContext	context,
		ObjectName	tableName
	)

inlinestatic

Definition at line 35 of file QueryContextExtensions.Tables.cs.

                                                                                          {
             return context.ObjectExists(DbObjectType.Table, tableName);
         }

static int Deveel.Data.Sql.Tables.QueryContextExtensions.UpdateTable	(	this IQuery	context,
		ObjectName	tableName,
		IQueryPlanNode	queryPlan,
		IEnumerable< SqlAssignExpression >	assignments,
		int	limit
	)

inlinestatic

Definition at line 75 of file QueryContext.Tables.Commands.cs.

                                                                      {
             var columnNames = assignments.Select(x => x.ReferenceExpression)
                 .Cast<SqlReferenceExpression>()
                 .Select(x => x.ReferenceName.Name).ToArray();
 
             if (!context.UserCanUpdateTable(tableName, columnNames))
                 throw new MissingPrivilegesException(context.UserName(), tableName, Privileges.Update);
 
             if (!context.UserCanSelectFromPlan(queryPlan))
                 throw new InvalidOperationException();
 
             var table = context.GetMutableTable(tableName);
             if (table == null)
                 throw new ObjectNotFoundException(tableName);
 
             var updateSet = queryPlan.Evaluate(context);
             return table.Update(context, updateSet, assignments, limit);
         }

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

/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Sql.Tables/QueryContext.Tables.Commands.cs
/var/calculate/remote/distfiles/egit-src/deveeldb.git/src/deveeldb/Deveel.Data.Sql.Tables/QueryContextExtensions.Tables.cs

Static Public Member Functions

Static Package Functions

Static Private Member Functions

Detailed Description

Member Function Documentation