Method domains

database/postgres/database.go:479–598

()

}

func (d *PostgresDatabase) domains() ([]string, error) {
	rows, err := d.db.Query(`
		SELECT n.nspname AS domain_schema,
		       t.typname AS domain_name,
		       pg_catalog.format_type(t.typbasetype, t.typtypmod) AS data_type,
		       t.typdefault AS default_value,
		       t.typnotnull AS not_null,
		       c.collname AS collation,
		       obj_description(t.oid, 'pg_type') AS domain_comment
		FROM pg_catalog.pg_type t
		INNER JOIN pg_catalog.pg_namespace n ON t.typnamespace = n.oid
		LEFT JOIN pg_catalog.pg_collation c ON t.typcollation = c.oid AND t.typcollation <> 0
		WHERE t.typtype = 'd'
		  AND n.nspname NOT IN ('pg_catalog', 'information_schema', 'pg_toast', 'sys')
		  AND NOT EXISTS (SELECT 1 FROM pg_depend d WHERE d.objid = t.oid AND d.classid = (SELECT oid FROM pg_catalog.pg_class WHERE relname = 'pg_type') AND d.deptype = 'e')
		ORDER BY n.nspname, t.typname;
	`)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	type domainInfo struct {
		schema, name, dataType  string
		defaultValue, collation sql.NullString
		notNull                 bool
		comment                 sql.NullString
	}

	var domains []domainInfo
	for rows.Next() {
		var di domainInfo
		if err := rows.Scan(&di.schema, &di.name, &di.dataType, &di.defaultValue, &di.notNull, &di.collation, &di.comment); err != nil {
			return nil, err
		}
		if d.config.TargetSchema != nil && !slices.Contains(d.config.TargetSchema, di.schema) {
			continue
		}
		domains = append(domains, di)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}

	// Now fetch constraints for domains, applying the same TargetSchema filter
	constraintRows, err := d.db.Query(`
		SELECT n.nspname AS domain_schema,
		       t.typname AS domain_name,
		       con.conname AS constraint_name,
		       pg_catalog.pg_get_constraintdef(con.oid, true) AS constraint_def
		FROM pg_catalog.pg_constraint con
		INNER JOIN pg_catalog.pg_type t ON con.contypid = t.oid
		INNER JOIN pg_catalog.pg_namespace n ON t.typnamespace = n.oid
		WHERE t.typtype = 'd'
		  AND n.nspname NOT IN ('pg_catalog', 'information_schema', 'pg_toast', 'sys')
		ORDER BY n.nspname, t.typname, con.conname;
	`)
	if err != nil {