Method finalizeDatabaseSchema

core/init_multidb.go:203–332

finalizeDatabaseSchema creates schema and compilers for a single database.

(ctx *dbContext)

// finalizeDatabaseSchema creates schema and compilers for a single database.
func (gj *graphjinEngine) finalizeDatabaseSchema(ctx *dbContext) error {
	if ctx.dbinfo == nil {
		return nil
	}

	// Graceful degradation: if no tables were discovered, log a warning
	// and return nil — the watcher will re-check periodically.
	if len(ctx.dbinfo.Tables) == 0 {
		ps := gj.conf.DBSchemaPollDuration
		if ps < 5*time.Second {
			ps = 10 * time.Second
		}
		gj.log.Printf("warning: no tables found in database '%s', rechecking every %s",
			ctx.dbinfo.Name, ps)
		return nil
	}

	// Process table config info (order-by config, etc.) for tables belonging to this database.
	// Also fill in empty Schema fields and handle Oracle lowercase.
	{
		schema := ctx.dbinfo.Schema
		for i, t := range gj.conf.Tables {
			// Only process tables that belong to this database
			if t.Database != "" && t.Database != ctx.name {
				continue
			}
			// Oracle requires lowercase identifiers
			if ctx.dbtype == "oracle" {
				gj.conf.Tables[i].Schema = strings.ToLower(gj.conf.Tables[i].Schema)
				gj.conf.Tables[i].Name = strings.ToLower(gj.conf.Tables[i].Name)
				gj.conf.Tables[i].Table = strings.ToLower(gj.conf.Tables[i].Table)
				t = gj.conf.Tables[i]
			}
			// Fill in empty Schema from dbinfo.Schema
			if t.Schema == "" {
				gj.conf.Tables[i].Schema = schema
				t.Schema = schema
			}
			// Skip aliases
			if t.Table != "" && t.Type == "" {
				continue
			}
			if err := gj.addTableInfo(t); err != nil {
				return err
			}
		}
	}

	// Tag all discovered tables with the owning database name
	for i := range ctx.dbinfo.Tables {
		ctx.dbinfo.Tables[i].Database = ctx.name
	}

	// Ensure conf.Tables has entries for all discovered tables in this database.
	// Without this, groupRootsByDatabase cannot route queries/mutations to
	// non-default databases because it only checks conf.Tables.
	// This runs on both init and Reload(), so dynamic config changes are covered.
	gj.ensureDiscoveredTablesInConfig(ctx)