ProjectM36.SQL.Convert

Documentation

newtype TableContext

Constructors

TableContext (Map TableAlias (RelationalExpr, Attributes, ColumnAliasRemapper))

Instances

Monoid TableContext

Defined in ProjectM36.SQL.Convert

Methods

mempty :: TableContext

mappend :: TableContext -> TableContext -> TableContext

mconcat :: [TableContext] -> TableContext

Semigroup TableContext

Defined in ProjectM36.SQL.Convert

Methods

(<>) :: TableContext -> TableContext -> TableContext

sconcat :: NonEmpty TableContext -> TableContext

stimes :: Integral b => b -> TableContext -> TableContext

Show TableContext

Defined in ProjectM36.SQL.Convert

Methods

showsPrec :: Int -> TableContext -> ShowS

show :: TableContext -> String

showList :: [TableContext] -> ShowS

Eq TableContext

Defined in ProjectM36.SQL.Convert

Methods

(==) :: TableContext -> TableContext -> Bool

(/=) :: TableContext -> TableContext -> Bool

type TypeForRelExprF = RelationalExpr -> Either RelationalError Relation

type ConvertM = StateT TableContext (ExceptT SQLError Identity)

runConvertM :: TableContext -> ConvertM a -> Either SQLError (a, TableContext)

runLocalConvertM :: ConvertM a -> ConvertM a

evalConvertM :: TableContext -> ConvertM a -> Either SQLError a

data SelectItemsConvertTask

Constructors

SelectItemsConvertTask

Fields

• taskProjections :: Set ColumnProjectionName
• taskRenames :: [(ColumnProjectionName, ColumnAlias)]
• taskExtenders :: [ExtendTupleExpr]
• taskGroups :: [Set ColumnProjectionName]

Instances

Show SelectItemsConvertTask

Defined in ProjectM36.SQL.Convert

Methods

showsPrec :: Int -> SelectItemsConvertTask -> ShowS

show :: SelectItemsConvertTask -> String

showList :: [SelectItemsConvertTask] -> ShowS

Eq SelectItemsConvertTask

Defined in ProjectM36.SQL.Convert

Methods

(==) :: SelectItemsConvertTask -> SelectItemsConvertTask -> Bool

(/=) :: SelectItemsConvertTask -> SelectItemsConvertTask -> Bool

emptyTask :: SelectItemsConvertTask

type AttributeAlias = AttributeName

type ColumnAliasRemapper = Map AttributeName (AttributeAlias, Set ColumnName)

insertIntoColumnAliasRemap' :: AttributeName -> AttributeAlias -> ColumnName -> ColumnAliasRemapper -> Either SQLError ColumnAliasRemapper

insertColumnAlias :: TableAlias -> AttributeName -> ColumnAlias -> ColumnName -> ConvertM ()

Used to note if columns are remapped to different attributes in order to mitigate attribute naming conflicts.

prettyTableContext :: TableContext -> String

prettyColumnAliasRemapper :: ColumnAliasRemapper -> String

type ColumnAliasMap = Map ColumnAlias AttributeName

tableAliasesAsWithNameAssocs :: ConvertM WithNamesAssocs

throwSQLE :: SQLError -> ConvertM a

type ColumnAliasRenameMap = Map (TableAlias, AttributeName) ColumnAlias

withSubSelect :: ConvertM a -> ConvertM (a, ColumnAliasRenameMap)

Pass state down to subselect, but discard any state changes from the subselect processing.

generateColumnAlias :: TableAlias -> AttributeName -> ConvertM ColumnAlias

insertTable :: TableAlias -> RelationalExpr -> Attributes -> ConvertM ColumnAliasMap

Insert another table into the TableContext. Returns an alias map of any columns which could conflict with column names already present in the TableContext so that they can be optionally renamed.

noteColumnMention :: Maybe TableAlias -> ColumnName -> Maybe ColumnAlias -> ConvertM ColumnAlias

When a column is mentioned, it may need to be aliased. The table name must already be in the table context so that we can identify that the attribute exists. Without a table name, we must look for a uniquely named column amongst all tables. Thus, we pre-emptively eliminate duplicate column names.

lookupTable :: TableAlias -> ConvertM (RelationalExpr, Attributes, ColumnAliasRemapper)

findColumn :: ColumnName -> ConvertM [TableAlias]

Find a column name or column alias in the underlying table context. Returns key into table context.

findColumn' :: ColumnName -> TableContext -> [TableAlias]

non ConvertM version of findColumn

findNotedColumn' :: ColumnName -> TableContext -> Either SQLError [(TableAlias, AttributeName)]

attributeNameForAttributeAlias :: AttributeAlias -> ColumnAliasRemapper -> Either SQLError AttributeName

findOneColumn :: ColumnName -> ConvertM TableAlias

findOneColumn' :: ColumnName -> TableContext -> Either SQLError TableAlias

attributeNameForColumnName :: ColumnName -> ConvertM AttributeName

Search the TableContext for a column alias remapping for the given column name. This function can change the state context if column names conflict.

wrapTypeF :: TypeForRelExprF -> RelationalExpr -> ConvertM Relation

baseDFExpr :: DataFrameExpr

falseDFExpr :: DataFrameExpr

convertQuery :: TypeForRelExprF -> Query -> ConvertM DataFrameExpr

convertSelect :: TypeForRelExprF -> Select -> ConvertM DataFrameExpr

appendWithsToTypeF :: TypeForRelExprF -> WithNamesAssocs -> TypeForRelExprF

convertSubSelect :: TypeForRelExprF -> Select -> ConvertM RelationalExpr

Slightly different processing for subselects.

convertSelectItem :: TypeForRelExprF -> SelectItemsConvertTask -> (Int, SelectItem) -> ConvertM SelectItemsConvertTask

convertProjection :: TypeForRelExprF -> [SelectItem] -> [GroupByExpr] -> Maybe HavingExpr -> ConvertM (RelationalExpr -> RelationalExpr)

convertUnqualifiedColumnName :: UnqualifiedColumnName -> AttributeName

convertColumnName :: ColumnName -> ConvertM AttributeName

convertColumnProjectionName :: ColumnProjectionName -> ConvertM AttributeName

convertTableExpr :: TypeForRelExprF -> TableExpr -> ConvertM (DataFrameExpr, ColumnAliasMap)

func :: FunctionName -> [AtomExpr] -> AtomExpr

convertWhereClause :: TypeForRelExprF -> RestrictionExpr -> ConvertM RestrictionPredicateExpr

convertScalarExpr :: TypeForRelExprF -> ScalarExpr -> ConvertM AtomExpr

convertProjectionScalarExpr :: TypeForRelExprF -> ProjectionScalarExpr -> ConvertM AtomExpr

convertOrderByClause :: TypeForRelExprF -> [SortExpr] -> ConvertM [AttributeOrderExpr]

convertWithClause :: TypeForRelExprF -> WithClause -> ConvertM WithNamesAssocs

type ColumnRemap = Map ColumnName ColumnName

convertFromClause :: TypeForRelExprF -> [TableRef] -> ConvertM (RelationalExpr, ColumnAliasMap)

convertTableRef :: TypeForRelExprF -> TableRef -> ConvertM (TableAlias, RelationalExpr)

Convert TableRefs after the first one (assumes all additional TableRefs are for joins). Returns the qualified name key that was added to the map, the underlying relexpr (not aliased so that it can used for extracting type information), and the new table context map

joinTableRef :: TypeForRelExprF -> RelationalExpr -> (Int, TableRef) -> ConvertM RelationalExpr

lookupOperator :: Bool -> OperatorName -> ConvertM ([AtomExpr] -> AtomExpr)

lookupFunc :: FuncName -> ConvertM ([AtomExpr] -> AtomExpr)

commonAttributeNames :: TypeForRelExprF -> RelationalExpr -> RelationalExpr -> ConvertM (Set AttributeName, Set AttributeName, Set AttributeName)

Used in join condition detection necessary for renames to enable natural joins.

renameIdentifier :: (ColumnName -> ColumnName) -> ScalarExpr -> ScalarExpr

Used to remap SQL qualified names to new names to prevent conflicts in join conditions.

columnNamesInScalarExpr :: ScalarExpr -> Set ColumnName

columnNamesInRestrictionExpr :: RestrictionExpr -> Set ColumnName

needsToRenameAllAttributes :: RestrictionExpr -> Bool

If the restriction includes a EXISTS expression, we must rename all attributes at the top-level to prevent conflicts.

pushDownAttributeRename :: Set (AttributeName, AttributeName) -> RelationalExpr -> RelationalExpr -> RelationalExpr

mkTableContextFromDatabaseContext :: DatabaseContext -> TransactionGraph -> Either RelationalError TableContext

convertUpdate :: TypeForRelExprF -> Update -> ConvertM DatabaseContextExpr

convertTableName :: TableName -> ConvertM RelVarName

convertDBUpdates :: TypeForRelExprF -> [DBUpdate] -> ConvertM DatabaseContextExpr

convertDBUpdate :: TypeForRelExprF -> DBUpdate -> ConvertM DatabaseContextExpr

convertInsert :: TypeForRelExprF -> Insert -> ConvertM DatabaseContextExpr

convertDelete :: TypeForRelExprF -> Delete -> ConvertM DatabaseContextExpr

convertCreateTable :: TypeForRelExprF -> CreateTable -> ConvertM DatabaseContextExpr

convertDropTable :: TypeForRelExprF -> DropTable -> ConvertM DatabaseContextExpr

convertColumnNamesAndTypes :: RelVarName -> [(UnqualifiedColumnName, ColumnType, PerColumnConstraints)] -> ConvertM ([AttributeExpr], [DatabaseContextExpr])

convertColumnType :: ColumnType -> PerColumnConstraints -> ConvertM TypeConstructor

convertPerColumnConstraints :: RelVarName -> UnqualifiedColumnName -> PerColumnConstraints -> ConvertM [DatabaseContextExpr]

databaseContextExprForUniqueKeyWithNull :: RelVarName -> AttributeName -> DatabaseContextExpr

convertGroupBy :: TypeForRelExprF -> [GroupByExpr] -> Maybe HavingExpr -> [SelectItem] -> ConvertM GroupByInfo

data GroupByItem

Constructors

AggGroupByItem ProjectionScalarExpr GroupByExpr

NonAggGroupByItem ProjectionScalarExpr GroupByExpr

Instances

Show GroupByItem

Defined in ProjectM36.SQL.Convert

Methods

showsPrec :: Int -> GroupByItem -> ShowS

show :: GroupByItem -> String

showList :: [GroupByItem] -> ShowS

Eq GroupByItem

Defined in ProjectM36.SQL.Convert

Methods

(==) :: GroupByItem -> GroupByItem -> Bool

(/=) :: GroupByItem -> GroupByItem -> Bool

data GroupByInfo

Validated "group by" and "having" data

Constructors

GroupByInfo

Fields

• aggregates :: [ProjectionScalarExpr]

  mentioned in group by clause and uses aggregation

• nonAggregates :: [(AttributeName, GroupByExpr)]

  mentioned in group by clause by not aggregations

• havingRestriction :: Maybe ProjectionScalarExpr

Instances

Show GroupByInfo

Defined in ProjectM36.SQL.Convert

Methods

showsPrec :: Int -> GroupByInfo -> ShowS

show :: GroupByInfo -> String

showList :: [GroupByInfo] -> ShowS

Eq GroupByInfo

Defined in ProjectM36.SQL.Convert

Methods

(==) :: GroupByInfo -> GroupByInfo -> Bool

(/=) :: GroupByInfo -> GroupByInfo -> Bool

emptyGroupByInfo :: GroupByInfo

aggregateFunctionsMap :: [(FuncName, FunctionName)]

isAggregateFunction :: FuncName -> Bool

containsAggregate :: ProjectionScalarExpr -> Bool

containsProjScalarExpr :: ProjectionScalarExpr -> ProjectionScalarExpr -> Bool

Returns True iff a projection scalar expr within a larger expression. Used for group by aggregation validation.

replaceProjScalarExpr :: (ProjectionScalarExpr -> ProjectionScalarExpr) -> ProjectionScalarExpr -> ProjectionScalarExpr

processSQLAggregateFunctions :: AtomExpr -> AtomExpr