Function getMaterializedViewNames

backend/plugin/db/starrocks/dump.go:357–398

getMaterializedViewNames returns the set of materialized-view names in the database. Doris and StarRocks expose them through different catalogs; the query is best-effort (an unsupported engine/version logs and yields an empty set). StarRocks sync rollups (REFRESH_TYPE='ROLLUP') are excluded — they a

(db *sql.DB, dbName string, dbType storepb.Engine)

// (REFRESH_TYPE='ROLLUP') are excluded — they are rollup indexes on the base table, not
// standalone views.
func getMaterializedViewNames(db *sql.DB, dbName string, dbType storepb.Engine) (map[string]bool, error) {
	names := make(map[string]bool)

	var query string
	switch dbType {
	case storepb.Engine_DORIS:
		query = fmt.Sprintf(`SELECT Name FROM mv_infos("database"="%s")`, dbName)
	case storepb.Engine_STARROCKS:
		// IFNULL guards the bare-string scan below: database/sql errors on a NULL->string scan.
		query = fmt.Sprintf(`SELECT TABLE_NAME, IFNULL(REFRESH_TYPE, '') FROM information_schema.materialized_views WHERE TABLE_SCHEMA = '%s'`, dbName)
	default:
		return names, nil
	}

	rows, err := db.Query(query)
	if err != nil {
		// The catalog may be unavailable on older engine versions; log and continue.
		slog.Debug("failed to query materialized views, might not be supported", slog.String("error", err.Error()))
		return names, nil
	}
	defer rows.Close()

	for rows.Next() {
		var name string
		if dbType == storepb.Engine_STARROCKS {
			var refreshType string
			if err := rows.Scan(&name, &refreshType); err != nil {
				return nil, err
			}
			if isSyncRollup(refreshType) {
				continue
			}
		} else if err := rows.Scan(&name); err != nil {
			return nil, err
		}
		names[name] = true
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return names, nil
}

// markMaterializedViews re-tags rows that are actually materialized views so the dump
// emits SHOW CREATE MATERIALIZED VIEW for them. Doris reports MVs as 'BASE TABLE' and