module ProjectM36.Tuple where
import ProjectM36.Base
import ProjectM36.Error
import ProjectM36.Attribute
import ProjectM36.Atom
import ProjectM36.AtomType
import ProjectM36.DataTypes.Primitive
import qualified Data.Map as M
import qualified Data.Set as S
import qualified Data.Vector as V
import Data.Either (rights)
import Control.Monad
import Control.Arrow
import Data.Maybe
emptyTuple :: RelationTuple
emptyTuple = RelationTuple V.empty V.empty
tupleSize :: RelationTuple -> Int
tupleSize (RelationTuple tupAttrs _) = V.length tupAttrs
tupleAttributeNameSet :: RelationTuple -> S.Set AttributeName
tupleAttributeNameSet (RelationTuple tupAttrs _) = S.fromList $ V.toList $ V.map attributeName tupAttrs
tupleAttributes :: RelationTuple -> Attributes
tupleAttributes (RelationTuple tupAttrs _) = tupAttrs
tupleAssocs :: RelationTuple -> [(AttributeName, Atom)]
tupleAssocs (RelationTuple attrVec tupVec) = V.toList $ V.map (first attributeName) (V.zip attrVec tupVec)
orderedTupleAssocs :: RelationTuple -> [(AttributeName, Atom)]
orderedTupleAssocs tup@(RelationTuple attrVec _) = map (\attr -> (attributeName attr, atomForAttr (attributeName attr))) oAttrs
where
oAttrs = orderedAttributes attrVec
atomForAttr nam = case atomForAttributeName nam tup of
Left _ -> TextAtom "<?>"
Right val -> val
tupleAtoms :: RelationTuple -> V.Vector Atom
tupleAtoms (RelationTuple _ tupVec) = tupVec
atomForAttributeName :: AttributeName -> RelationTuple -> Either RelationalError Atom
atomForAttributeName attrName (RelationTuple tupAttrs tupVec) = case V.findIndex (\attr -> attributeName attr == attrName) tupAttrs of
Nothing -> Left (NoSuchAttributeNamesError (S.singleton attrName))
Just index -> case tupVec V.!? index of
Nothing -> Left (NoSuchAttributeNamesError (S.singleton attrName))
Just atom -> Right atom
atomsForAttributeNames :: V.Vector AttributeName -> RelationTuple -> Either RelationalError (V.Vector Atom)
atomsForAttributeNames attrNames tuple =
V.map (\index -> tupleAtoms tuple V.! index) <$> vectorIndicesForAttributeNames attrNames (tupleAttributes tuple)
vectorIndicesForAttributeNames :: V.Vector AttributeName -> Attributes -> Either RelationalError (V.Vector Int)
vectorIndicesForAttributeNames attrNameVec attrs = if not $ V.null unknownAttrNames then
Left $ NoSuchAttributeNamesError (S.fromList (V.toList unknownAttrNames))
else
Right $ V.map mapper attrNameVec
where
unknownAttrNames = V.filter (`V.notElem` attributeNames attrs) attrNameVec
mapper attrName = fromMaybe (error "logic failure in vectorIndicesForAttributeNames") (V.elemIndex attrName (V.map attributeName attrs))
relationForAttributeName :: AttributeName -> RelationTuple -> Either RelationalError Relation
relationForAttributeName attrName tuple = do
aType <- atomTypeForAttributeName attrName (tupleAttributes tuple)
if not (isRelationAtomType aType) then
Left $ AttributeIsNotRelationValuedError attrName
else do
atomVal <- atomForAttributeName attrName tuple
relationForAtom atomVal
tupleRenameAttribute :: AttributeName -> AttributeName -> RelationTuple -> RelationTuple
tupleRenameAttribute oldattr newattr (RelationTuple tupAttrs tupVec) = RelationTuple newAttrs tupVec
where
newAttrs = renameAttributes oldattr newattr tupAttrs
mkRelationTuple :: Attributes -> V.Vector Atom -> RelationTuple
mkRelationTuple = RelationTuple
mkRelationTuples :: Attributes -> [V.Vector Atom] -> [RelationTuple]
mkRelationTuples attrs = map mapper
where
mapper = mkRelationTuple attrs
mkRelationTupleFromMap :: M.Map AttributeName Atom -> RelationTuple
mkRelationTupleFromMap attrMap = RelationTuple attrs (V.map (\attrName -> attrMap M.! attrName) attrNames)
where
attrNames = V.fromList (M.keys attrMap)
attrs = V.map (\attrName -> Attribute attrName (atomTypeForAtom (attrMap M.! attrName))) attrNames
singleTupleSetJoin :: Attributes -> RelationTuple -> RelationTupleSet -> Either RelationalError [RelationTuple]
singleTupleSetJoin joinAttrs tup tupSet =
foldM tupleJoiner [] (asList tupSet)
where
tupleJoiner :: [RelationTuple] -> RelationTuple -> Either RelationalError [RelationTuple]
tupleJoiner accumulator tuple2 = case singleTupleJoin joinAttrs tup tuple2 of
Right Nothing -> Right accumulator
Right (Just relTuple) -> Right $ relTuple : accumulator
Left err -> Left err
singleTupleJoin :: Attributes -> RelationTuple -> RelationTuple -> Either RelationalError (Maybe RelationTuple)
singleTupleJoin joinedAttrs tup1@(RelationTuple tupAttrs1 _) tup2@(RelationTuple tupAttrs2 _) = if
V.null keysIntersection || atomsForAttributeNames keysIntersection tup1 /= atomsForAttributeNames keysIntersection tup2
then
return Nothing
else
return $ Just $ RelationTuple joinedAttrs newVec
where
keysIntersection = V.map attributeName attrsIntersection
attrsIntersection = V.filter (`V.elem` tupAttrs1) tupAttrs2
newVec = V.map (findAtomForAttributeName . attributeName) joinedAttrs
findAtomForAttributeName attrName = head $ rights $ fmap (atomForAttributeName attrName) [tup1, tup2]
vectorUnion :: (Eq a) => V.Vector a -> V.Vector a -> V.Vector a
vectorUnion v1 v2 = V.foldr folder v1 v2
where
folder e acc = if V.elem e v1 then
acc
else
V.snoc acc e
tupleExtend :: RelationTuple -> RelationTuple -> RelationTuple
tupleExtend (RelationTuple tupAttrs1 tupVec1) (RelationTuple tupAttrs2 tupVec2) = RelationTuple newAttrs newVec
where
newAttrs = tupAttrs1 V.++ tupAttrs2
newVec = tupVec1 V.++ tupVec2
tupleAtomExtend :: AttributeName -> Atom -> RelationTuple -> RelationTuple
tupleAtomExtend newAttrName atom tupIn = tupleExtend tupIn newTup
where
newTup = RelationTuple (V.singleton $ Attribute newAttrName (atomTypeForAtom atom)) (V.singleton atom)
tupleProject :: S.Set AttributeName -> RelationTuple -> RelationTuple
tupleProject projectAttrs (RelationTuple attrs tupVec) = RelationTuple newAttrs newTupVec
where
deleteIndices = V.findIndices (\attr -> S.notMember (attributeName attr) projectAttrs) attrs
indexDeleter = V.ifilter (\index _ -> V.notElem index deleteIndices)
newAttrs = indexDeleter attrs
newTupVec = indexDeleter tupVec
tupleIntersection :: RelationTuple -> RelationTuple -> RelationTuple
tupleIntersection tuple1 tuple2 = RelationTuple newAttrs newTupVec
where
attrs1 = tupleAttributes tuple1
attrs2 = tupleAttributes tuple2
matchingIndices = V.findIndices (\attr -> V.elem attr attrs2 &&
atomForAttributeName (attributeName attr) tuple1 ==
atomForAttributeName (attributeName attr) tuple2
) attrs1
indexFilter = V.ifilter (\index _ -> V.elem index matchingIndices)
newAttrs = indexFilter attrs1
newTupVec = indexFilter (tupleAtoms tuple1)
updateTupleWithAtoms :: M.Map AttributeName Atom -> RelationTuple -> RelationTuple
updateTupleWithAtoms updateMap (RelationTuple attrs tupVec) = RelationTuple attrs newVec
where
updateKeysSet = M.keysSet updateMap
updateKeysIVec = V.filter (\(_,attr) -> S.member (attributeName attr) updateKeysSet) (V.indexed attrs)
newVec = V.update tupVec updateVec
updateVec = V.map (\(index, attr) -> (index, updateMap M.! attributeName attr)) updateKeysIVec
tupleToMap :: RelationTuple -> M.Map AttributeName Atom
tupleToMap (RelationTuple attrs tupVec) = M.fromList assocList
where
assocList = V.toList $ V.map (\(index, attr) -> (attributeName attr, tupVec V.! index)) (V.indexed attrs)
verifyTuple :: Attributes -> RelationTuple -> Either RelationalError RelationTuple
verifyTuple attrs tuple = let attrsTypes = V.map atomType attrs
tupleTypes = V.map atomTypeForAtom (tupleAtoms tuple) in
if V.length attrs /= V.length tupleTypes then
Left $ TupleAttributeCountMismatchError 0
else do
mapM_ (uncurry atomTypeVerify) (V.zip attrsTypes tupleTypes)
Right tuple
reorderTuple :: Attributes -> RelationTuple -> RelationTuple
reorderTuple attrs tupIn = if tupleAttributes tupIn == attrs then
tupIn
else
RelationTuple attrs (V.map mapper attrs)
where
mapper attr = case atomForAttributeName (attributeName attr) tupIn of
Left err -> error ("logic bug in reorderTuple: " ++ show err)
Right atom -> atom
trimTuple :: Int -> RelationTuple -> RelationTuple
trimTuple index (RelationTuple attrs vals) = RelationTuple (V.drop index attrs) (V.drop index vals)