sql: add version gating for row-level TTL

docs/generated/settings/settings-for-tenants.txt

@@ -185,4 +185,4 @@ trace.debug.enable	boolean	false	if set, traces for recent requests can be seen
 trace.jaeger.agent	string		the address of a Jaeger agent to receive traces using the Jaeger UDP Thrift protocol, as <host>:<port>. If no port is specified, 6381 will be used.
 trace.opentelemetry.collector	string		address of an OpenTelemetry trace collector to receive traces using the otel gRPC protocol, as <host>:<port>. If no port is specified, 4317 will be used.
 trace.zipkin.collector	string		the address of a Zipkin instance to receive traces, as <host>:<port>. If no port is specified, 9411 will be used.
-version	version	21.2-86	set the active cluster version in the format '<major>.<minor>'
+version	version	21.2-88	set the active cluster version in the format '<major>.<minor>'

docs/generated/settings/settings.html

@@ -198,6 +198,6 @@
 <tr><td><code>trace.jaeger.agent</code></td><td>string</td><td><code></code></td><td>the address of a Jaeger agent to receive traces using the Jaeger UDP Thrift protocol, as <host>:<port>. If no port is specified, 6381 will be used.</td></tr>
 <tr><td><code>trace.opentelemetry.collector</code></td><td>string</td><td><code></code></td><td>address of an OpenTelemetry trace collector to receive traces using the otel gRPC protocol, as <host>:<port>. If no port is specified, 4317 will be used.</td></tr>
 <tr><td><code>trace.zipkin.collector</code></td><td>string</td><td><code></code></td><td>the address of a Zipkin instance to receive traces, as <host>:<port>. If no port is specified, 9411 will be used.</td></tr>
-<tr><td><code>version</code></td><td>version</td><td><code>21.2-86</code></td><td>set the active cluster version in the format '<major>.<minor>'</td></tr>
+<tr><td><code>version</code></td><td>version</td><td><code>21.2-88</code></td><td>set the active cluster version in the format '<major>.<minor>'</td></tr>
 </tbody>
 </table>

pkg/clusterversion/cockroach_versions.go

@@ -309,6 +309,9 @@ const (
 	// can be used to construct schema change plan node.
 	EnableDeclarativeSchemaChanger
 
+	// RowLevelTTL is the version where we allow row level TTL tables.
+	RowLevelTTL
+
 	// *************************************************
 	// Step (1): Add new versions here.
 	// Do not add new versions to a patch release.
@@ -507,6 +510,10 @@ var versionsSingleton = keyedVersions{
 		Key:     EnableDeclarativeSchemaChanger,
 		Version: roachpb.Version{Major: 21, Minor: 2, Internal: 86},
 	},
+	{
+		Key:     RowLevelTTL,
+		Version: roachpb.Version{Major: 21, Minor: 2, Internal: 88},
+	},
 
 	// *************************************************
 	// Step (2): Add new versions here.

pkg/sql/alter_table.go

@@ -1865,6 +1865,10 @@ func handleTTLStorageParamChange(
 			}
 		}
 	case before == nil && after != nil:
+		if err := checkTTLEnabledForCluster(params.ctx, params.p.ExecCfg().Settings); err != nil {
+			return err
+		}
+
 		// Adding a TTL requires adding the automatic column and deferring the TTL
 		// addition to after the column is successfully added.
 		tableDesc.RowLevelTTL = nil

pkg/sql/create_table.go

@@ -19,6 +19,7 @@ import (
 	"time"
 
 	"github.com/cockroachdb/cockroach/pkg/build"
+	"github.com/cockroachdb/cockroach/pkg/clusterversion"
 	"github.com/cockroachdb/cockroach/pkg/docs"
 	"github.com/cockroachdb/cockroach/pkg/geo/geoindex"
 	"github.com/cockroachdb/cockroach/pkg/jobs"
@@ -1442,6 +1443,9 @@ func NewTableDesc(
 
 	// Create the TTL column if one does not already exist.
 	if ttl := desc.GetRowLevelTTL(); ttl != nil {
+		if err := checkTTLEnabledForCluster(ctx, st); err != nil {
+			return nil, err
+		}
 		hasRowLevelTTLColumn := false
 		for _, def := range n.Defs {
 			switch def := def.(type) {
@@ -2390,6 +2394,16 @@ func rowLevelTTLSchedule(ttl *catpb.RowLevelTTL) string {
 	return defaultTTLScheduleCron
 }
 
+func checkTTLEnabledForCluster(ctx context.Context, st *cluster.Settings) error {
+	if !st.Version.IsActive(ctx, clusterversion.RowLevelTTL) {
+		return pgerror.Newf(
+			pgcode.FeatureNotSupported,
+			"row level TTL is only available once the cluster is fully upgraded",
+		)
+	}
+	return nil
+}
+
 // CreateRowLevelTTLScheduledJob creates a new row-level TTL schedule.
 func CreateRowLevelTTLScheduledJob(
 	ctx context.Context,

pkg/sql/logictest/testdata/logic_test/row_level_ttl_mixed_21.2_22.1

@@ -0,0 +1,10 @@
+# LogicTest: local-mixed-21.2-22.1
+
+statement error row level TTL is only available once the cluster is fully upgraded
+CREATE TABLE tbl () WITH (ttl_expire_after = '10 minutes')
+
+statement ok
+CREATE TABLE tbl ()
+
+statement error row level TTL is only available once the cluster is fully upgraded
+ALTER TABLE tbl SET (ttl_expire_after = '10 minutes')