Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
73 changes: 35 additions & 38 deletions cypher/models/pgsql/operators.go
Original file line number Diff line number Diff line change
@@ -1,5 +1,7 @@
package pgsql

import "slices"

type Operator string

func (s Operator) IsIn(others ...Operator) bool {
Expand All @@ -25,13 +27,7 @@ func (s Operator) NodeType() string {
}

func OperatorIsIn(operator Expression, matchers ...Expression) bool {
for _, matcher := range matchers {
if operator == matcher {
return true
}
}

return false
return slices.Contains(matchers, operator)
}

func OperatorIsBoolean(operator Expression) bool {
Expand Down Expand Up @@ -59,40 +55,41 @@ func OperatorIsComparator(operator Expression) bool {
return OperatorIsIn(operator,
OperatorEquals, OperatorNotEquals, OperatorGreaterThan, OperatorGreaterThanOrEqualTo, OperatorLessThan,
OperatorLessThanOrEqualTo, OperatorArrayOverlap, OperatorLike, OperatorILike, OperatorPGArrayOverlap,
OperatorRegexMatch, OperatorSimilarTo)
OperatorRegexMatch, OperatorSimilarTo, OperatorPGArrayLHSContainsRHS)
}

const (
UnsetOperator Operator = ""
OperatorUnion Operator = "union"
OperatorConcatenate Operator = "||"
OperatorArrayOverlap Operator = "&&"
OperatorEquals Operator = "="
OperatorNotEquals Operator = "!="
OperatorGreaterThan Operator = ">"
OperatorGreaterThanOrEqualTo Operator = ">="
OperatorLessThan Operator = "<"
OperatorLessThanOrEqualTo Operator = "<="
OperatorLike Operator = "like"
OperatorILike Operator = "ilike"
OperatorPGArrayOverlap Operator = "operator (pg_catalog.&&)"
OperatorAnd Operator = "and"
OperatorOr Operator = "or"
OperatorNot Operator = "not"
OperatorJSONBFieldExists Operator = "?"
OperatorJSONField Operator = "->"
OperatorJSONTextField Operator = "->>"
OperatorAdd Operator = "+"
OperatorSubtract Operator = "-"
OperatorMultiply Operator = "*"
OperatorDivide Operator = "/"
OperatorIn Operator = "in"
OperatorIs Operator = "is"
OperatorIsNot Operator = "is not"
OperatorSimilarTo Operator = "similar to"
OperatorRegexMatch Operator = "~"
OperatorAssignment Operator = "="
OperatorAdditionAssignment Operator = "+="
UnsetOperator Operator = ""
OperatorUnion Operator = "union"
OperatorConcatenate Operator = "||"
OperatorArrayOverlap Operator = "&&"
OperatorEquals Operator = "="
OperatorNotEquals Operator = "!="
OperatorGreaterThan Operator = ">"
OperatorGreaterThanOrEqualTo Operator = ">="
OperatorLessThan Operator = "<"
OperatorLessThanOrEqualTo Operator = "<="
OperatorLike Operator = "like"
OperatorILike Operator = "ilike"
OperatorPGArrayOverlap Operator = "operator (pg_catalog.&&)"
OperatorPGArrayLHSContainsRHS Operator = "operator (pg_catalog.@>)"
OperatorAnd Operator = "and"
OperatorOr Operator = "or"
OperatorNot Operator = "not"
OperatorJSONBFieldExists Operator = "?"
OperatorJSONField Operator = "->"
OperatorJSONTextField Operator = "->>"
OperatorAdd Operator = "+"
OperatorSubtract Operator = "-"
OperatorMultiply Operator = "*"
OperatorDivide Operator = "/"
OperatorIn Operator = "in"
OperatorIs Operator = "is"
OperatorIsNot Operator = "is not"
OperatorSimilarTo Operator = "similar to"
OperatorRegexMatch Operator = "~"
OperatorAssignment Operator = "="
OperatorAdditionAssignment Operator = "+="

OperatorCypherRegexMatch Operator = "=~"
OperatorCypherStartsWith Operator = "starts with"
Expand Down
6 changes: 2 additions & 4 deletions cypher/models/pgsql/pgtypes.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,9 +10,7 @@ import (
"github.com/specterops/dawgs/graph"
)

var (
ErrNoAvailableArrayDataType = errors.New("data type has no direct array representation")
)
var ErrNoAvailableArrayDataType = errors.New("data type has no direct array representation")

const (
StringLiteralNull = "null"
Expand Down Expand Up @@ -118,7 +116,7 @@ func (s DataType) IsKnown() bool {

func (s DataType) IsComparable(other DataType, operator Operator) bool {
switch operator {
case OperatorPGArrayOverlap, OperatorArrayOverlap:
case OperatorPGArrayOverlap, OperatorArrayOverlap, OperatorPGArrayLHSContainsRHS:
if !s.IsArrayType() || !other.IsArrayType() {
return false
}
Expand Down
14 changes: 14 additions & 0 deletions cypher/models/pgsql/pytypes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -201,6 +201,20 @@ func TestDataType_Comparable(t *testing.T) {
Expected: false,
},

// Array types may use the "LHS contains RHS" operator but only if their base types match
{
LeftTypes: []DataType{IntArray},
Operators: []Operator{OperatorPGArrayLHSContainsRHS},
RightTypes: []DataType{IntArray},
Expected: true,
},
{
LeftTypes: []DataType{IntArray},
Operators: []Operator{OperatorPGArrayLHSContainsRHS},
RightTypes: []DataType{Int},
Expected: false,
},

// Catch all for any unsupported operator
{
LeftTypes: []DataType{Int},
Expand Down
2 changes: 1 addition & 1 deletion cypher/models/pgsql/translate/hinting.go
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ func InferExpressionType(expression pgsql.Expression) (pgsql.DataType, error) {

case pgsql.OperatorAnd, pgsql.OperatorOr, pgsql.OperatorEquals, pgsql.OperatorGreaterThan, pgsql.OperatorGreaterThanOrEqualTo,
pgsql.OperatorLessThan, pgsql.OperatorLessThanOrEqualTo, pgsql.OperatorIn, pgsql.OperatorJSONBFieldExists,
pgsql.OperatorLike, pgsql.OperatorILike, pgsql.OperatorPGArrayOverlap:
pgsql.OperatorLike, pgsql.OperatorILike, pgsql.OperatorPGArrayOverlap, pgsql.OperatorPGArrayLHSContainsRHS:
return pgsql.Boolean, nil

default:
Expand Down
2 changes: 1 addition & 1 deletion cypher/models/pgsql/translate/kind.go
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ func newPGKindIDMatcher(scope *Scope, treeTranslator *ExpressionTreeTranslator,
treeTranslator.PushOperand(pgd.Column(binding.Identifier, pgsql.ColumnKindIDs))
treeTranslator.PushOperand(kindIDsLiteral)

return treeTranslator.CompleteBinaryExpression(scope, pgsql.OperatorPGArrayOverlap)
return treeTranslator.CompleteBinaryExpression(scope, pgsql.OperatorPGArrayLHSContainsRHS)

case pgsql.EdgeComposite, pgsql.ExpansionEdge:
treeTranslator.PushOperand(pgsql.CompoundIdentifier{binding.Identifier, pgsql.ColumnKindID})
Expand Down
2 changes: 1 addition & 1 deletion cypher/models/pgsql/translate/node.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ func (s *Translator) translateNodePatternToStep(nodePattern *cypher.NodePattern,
return err
} else if err := s.treeTranslator.AddTranslationConstraint(pgsql.NewIdentifierSet().Add(bindingResult.Binding.Identifier), pgsql.NewBinaryExpression(
pgsql.CompoundIdentifier{bindingResult.Binding.Identifier, pgsql.ColumnKindIDs},
pgsql.OperatorPGArrayOverlap,
pgsql.OperatorPGArrayLHSContainsRHS,
kindIDsLiteral,
)); err != nil {
return err
Expand Down
Loading