lookup type for aliased schema fields

lib/ecto/adapters/clickhouse/schema.ex

@@ -226,11 +226,23 @@ defmodule Ecto.Adapters.ClickHouse.Schema do
 
   defp extract_types(schema, fields) do
     Enum.map(fields, fn field ->
-      type = schema.__schema__(:type, field) || raise "missing type for field " <> inspect(field)
+      type =
+        schema.__schema__(:type, field) || find_field_source_type(schema, field) ||
+          raise "missing type for field " <> inspect(field)
+
       type |> Ecto.Type.type() |> remap_type(type, schema, field)
     end)
   end
 
+  defp find_field_source_type(schema, field) do
+    reverse_field_source =
+      Enum.find(schema.__schema__(:fields), &(schema.__schema__(:field_source, &1) == field))
+
+    if reverse_field_source do
+      schema.__schema__(:type, reverse_field_source)
+    end
+  end
+
   defp prepare_types(schema, header, opts) do
     cond do
       schema ->

test/support/ecto_schemas.exs

@@ -194,9 +194,7 @@ defmodule Ecto.Integration.Permalink do
   use Ecto.Integration.Schema
 
   schema "permalinks" do
-    # TODO support aliased fields
-    # field :url, :string, source: :uniform_resource_locator
-    field :url, :string, default: ""
+    field :url, :string, source: :uniform_resource_locator, default: ""
     field :title, :string, default: ""
     field :posted, :date, virtual: true
 

test/support/migrations.ex

@@ -50,8 +50,7 @@ defmodule EctoClickHouse.Integration.Migration do
 
     create table(:permalinks, primary_key: false, engine: "MergeTree") do
       add :id, :UInt64, primary_key: true
-      # add :uniform_resource_locator, :string
-      add :url, :string
+      add :uniform_resource_locator, :string
       add :title, :string
       add :post_id, :UInt64
       add :user_id, :UInt64