Method withSchema

catalog/table.go:79–97

(ctx *sql.Context)

	t.comment = comment
	return t
}

func (t *Table) withSchema(ctx *sql.Context) error {
	schema, err := getPKSchema(ctx, t.db.catalog, t.db.name, t.name)
	if err != nil {
		return err
	}

	t.schema = schema

	// https://github.com/apecloud/myduckserver/issues/272
	if len(t.schema.PkOrdinals) == 0 && configuration.IsReplicationWithoutIndex() {
		// Pretend that the primary key exists
		for _, idx := range t.comment.Meta.PkOrdinals {
			t.schema.Schema[idx].PrimaryKey = true
		}
		t.schema = sql.NewPrimaryKeySchema(t.schema.Schema, t.comment.Meta.PkOrdinals...)
	}

	return nil
}