Function writeTable

backend/plugin/schema/pg/get_database_definition.go:1712–1845

(out io.Writer, schema string, table *storepb.TableMetadata, sequences []*storepb.SequenceMetadata)

}

func writeTable(out io.Writer, schema string, table *storepb.TableMetadata, sequences []*storepb.SequenceMetadata) error {
	if tableMissingColumnMetadata(table) {
		// Emit a bare CREATE TABLE so the table still exists on replay, and
		// skip constraints, indexes, partitions, and sequence ownership —
		// they all reference columns absent from the dump.
		if err := writeCreateTable(out, schema, table.Name, nil, nil, nil); err != nil {
			return err
		}
		if _, err := io.WriteString(out, ";\n\n"); err != nil {
			return err
		}
		if len(table.Comment) > 0 {
			return writeTableComment(out, schema, table)
		}
		return nil
	}

	generationTypes, identitySequences, nonIdentitySequences := splitSequencesByIdentityOrNot(table, sequences)

	if err := writeCreateTable(out, schema, table.Name, table.Columns, table.CheckConstraints, table.ExcludeConstraints); err != nil {
		return err
	}

	if len(table.Partitions) > 0 {
		if err := writePartitionClause(out, table.Partitions[0]); err != nil {
			return err
		}
	}

	if _, err := io.WriteString(out, ";\n\n"); err != nil {
		return err
	}

	// Skip OWNED BY for a table with no columns; the clause would reference
	// a column absent from the dump.
	if !tableHasNoColumns(table) {
		for _, sequence := range nonIdentitySequences {
			if err := writeAlterSequenceOwnedBy(out, schema, sequence); err != nil {
				return err
			}
		}
	}

	// Construct comments.
	if len(table.Comment) > 0 {
		if err := writeTableComment(out, schema, table); err != nil {
			return err
		}
	}

	for _, column := range table.Columns {
		if len(column.Comment) > 0 {
			if err := writeColumnComment(out, schema, table.Name, column); err != nil {
				return err
			}
		}
	}