Function getAllMaterializedViewDependencies

backend/plugin/db/oracle/sync.go:1058–1095

getAllMaterializedViewDependencies gets all materialized view dependencies for a schema in a single query.

(txn *sql.Tx, schemaName string)

// getAllMaterializedViewDependencies gets all materialized view dependencies for a schema in a single query.
func getAllMaterializedViewDependencies(txn *sql.Tx, schemaName string) (map[db.TableKey][]*storepb.DependencyColumn, error) {
	dependenciesMap := make(map[db.TableKey][]*storepb.DependencyColumn)

	query := fmt.Sprintf(`
		SELECT 
			NAME as mview_name,
			REFERENCED_OWNER as source_schema,
			REFERENCED_NAME as source_table,
			'*' as column_name
		FROM ALL_DEPENDENCIES
		WHERE OWNER = '%s'
			AND TYPE = 'MATERIALIZED VIEW'
			AND REFERENCED_TYPE IN ('TABLE', 'VIEW')
		ORDER BY NAME, REFERENCED_OWNER, REFERENCED_NAME
	`, schemaName)

	rows, err := txn.Query(query)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	for rows.Next() {
		var mviewName string
		dependencyColumn := &storepb.DependencyColumn{}
		if err := rows.Scan(&mviewName, &dependencyColumn.Schema, &dependencyColumn.Table, &dependencyColumn.Column); err != nil {
			return nil, err
		}

		key := db.TableKey{Schema: schemaName, Table: mviewName}
		dependenciesMap[key] = append(dependenciesMap[key], dependencyColumn)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}

	return dependenciesMap, nil
}

// getMaterializedViews gets all materialized views of a database.
func getMaterializedViews(txn *sql.Tx, schemaName string, _ map[db.TableKey][]*storepb.ColumnMetadata) ([]*storepb.MaterializedViewMetadata, error) {