workload/schemachange: handle LTREE in mixed version CREATE TYPE

Using this type in a composite type in a mixed version cluster will
cause UndefinedObject errors, so we need to make the workload aware of
that.

Release note: None

Author: rafiss

pkg/sql/randgen/schema.go

@@ -40,7 +40,7 @@ func MakeSchemaName(ifNotExists bool, schema string, authRole tree.RoleSpec) *tr
 // RandCreateEnumType creates a random CREATE TYPE <type_name> AS ENUM statement.
 // The resulting type's name will be name, the enum members will
 // be random strings generated from alphabet.
-func RandCreateEnumType(rng *rand.Rand, name, alphabet string) tree.Statement {
+func RandCreateEnumType(rng *rand.Rand, name, alphabet string) *tree.CreateType {
 	numLabels := rng.Intn(6) + 1
 	labels := make(tree.EnumValueList, numLabels)
 	labelsMap := make(map[string]struct{})
@@ -66,7 +66,7 @@ func RandCreateEnumType(rng *rand.Rand, name, alphabet string) tree.Statement {
 }
 
 // RandCreateCompositeType creates a random composite type statement.
-func RandCreateCompositeType(rng *rand.Rand, name, alphabet string) tree.Statement {
+func RandCreateCompositeType(rng *rand.Rand, name, alphabet string) *tree.CreateType {
 	var compositeTypeList []tree.CompositeTypeElem
 
 	numTypes := rng.Intn(6) + 1

pkg/workload/schemachange/operation_generator.go

@@ -1359,15 +1359,36 @@ func (og *operationGenerator) createType(
 	})
 
 	const letters = "abcdefghijklmnopqrstuvwxyz"
-	var statement tree.Statement
+	var statement *tree.CreateType
 
 	if isEnum {
 		statement = randgen.RandCreateEnumType(og.params.rng, typName.Object(), letters)
 	} else {
 		statement = randgen.RandCreateCompositeType(og.params.rng, typName.Object(), letters)
+
+		hasTypeWithPrefix := func(typePrefix string) bool {
+			for _, field := range statement.CompositeTypeList {
+				if strings.HasPrefix(field.Type.SQLString(), typePrefix) {
+					return true
+				}
+			}
+			return false
+		}
+
+		// Check for references to any types that are not supported in mixed version
+		// clusters.
+		ltreeNotSupported, err := isClusterVersionLessThan(ctx, tx, clusterversion.V25_4.Version())
+		if err != nil {
+			return nil, err
+		}
+		hasLtreeType := hasTypeWithPrefix("LTREE")
+		opStmt.potentialExecErrors.addAll(codesWithConditions{
+			{code: pgcode.UndefinedObject, condition: hasLtreeType && ltreeNotSupported},
+			{code: pgcode.Syntax, condition: hasLtreeType && ltreeNotSupported},
+		})
 	}
 
-	statement.(*tree.CreateType).TypeName = typName.ToUnresolvedObjectName()
+	statement.TypeName = typName.ToUnresolvedObjectName()
 	opStmt.sql = tree.Serialize(statement)
 	return opStmt, nil
 }