Skip to content

Commit 0cf4ff8

Browse files
authored
fix: When cq_id is pkey remove unique (#20)
1 parent 9060335 commit 0cf4ff8

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

plugins/source.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ func addInternalColumns(tables []*schema.Table) {
7070
cqId := schema.CqIdColumn
7171
if len(table.PrimaryKeys()) == 0 {
7272
cqId.CreationOptions.PrimaryKey = true
73+
cqId.CreationOptions.Unique = false
7374
}
7475
table.Columns = append(table.Columns, cqId, schema.CqFetchTime)
7576
addInternalColumns(table.Relations)

0 commit comments

Comments
 (0)