feat: Remove Unique constraint (support pks only) (#41)

Author: yevgenypats

plugins/source.go

@@ -70,7 +70,6 @@ func addInternalColumns(tables []*schema.Table) {
 		cqId := schema.CqIdColumn
 		if len(table.PrimaryKeys()) == 0 {
 			cqId.CreationOptions.PrimaryKey = true
-			cqId.CreationOptions.Unique = false
 		}
 		table.Columns = append(table.Columns, cqId, schema.CqFetchTime)
 		addInternalColumns(table.Relations)

schema/column.go

@@ -37,8 +37,6 @@ type ColumnResolver func(ctx context.Context, meta ClientMeta, resource *Resourc
 // ColumnCreationOptions allow modification of how column is defined when table is created
 type ColumnCreationOptions struct {
 	PrimaryKey bool `json:"primary_key,omitempty"`
-	Unique     bool `json:"unique,omitempty"`
-	NotNull    bool `json:"notnull,omitempty"`
 }
 
 // Column definition for Table

schema/meta.go

@@ -17,7 +17,7 @@ type Meta struct {
 
 const FetchIdMetaKey = "cq_fetch_id"
 
-var CqIdColumn = Column{Name: "_cq_id", Type: TypeUUID, Description: "Internal CQ ID of the row", CreationOptions: ColumnCreationOptions{Unique: true}, Resolver: CQUUIDResolver()}
+var CqIdColumn = Column{Name: "_cq_id", Type: TypeUUID, Description: "Internal CQ ID of the row", Resolver: CQUUIDResolver()}
 var CqFetchTime = Column{Name: "_cq_fetch_time", Type: TypeTimestamp, Description: "Internal CQ row of when fetch was started (this will be the same for all rows in a single fetch)"}
 
 var CqColumns = []Column{