File size: 2,411 Bytes
3e21b19 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 | defmodule Plausible.ClickhouseSessionV2 do
@moduledoc """
Session schema for when NumericIDs migration is complete
"""
use Ecto.Schema
defmodule BoolUInt8 do
@moduledoc """
Custom type to cast Bool as UInt8
"""
use Ecto.Type
u8 = Ecto.ParameterizedType.init(Ch, type: "UInt8")
@impl true
def type, do: unquote(Macro.escape(u8))
@impl true
def cast(true), do: {:ok, 1}
def cast(false), do: {:ok, 0}
def cast(nil), do: {:ok, 0}
@impl true
def load(1), do: {:ok, true}
def load(0), do: {:ok, false}
@impl true
def dump(true), do: {:ok, 1}
def dump(false), do: {:ok, 0}
def dump(nil), do: {:ok, 0}
end
@primary_key false
schema "sessions_v2" do
field :hostname, :string
field :site_id, Ch, type: "UInt64"
field :user_id, Ch, type: "UInt64"
field :session_id, Ch, type: "UInt64"
field :start, :naive_datetime
field :duration, Ch, type: "UInt32"
field :is_bounce, BoolUInt8
field :entry_page, :string
field :exit_page, :string
field :exit_page_hostname, :string
field :pageviews, Ch, type: "Int32"
field :events, Ch, type: "Int32"
field :sign, Ch, type: "Int8"
field :"entry_meta.key", {:array, :string}
field :"entry_meta.value", {:array, :string}
field :utm_medium, :string
field :utm_source, :string
field :utm_campaign, :string
field :utm_content, :string
field :utm_term, :string
field :referrer, :string
field :referrer_source, :string
field :click_id_param, Ch, type: "LowCardinality(String)"
field :country_code, Ch, type: "LowCardinality(FixedString(2))"
field :subdivision1_code, Ch, type: "LowCardinality(String)"
field :subdivision2_code, Ch, type: "LowCardinality(String)"
field :city_geoname_id, Ch, type: "UInt32"
field :screen_size, Ch, type: "LowCardinality(String)"
field :operating_system, Ch, type: "LowCardinality(String)"
field :operating_system_version, Ch, type: "LowCardinality(String)"
field :browser, Ch, type: "LowCardinality(String)"
field :browser_version, Ch, type: "LowCardinality(String)"
field :timestamp, :naive_datetime
field :transferred_from, :string
field :acquisition_channel, Ch, type: "LowCardinality(String)", writable: :never
end
def random_uint64() do
:crypto.strong_rand_bytes(8) |> :binary.decode_unsigned()
end
end
|