(ns metabase.query-processor.util.persisted-cache (:require [metabase.driver :as driver] [metabase.driver.ddl.interface :as ddl.i] [metabase.driver.sql.util :as sql.u] [metabase.driver.util :as driver.u] [metabase.lib.schema.id :as lib.schema.id] [metabase.lib.schema.metadata :as lib.schema.metadata] [metabase.models.persisted-info :as persisted-info] [metabase.public-settings :as public-settings] [metabase.util.malli :as mu])) | |
Taking a card and a persisted-info record (possibly nil), returns whether the card's query can be substituted for a persisted version. | (mu/defn can-substitute?
[card :- ::lib.schema.metadata/card
persisted-info :- [:maybe ::lib.schema.metadata/persisted-info]]
(and persisted-info
persisted-info/*allow-persisted-substitution*
(:active persisted-info)
(= (:state persisted-info) "persisted")
(:definition persisted-info)
(:query-hash persisted-info)
(= (:query-hash persisted-info) (persisted-info/query-hash (:dataset-query card)))
(= (:definition persisted-info)
(persisted-info/metadata->definition (:result-metadata card)
(:table-name persisted-info))))) |
Returns a native query that selects from the persisted cached table from | (mu/defn persisted-info-native-query
[database-id :- ::lib.schema.id/database
{:keys [table-name] :as _persisted-info} :- ::lib.schema.metadata/persisted-info]
(let [driver (or driver/*driver* (driver.u/database->driver database-id))]
;; select * because we don't actually know the name of the fields when in the actual query. See #28902
(format "select * from %s.%s"
(sql.u/quote-name
driver
:table
(ddl.i/schema-name {:id database-id} (public-settings/site-uuid)))
(sql.u/quote-name
driver
:table
table-name)))) |