Method parseConstraint

database/postgres/parser.go:1017–1066

(constraint *pgquery.Constraint, tableName parser.TableName)

}

func (p PostgresParser) parseConstraint(constraint *pgquery.Constraint, tableName parser.TableName) (parser.Statement, error) {
	switch constraint.Contype {
	case pgquery.ConstrType_CONSTR_UNIQUE:
		cols := util.TransformSlice(constraint.Keys, func(key *pgquery.Node) parser.IndexColumn {
			return parser.IndexColumn{
				Column:    parser.NewIdent(key.Node.(*pgquery.Node_String_).String_.Sval, false),
				Direction: "asc",
			}
		})
		return &parser.DDL{
			Action:  parser.AddIndex,
			Table:   tableName,
			NewName: tableName,
			IndexSpec: &parser.IndexSpec{
				Name:       parser.NewIdent(constraint.Conname, false),
				Constraint: true,
				Unique:     true,
				ConstraintOptions: &parser.ConstraintOptions{
					Deferrable:        constraint.Deferrable,
					InitiallyDeferred: constraint.Initdeferred,
				},
			},
			IndexCols: cols,
		}, nil
	case pgquery.ConstrType_CONSTR_FOREIGN:
		fk, err := p.parseForeignKey(constraint)
		if err != nil {
			return nil, err
		}
		return &parser.DDL{
			Action:     parser.AddForeignKey,
			Table:      tableName,
			NewName:    tableName,
			ForeignKey: fk,
		}, nil
	case pgquery.ConstrType_CONSTR_EXCLUSION:
		ex, err := p.parseExclusion(constraint)
		if err != nil {
			return nil, err
		}
		return &parser.DDL{
			Action:    parser.AddExclusion,
			Table:     tableName,
			NewName:   tableName,
			Exclusion: ex,
		}, nil
	default:
		return nil, fmt.Errorf("unhandled constraint type in parseAlterTableStmt: %d", constraint.Contype)
	}
}

func (p PostgresParser) parseExclusion(constraint *pgquery.Constraint) (*parser.ExclusionDefinition, error) {
	var exs []parser.ExclusionPair