Method tableNames

database/postgres/database.go:175–215

()

}

func (d *PostgresDatabase) tableNames() ([]string, error) {
	// When SkipPartition is true, exclude partitioned parent tables (relkind='p').
	// Otherwise, include both regular tables ('r') and partitioned parent tables ('p').
	relkindCondition := "c.relkind in ('r', 'p')"
	if d.config.SkipPartition {
		relkindCondition = "c.relkind = 'r'"
	}

	query := fmt.Sprintf(`
		SELECT n.nspname AS table_schema, relname AS table_name FROM pg_catalog.pg_class c
		INNER JOIN pg_catalog.pg_namespace n ON c.relnamespace = n.oid
		WHERE n.nspname NOT IN ('information_schema', 'pg_catalog', 'sys')
		AND %s
		AND c.relpersistence IN ('p', 'u')
		AND c.relispartition = false
		AND NOT EXISTS (SELECT 1 FROM pg_catalog.pg_depend d WHERE c.oid = d.objid AND d.classid = (SELECT oid FROM pg_catalog.pg_class WHERE relname = 'pg_class') AND d.deptype = 'e')
		ORDER BY n.nspname ASC, relname ASC;
	`, relkindCondition)

	rows, err := d.db.Query(query)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	tables := []string{}
	for rows.Next() {
		var schema, name string
		if err := rows.Scan(&schema, &name); err != nil {
			return nil, err
		}
		if d.config.TargetSchema != nil && !slices.Contains(d.config.TargetSchema, schema) {
			continue
		}
		tables = append(tables, schema+"."+name)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return tables, nil
}

// partitionChildTables exports CREATE TABLE ... PARTITION OF statements for partition child tables
func (d *PostgresDatabase) partitionChildTables() ([]string, error) {