Method newGraphJinReloadingDatabase

core/api.go:1225–1353

(base *graphjinEngine, database string)

}

func (g *GraphJin) newGraphJinReloadingDatabase(base *graphjinEngine, database string) error {
	if base == nil {
		return errors.New("graphjin engine is not initialized")
	}
	conf := base.conf.clone()
	if conf.IsSourcesUsed() {
		for i := range conf.Tables {
			if conf.Tables[i].Source == "" && conf.Tables[i].Database != "" {
				conf.Tables[i].Source = conf.Tables[i].Database
			}
		}
	}
	if err := conf.NormalizeMode(); err != nil {
		return err
	}

	log := base.log
	if log == nil {
		log = _log.New(os.Stderr, "", 0)
	}
	trace := base.trace
	if trace == nil {
		trace = &tracer{}
	}
	printFormat := append([]byte(nil), base.printFormat...)
	if len(printFormat) == 0 {
		printFormat = []byte(fmt.Sprintf("gj-%x:", time.Now().UnixNano()))
	}

	gj := &graphjinEngine{
		conf:        conf,
		log:         log,
		prod:        conf.Production,
		prodSec:     conf.Production,
		printFormat: printFormat,
		opts:        base.opts,
		fs:          base.fs,
		trace:       trace,
		namespace:   base.namespace,
		done:        g.done,
	}
	if gj.conf.DisableProdSecurity {
		gj.prodSec = false
	}
	if err := gj.initCache(); err != nil {
		return err
	}
	if err := gj.initConfig(); err != nil {
		return err
	}
	gj.defaultDB = base.defaultDB
	if gj.defaultDB == "" {
		names := make([]string, 0, len(gj.conf.Databases))
		for name := range gj.conf.Databases {
			names = append(names, name)
		}
		sort.Strings(names)
		if len(names) != 0 {