Skip to content

Commit

Permalink
added support for primary key rely
Browse files Browse the repository at this point in the history
  • Loading branch information
hshahconsulting committed Oct 25, 2024
1 parent 021c206 commit eb8f4ca
Show file tree
Hide file tree
Showing 3 changed files with 10 additions and 2 deletions.
7 changes: 6 additions & 1 deletion catalog/resource_sql_table.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@ type SqlKeyConstraint interface {

type SqlPrimaryKeyConstraint struct {
PrimaryKey string `json:"primary_key" tf:"alias:key,computed"`
Rely bool `json:"rely,omitempty" tf:"default:false,alias:key,computed"`
}

type SqlForeignKeyConstraint struct {
Expand All @@ -63,7 +64,11 @@ type SqlForeignKeyConstraint struct {
}

func (sqlKeyConstraint SqlPrimaryKeyConstraint) getConstraint() string {
return fmt.Sprintf("PRIMARY KEY (%s)", sqlKeyConstraint.PrimaryKey)
var constraint = fmt.Sprintf("PRIMARY KEY (%s)", sqlKeyConstraint.PrimaryKey)
if sqlKeyConstraint.Rely == true {
constraint += " RELY"
}
return constraint
}

func (sqlKeyConstraint SqlForeignKeyConstraint) getConstraint() string {
Expand Down
3 changes: 2 additions & 1 deletion catalog/resource_sql_table_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -88,6 +88,7 @@ func TestResourceSqlTableCreateStatement_PrimaryKeyConstraint(t *testing.T) {
{
SqlKeyConstraint: SqlPrimaryKeyConstraint{
PrimaryKey: "id",
Rely: true,
},
},
},
Expand All @@ -96,7 +97,7 @@ func TestResourceSqlTableCreateStatement_PrimaryKeyConstraint(t *testing.T) {
assert.Contains(t, stmt, "CREATE EXTERNAL TABLE `main`.`foo`.`bar`")
assert.Contains(t, stmt, "USING DELTA")
assert.Contains(t, stmt, "(`id` NOT NULL, `name` NOT NULL COMMENT 'a comment')")
assert.Contains(t, stmt, "(PRIMARY KEY (id))")
assert.Contains(t, stmt, "(PRIMARY KEY (id) RELY)")
assert.Contains(t, stmt, "LOCATION 's3://ext-main/foo/bar1' WITH (CREDENTIAL `somecred`)")
assert.Contains(t, stmt, "COMMENT 'terraform managed'")
}
Expand Down
2 changes: 2 additions & 0 deletions internal/acceptance/sql_table_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -171,6 +171,7 @@ func TestUcAccResourceSqlTableWithPrimaryAndForeignKeyConstraints_Managed(t *tes
}
key_constraint {
primary_key = "id"
rely = "true"
}
key_constraint {
referenced_key = "external_id"
Expand Down Expand Up @@ -213,6 +214,7 @@ func TestUcAccResourceSqlTableWithPrimaryAndForeignKeyConstraints_Managed(t *tes
}
key_constraint {
primary_key = "id"
rely = "true"
}
key_constraint {
referenced_key = "external_id"
Expand Down

0 comments on commit eb8f4ca

Please sign in to comment.