Function CopyDBResources

db/db.go:196–243

CopyDBResources copies resources from input database to output database

(input, output DB, overrideExisting bool)

//CopyDBResources copies resources from input database to output database
func CopyDBResources(input, output DB, overrideExisting bool) error {
	schemaManager := schema.GetManager()
	schemas := schemaManager.OrderedSchemas()

	if len(schemas) == 0 {
		return errNoSchemasInManager
	}

	if errInputTx := Within(input, func(inputTx transaction.Transaction) error {
		if errorOutputTx := Within(output, func(outputTx transaction.Transaction) error {
			for _, s := range schemas {
				if s.IsAbstract() {
					continue
				}
				log.Info("Populating resources for schema %s", s.ID)
				resources, _, err := inputTx.List(s, nil, nil, nil)
				if err != nil {
					return err
				}

				for _, resource := range resources {
					log.Info("Creating resource %s", resource.ID())
					destResource, _ := outputTx.Fetch(s, transaction.IDFilter(resource.ID()), nil)
					if destResource == nil {
						resource.PopulateDefaults()
						err := outputTx.Create(resource)
						if err != nil {
							return err
						}
					} else if overrideExisting {
						err := outputTx.Update(resource)
						if err != nil {
							return err
						}
					}
				}
			}
			return nil
		}); errorOutputTx != nil {
			return errorOutputTx
		}
		return nil
	}); errInputTx != nil {
		return errInputTx
	}

	return nil
}

// CreateFromConfig creates db connection from config
func CreateFromConfig(config *util.Config) (DB, error) {