Function getPrimaryKeyStruct

delta/controller.go:628–641

Helper function to get the primary key. For composite primary keys, `row()` is used.

(schema sql.Schema)

// Helper function to get the primary key. For composite primary keys, `row()` is used.
func getPrimaryKeyStruct(schema sql.Schema) string {
	pks := make([]string, 0, 1)
	for _, col := range schema {
		if col.PrimaryKey {
			pks = append(pks, catalog.QuoteIdentifierANSI(col.Name))
		}
	}
	if len(pks) == 0 {
		return ""
	} else if len(pks) == 1 {
		return pks[0]
	}
	return "row(" + strings.Join(pks, ", ") + ")"
}

// Helper function to get the primary key list.
func getPrimaryKeyList(schema sql.Schema) string {