Skip to content
Snippets Groups Projects
Unverified Commit b82fb5c4 authored by Cam Saul's avatar Cam Saul
Browse files

Test fixes :wrench: [ci drivers]

parent 26fe0465
No related branches found
No related tags found
No related merge requests found
...@@ -25,6 +25,7 @@ ...@@ -25,6 +25,7 @@
[metabase.query_processor.interface AgFieldRef BinnedField DateTimeField DateTimeValue Expression [metabase.query_processor.interface AgFieldRef BinnedField DateTimeField DateTimeValue Expression
ExpressionRef Field FieldLiteral JoinQuery JoinTable RelativeDateTimeValue TimeField TimeValue Value])) ExpressionRef Field FieldLiteral JoinQuery JoinTable RelativeDateTimeValue TimeField TimeValue Value]))
;; TODO - yet another `*query*` dynamic var. We should really consolidate them all so we only need a single one.
(def ^:dynamic *query* (def ^:dynamic *query*
"The outer query currently being processed." "The outer query currently being processed."
nil) nil)
...@@ -288,7 +289,8 @@ ...@@ -288,7 +289,8 @@
(let [source-table-id (mbql.u/query->source-table-id *query*) (let [source-table-id (mbql.u/query->source-table-id *query*)
{source-table-name :name, source-schema :schema} (qp.store/table source-table-id)] {source-table-name :name, source-schema :schema} (qp.store/table source-table-id)]
[[table-or-query-expr (keyword join-alias)] [[table-or-query-expr (keyword join-alias)]
[:= (hx/qualify-and-escape-dots source-schema source-table-name (:field-name source-field)) [:=
(hx/qualify-and-escape-dots source-schema source-table-name (:field-name source-field))
(hx/qualify-and-escape-dots join-alias (:field-name pk-field))]])) (hx/qualify-and-escape-dots join-alias (:field-name pk-field))]]))
(defmethod ->honeysql [Object JoinTable] (defmethod ->honeysql [Object JoinTable]
......
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
[generic-sql :as sql] [generic-sql :as sql]
[hive-like :as hive-like]] [hive-like :as hive-like]]
[metabase.driver.generic-sql.query-processor :as sqlqp] [metabase.driver.generic-sql.query-processor :as sqlqp]
[metabase.models.table :refer [Table]] [metabase.mbql.util :as mbql.u]
[metabase.query-processor [metabase.query-processor
[store :as qp.store] [store :as qp.store]
[util :as qputil]] [util :as qputil]]
...@@ -36,13 +36,8 @@ ...@@ -36,13 +36,8 @@
(def ^:private source-table-alias "t1") (def ^:private source-table-alias "t1")
(defn- find-source-table [query]
(first (qputil/postwalk-collect #(instance? (type Table) %)
identity
query)))
(defn- resolve-table-alias [{:keys [schema-name table-name special-type field-name] :as field}] (defn- resolve-table-alias [{:keys [schema-name table-name special-type field-name] :as field}]
(let [source-table (find-source-table sqlqp/*query*)] (let [source-table (qp.store/table (mbql.u/query->source-table-id sqlqp/*query*))]
(if (and (= schema-name (:schema source-table)) (if (and (= schema-name (:schema source-table))
(= table-name (:name source-table))) (= table-name (:name source-table)))
(-> (assoc field :schema-name nil) (-> (assoc field :schema-name nil)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment