Allow different but compatible types in foreign key constraints

go.mod

@@ -10,7 +10,7 @@ require (
 	github.com/dolthub/dolt/go/gen/proto/dolt/services/eventsapi v0.0.0-20241119094239-f4e529af734d
 	github.com/dolthub/flatbuffers/v23 v23.3.3-dh.2
 	github.com/dolthub/go-icu-regex v0.0.0-20250303123116-549b8d7cad00
-	github.com/dolthub/go-mysql-server v0.19.1-0.20250306014046-f73a318f7731
+	github.com/dolthub/go-mysql-server v0.19.1-0.20250312002336-2f80db58ecab
 	github.com/dolthub/sqllogictest/go v0.0.0-20240618184124-ca47f9354216
 	github.com/dolthub/vitess v0.0.0-20250304211657-920ca9ec2b9a
 	github.com/fatih/color v1.13.0

go.sum

@@ -224,8 +224,8 @@ github.com/dolthub/fslock v0.0.3 h1:iLMpUIvJKMKm92+N1fmHVdxJP5NdyDK5bK7z7Ba2s2U=
 github.com/dolthub/fslock v0.0.3/go.mod h1:QWql+P17oAAMLnL4HGB5tiovtDuAjdDTPbuqx7bYfa0=
 github.com/dolthub/go-icu-regex v0.0.0-20250303123116-549b8d7cad00 h1:rh2ij2yTYKJWlX+c8XRg4H5OzqPewbU1lPK8pcfVmx8=
 github.com/dolthub/go-icu-regex v0.0.0-20250303123116-549b8d7cad00/go.mod h1:ylU4XjUpsMcvl/BKeRRMXSH7e7WBrPXdSLvnRJYrxEA=
-github.com/dolthub/go-mysql-server v0.19.1-0.20250306014046-f73a318f7731 h1:flDUXUqKRo4u5gdoQZBeO3jESUnCNkv01GDmiZbgAA4=
-github.com/dolthub/go-mysql-server v0.19.1-0.20250306014046-f73a318f7731/go.mod h1:yr+Vv47/YLOKMgiEY+QxHTlbIVpTuiVtkEZ5l+xruY4=
+github.com/dolthub/go-mysql-server v0.19.1-0.20250312002336-2f80db58ecab h1:BhD0ykPxUd91XfF+FDT+BWCeqd/h22Lg56NRAnYoAaA=
+github.com/dolthub/go-mysql-server v0.19.1-0.20250312002336-2f80db58ecab/go.mod h1:yr+Vv47/YLOKMgiEY+QxHTlbIVpTuiVtkEZ5l+xruY4=
 github.com/dolthub/gozstd v0.0.0-20240423170813-23a2903bca63 h1:OAsXLAPL4du6tfbBgK0xXHZkOlos63RdKYS3Sgw/dfI=
 github.com/dolthub/gozstd v0.0.0-20240423170813-23a2903bca63/go.mod h1:lV7lUeuDhH5thVGDCKXbatwKy2KW80L4rMT46n+Y2/Q=
 github.com/dolthub/ishell v0.0.0-20240701202509-2b217167d718 h1:lT7hE5k+0nkBdj/1UOSFwjWpNxf+LCApbRHgnCA17XE=

server/analyzer/init.go

@@ -15,7 +15,16 @@
 package analyzer
 
 import (
+	"strings"
+
+	"github.com/cockroachdb/errors"
+	"github.com/dolthub/go-mysql-server/sql"
 	"github.com/dolthub/go-mysql-server/sql/analyzer"
+	"github.com/dolthub/go-mysql-server/sql/expression"
+	"github.com/dolthub/go-mysql-server/sql/plan"
+
+	"github.com/dolthub/doltgresql/server/functions/framework"
+	"github.com/dolthub/doltgresql/server/types"
 )
 
 // IDs are basically arbitrary, we just need to ensure that they do not conflict with existing IDs
@@ -86,6 +95,55 @@ func Init() {
 		analyzer.Rule{Id: ruleId_AddDomainConstraintsToCasts, Apply: AddDomainConstraintsToCasts},
 		analyzer.Rule{Id: ruleId_ReplaceNode, Apply: ReplaceNode},
 		analyzer.Rule{Id: ruleId_InsertContextRootFinalizer, Apply: InsertContextRootFinalizer})
+
+	initEngine()
+}
+
+func initEngine() {
+	plan.ValidateForeignKeyDefinition = validateForeignKeyDefinition
+}
+
+// validateForeignKeyDefinition validates that the given foreign key definition is valid for creation
+func validateForeignKeyDefinition(ctx *sql.Context, fkDef sql.ForeignKeyConstraint, cols map[string]*sql.Column, parentCols map[string]*sql.Column) error {
+	for i := range fkDef.Columns {
+		col := cols[strings.ToLower(fkDef.Columns[i])]
+		parentCol := parentCols[strings.ToLower(fkDef.ParentColumns[i])]
+		if !foreignKeyComparableTypes(col.Type, parentCol.Type) {
+			return errors.Errorf("Key columns %q and %q are of incompatible types: %s and %s", col.Name, parentCol.Name, col.Type.String(), parentCol.Type.String())
+		}
+	}
+	return nil
+}
+
+// foreignKeyComparableTypes returns whether the two given types are able to be used as parent/child columns in a
+// foreign key.
+func foreignKeyComparableTypes(from sql.Type, to sql.Type) bool {
+	dtFrom, ok := from.(*types.DoltgresType)
+	if !ok {
+		return false // should never be possible
+	}
+
+	dtTo, ok := to.(*types.DoltgresType)
+	if !ok {
+		return false // should never be possible
+	}
+
+	if dtFrom.Equals(dtTo) {
+		return true
+	}
+
+	fromLiteral := expression.NewLiteral(dtFrom.Zero(), from)
+	toLiteral := expression.NewLiteral(dtTo.Zero(), to)
+
+	// a foreign key between two different types is valid if there is an equality operator on the two types
+	// TODO: there are some subtleties in postgres not captured by this logic, e.g. a foreign key from double -> int
+	//  is valid, but the reverse is not. This works fine, but is more permissive than postgres is.
+	eq := framework.GetBinaryFunction(framework.Operator_BinaryEqual).Compile("=", fromLiteral, toLiteral)
+	if eq != nil && eq.StashedError() == nil {
+		return true
+	}
+
+	return false
 }
 
 // insertAnalyzerRules inserts the given rule(s) before or after the given analyzer.RuleId, returning an updated slice.

server/ast/alter_table.go

@@ -181,7 +181,10 @@ func nodeAlterTableAddConstraint(
 			IfExists:         ifExists,
 			TableSpec: &vitess.TableSpec{
 				Constraints: []*vitess.ConstraintDefinition{
-					{Details: foreignKeyDefinition},
+					{
+						Name:    constraintDef.Name.String(),
+						Details: foreignKeyDefinition,
+					},
 				},
 			},
 		}, nil

server/ast/constraint_table_def.go

@@ -128,6 +128,7 @@ func nodeUniqueConstraintTableDef(
 		Table:    tableName,
 		IfExists: ifExists,
 		IndexSpec: &vitess.IndexSpec{
+			ToName:  vitess.NewColIdent(node.Name.String()),
 			Action:  "create",
 			Type:    indexType,
 			Columns: columns,

server/cast/init.go

@@ -14,6 +14,11 @@
 
 package cast
 
+import (
+	"github.com/dolthub/doltgresql/server/functions/framework"
+	"github.com/dolthub/doltgresql/server/types"
+)
+
 // Init initializes all casts in this package.
 func Init() {
 	initBool()
@@ -40,4 +45,8 @@ func Init() {
 	initTimestampTZ()
 	initTimeTZ()
 	initVarChar()
+
+	// This is a hack to get around import cycles
+	types.GetImplicitCast = framework.GetImplicitCast
+	types.GetAssignmentCast = framework.GetAssignmentCast
 }

server/cast/utils.go

@@ -32,6 +32,8 @@ var errOutOfRange = errors.NewKind("%s out of range")
 func handleStringCast(str string, targetType *pgtypes.DoltgresType) (string, error) {
 	tm := targetType.GetAttTypMod()
 	switch targetType.ID {
+	case pgtypes.Text.ID:
+		return str, nil
 	case pgtypes.BpChar.ID:
 		if tm == -1 {
 			return str, nil

server/functions/framework/cast.go

@@ -26,26 +26,22 @@ import (
 
 // TODO: Right now, all casts are global. We should decide how to handle this in the presence of branches, sessions, etc.
 
-// TypeCastFunction is a function that takes a value of a particular kind of type, and returns it as another kind of type.
-// The targetType given should match the "To" type used to obtain the cast.
-type TypeCastFunction func(ctx *sql.Context, val any, targetType *pgtypes.DoltgresType) (any, error)
-
 // getCastFunction is used to recursively call the cast function for when the inner logic sees that it has two array
 // types. This sidesteps providing
-type getCastFunction func(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) TypeCastFunction
+type getCastFunction func(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) pgtypes.TypeCastFunction
 
 // TypeCast is used to cast from one type to another.
 type TypeCast struct {
 	FromType *pgtypes.DoltgresType
 	ToType   *pgtypes.DoltgresType
-	Function TypeCastFunction
+	Function pgtypes.TypeCastFunction
 }
 
 // explicitTypeCastMutex is used to lock the explicit type cast map and array when writing.
 var explicitTypeCastMutex = &sync.RWMutex{}
 
 // explicitTypeCastsMap is a map that maps: from -> to -> function.
-var explicitTypeCastsMap = map[id.Type]map[id.Type]TypeCastFunction{}
+var explicitTypeCastsMap = map[id.Type]map[id.Type]pgtypes.TypeCastFunction{}
 
 // explicitTypeCastsArray is a slice that holds all registered explicit casts from the given type.
 var explicitTypeCastsArray = map[id.Type][]*pgtypes.DoltgresType{}
@@ -54,7 +50,7 @@ var explicitTypeCastsArray = map[id.Type][]*pgtypes.DoltgresType{}
 var assignmentTypeCastMutex = &sync.RWMutex{}
 
 // assignmentTypeCastsMap is a map that maps: from -> to -> function.
-var assignmentTypeCastsMap = map[id.Type]map[id.Type]TypeCastFunction{}
+var assignmentTypeCastsMap = map[id.Type]map[id.Type]pgtypes.TypeCastFunction{}
 
 // assignmentTypeCastsArray is a slice that holds all registered assignment casts from the given type.
 var assignmentTypeCastsArray = map[id.Type][]*pgtypes.DoltgresType{}
@@ -63,7 +59,7 @@ var assignmentTypeCastsArray = map[id.Type][]*pgtypes.DoltgresType{}
 var implicitTypeCastMutex = &sync.RWMutex{}
 
 // implicitTypeCastsMap is a map that maps: from -> to -> function.
-var implicitTypeCastsMap = map[id.Type]map[id.Type]TypeCastFunction{}
+var implicitTypeCastsMap = map[id.Type]map[id.Type]pgtypes.TypeCastFunction{}
 
 // implicitTypeCastsArray is a slice that holds all registered implicit casts from the given type.
 var implicitTypeCastsArray = map[id.Type][]*pgtypes.DoltgresType{}
@@ -126,7 +122,7 @@ func GetPotentialImplicitCasts(fromType id.Type) []*pgtypes.DoltgresType {
 
 // GetExplicitCast returns the explicit type cast function that will cast the "from" type to the "to" type. Returns nil
 // if such a cast is not valid.
-func GetExplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) TypeCastFunction {
+func GetExplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) pgtypes.TypeCastFunction {
 	if tcf := getCast(explicitTypeCastMutex, explicitTypeCastsMap, fromType, toType, GetExplicitCast); tcf != nil {
 		return tcf
 	} else if tcf = getCast(assignmentTypeCastMutex, assignmentTypeCastsMap, fromType, toType, GetExplicitCast); tcf != nil {
@@ -170,7 +166,7 @@ func GetExplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresTyp
 
 // GetAssignmentCast returns the assignment type cast function that will cast the "from" type to the "to" type. Returns
 // nil if such a cast is not valid.
-func GetAssignmentCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) TypeCastFunction {
+func GetAssignmentCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) pgtypes.TypeCastFunction {
 	if tcf := getCast(assignmentTypeCastMutex, assignmentTypeCastsMap, fromType, toType, GetAssignmentCast); tcf != nil {
 		return tcf
 	} else if tcf = getCast(implicitTypeCastMutex, implicitTypeCastsMap, fromType, toType, GetAssignmentCast); tcf != nil {
@@ -199,7 +195,7 @@ func GetAssignmentCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresT
 
 // GetImplicitCast returns the implicit type cast function that will cast the "from" type to the "to" type. Returns nil
 // if such a cast is not valid.
-func GetImplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) TypeCastFunction {
+func GetImplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType) pgtypes.TypeCastFunction {
 	if tcf := getCast(implicitTypeCastMutex, implicitTypeCastsMap, fromType, toType, GetImplicitCast); tcf != nil {
 		return tcf
 	}
@@ -213,14 +209,14 @@ func GetImplicitCast(fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresTyp
 
 // addTypeCast registers the given type cast.
 func addTypeCast(mutex *sync.RWMutex,
-	castMap map[id.Type]map[id.Type]TypeCastFunction,
+	castMap map[id.Type]map[id.Type]pgtypes.TypeCastFunction,
 	castArray map[id.Type][]*pgtypes.DoltgresType, cast TypeCast) error {
 	mutex.Lock()
 	defer mutex.Unlock()
 
 	toMap, ok := castMap[cast.FromType.ID]
 	if !ok {
-		toMap = map[id.Type]TypeCastFunction{}
+		toMap = map[id.Type]pgtypes.TypeCastFunction{}
 		castMap[cast.FromType.ID] = toMap
 		castArray[cast.FromType.ID] = nil
 	}
@@ -244,8 +240,8 @@ func getPotentialCasts(mutex *sync.RWMutex, castArray map[id.Type][]*pgtypes.Dol
 // getCast returns the type cast function that will cast the "from" type to the "to" type. Returns nil if such a cast is
 // not valid.
 func getCast(mutex *sync.RWMutex,
-	castMap map[id.Type]map[id.Type]TypeCastFunction,
-	fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType, outerFunc getCastFunction) TypeCastFunction {
+	castMap map[id.Type]map[id.Type]pgtypes.TypeCastFunction,
+	fromType *pgtypes.DoltgresType, toType *pgtypes.DoltgresType, outerFunc getCastFunction) pgtypes.TypeCastFunction {
 	mutex.RLock()
 	defer mutex.RUnlock()
 

server/functions/framework/compiled_function.go

@@ -403,7 +403,7 @@ func (c *CompiledFunction) resolveOperator(argTypes []*pgtypes.DoltgresType, ove
 		rightUnknownType := argTypes[1].ID == pgtypes.Unknown.ID
 		if (leftUnknownType && !rightUnknownType) || (!leftUnknownType && rightUnknownType) {
 			var typ *pgtypes.DoltgresType
-			casts := []TypeCastFunction{identityCast, identityCast}
+			casts := []pgtypes.TypeCastFunction{identityCast, identityCast}
 			if leftUnknownType {
 				casts[0] = UnknownLiteralCast
 				typ = argTypes[1]
@@ -484,7 +484,7 @@ func (c *CompiledFunction) typeCompatibleOverloads(fnOverloads []Overload, argTy
 	var compatible []overloadMatch
 	for _, overload := range fnOverloads {
 		isConvertible := true
-		overloadCasts := make([]TypeCastFunction, len(argTypes))
+		overloadCasts := make([]pgtypes.TypeCastFunction, len(argTypes))
 		// Polymorphic parameters must be gathered so that we can later verify that they all have matching base types
 		var polymorphicParameters []*pgtypes.DoltgresType
 		var polymorphicTargets []*pgtypes.DoltgresType

server/functions/framework/overloads.go

@@ -165,7 +165,7 @@ func (o *Overload) coalesceVariadicValues(returnValues []any) []any {
 // as the type cast functions required to convert every argument to its appropriate parameter type
 type overloadMatch struct {
 	params Overload
-	casts  []TypeCastFunction
+	casts  []pgtypes.TypeCastFunction
 }
 
 // Valid returns whether this overload is valid (has a callable function)

server/types/type.go

@@ -364,6 +364,28 @@ func (t *DoltgresType) Convert(v interface{}) (interface{}, sql.ConvertInRange,
 	return nil, sql.OutOfRange, ErrUnhandledType.New(t.String(), v)
 }
 
+// GetImplicitCast is a reference to the implicit cast logic in the functions/framework package, which we can't use
+// here due to import cycles
+var GetImplicitCast func(fromType *DoltgresType, toType *DoltgresType) TypeCastFunction
+
+// GetAssignmentCast is a reference to the assignment cast logic in the functions/framework package, which we can't use
+// here due to import cycles
+var GetAssignmentCast func(fromType *DoltgresType, toType *DoltgresType) TypeCastFunction
+
+func (t *DoltgresType) ConvertToType(ctx *sql.Context, typ types.ExtendedType, val any) (any, error) {
+	dt, ok := typ.(*DoltgresType)
+	if !ok {
+		return nil, errors.Errorf("expected DoltgresType, got %T", typ)
+	}
+
+	castFn := GetAssignmentCast(dt, t)
+	if castFn == nil {
+		return nil, errors.Errorf("no assignment cast from %s to %s", dt.Name(), t.Name())
+	}
+
+	return castFn(ctx, val, dt)
+}
+
 // DomainUnderlyingBaseType returns an underlying base type of this domain type.
 // It can be a nested domain type, so it recursively searches for a valid base type.
 func (t *DoltgresType) DomainUnderlyingBaseType() *DoltgresType {
@@ -851,3 +873,7 @@ func (t *DoltgresType) DeserializeValue(ctx context.Context, val []byte) (any, e
 		return globalFunctionRegistry.GetFunction(t.ReceiveFunc).CallVariadic(nil, val)
 	}
 }
+
+// TypeCastFunction is a function that takes a value of a particular kind of type, and returns it as another kind of type.
+// The targetType given should match the "To" type used to obtain the cast.
+type TypeCastFunction func(ctx *sql.Context, val any, targetType *DoltgresType) (any, error)