File tree Expand file tree Collapse file tree 2 files changed +10
-1
lines changed Expand file tree Collapse file tree 2 files changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,7 @@ go_library(
1717 "//pkg/sql/catalog/catpb" ,
1818 "//pkg/sql/catalog/descs" ,
1919 "//pkg/sql/isql" ,
20+ "//pkg/sql/lexbase" ,
2021 "//pkg/sql/pgwire/pgcode" ,
2122 "//pkg/sql/pgwire/pgerror" ,
2223 "//pkg/sql/sem/tree" ,
Original file line number Diff line number Diff line change 66package ttlschedule
77
88import (
9+ "bytes"
910 "context"
1011 "fmt"
1112
@@ -20,6 +21,7 @@ import (
2021 "github.com/cockroachdb/cockroach/pkg/sql/catalog/catpb"
2122 "github.com/cockroachdb/cockroach/pkg/sql/catalog/descs"
2223 "github.com/cockroachdb/cockroach/pkg/sql/isql"
24+ "github.com/cockroachdb/cockroach/pkg/sql/lexbase"
2325 "github.com/cockroachdb/cockroach/pkg/sql/pgwire/pgcode"
2426 "github.com/cockroachdb/cockroach/pkg/sql/pgwire/pgerror"
2527 "github.com/cockroachdb/cockroach/pkg/sql/sem/tree"
@@ -222,7 +224,13 @@ func makeTTLJobDescription(
222224) string {
223225 relationName := tn .FQString ()
224226 pkIndex := tableDesc .GetPrimaryIndex ().IndexDesc ()
225- pkColNames := pkIndex .KeyColumnNames
227+ pkColNames := make ([]string , 0 , len (pkIndex .KeyColumnNames ))
228+ var buf bytes.Buffer
229+ for _ , name := range pkIndex .KeyColumnNames {
230+ lexbase .EncodeRestrictedSQLIdent (& buf , name , lexbase .EncNoFlags )
231+ pkColNames = append (pkColNames , buf .String ())
232+ buf .Reset ()
233+ }
226234 pkColDirs := pkIndex .KeyColumnDirections
227235 rowLevelTTL := tableDesc .GetRowLevelTTL ()
228236 ttlExpirationExpr := rowLevelTTL .GetTTLExpr ()
You can’t perform that action at this time.
0 commit comments