Function parseGeneratorConfigFromBytes

database/database.go:357–429

(buf []byte, defaults GeneratorConfig)

}

func parseGeneratorConfigFromBytes(buf []byte, defaults GeneratorConfig) GeneratorConfig {
	var config struct {
		TargetTables            string   `yaml:"target_tables"`
		SkipTables              string   `yaml:"skip_tables"`
		SkipViews               string   `yaml:"skip_views"`
		TargetSchema            string   `yaml:"target_schema"`
		Algorithm               string   `yaml:"algorithm"`
		Lock                    string   `yaml:"lock"`
		DumpConcurrency         int      `yaml:"dump_concurrency"`
		ManagedRoles            []string `yaml:"managed_roles"`
		EnableDrop              bool     `yaml:"enable_drop"`
		CreateIndexConcurrently bool     `yaml:"create_index_concurrently"`
		DisableDdlTransaction   bool     `yaml:"disable_ddl_transaction"`
		LegacyIgnoreQuotes      *bool    `yaml:"legacy_ignore_quotes"`
	}

	dec := yaml.NewDecoder(bytes.NewReader(buf), yaml.DisallowUnknownField())
	err := dec.Decode(&config)
	if err != nil {
		log.Fatal(err)
	}

	var targetTables []string
	if config.TargetTables != "" {
		targetTables = strings.Split(strings.Trim(config.TargetTables, "\n"), "\n")
	}

	var skipTables []string
	if config.SkipTables != "" {
		skipTables = strings.Split(strings.Trim(config.SkipTables, "\n"), "\n")
	}

	var skipViews []string
	if config.SkipViews != "" {
		skipViews = strings.Split(strings.Trim(config.SkipViews, "\n"), "\n")
	}

	var targetSchema []string
	if config.TargetSchema != "" {
		targetSchema = strings.Split(strings.Trim(config.TargetSchema, "\n"), "\n")
	}

	var algorithm string
	if config.Algorithm != "" {
		algorithm = strings.Trim(config.Algorithm, "\n")
	}

	var lock string
	if config.Lock != "" {
		lock = strings.Trim(config.Lock, "\n")
	}

	// Use the provided default, override if explicitly set in config
	legacyIgnoreQuotes := defaults.LegacyIgnoreQuotes
	if config.LegacyIgnoreQuotes != nil {
		legacyIgnoreQuotes = *config.LegacyIgnoreQuotes
	}