number the inputs to keep order, use Stream, add a control test

Stream removes some of the overhead jitter of Enum, and having a
control test helps one understand what the overhead of the test itself
is versus what sort of time is being spent in EctoSQL modules

Author: aseigo

bench/scripts/micro/load_bench.exs

@@ -22,25 +22,26 @@ Code.require_file("../../support/setup.exs", __DIR__)
 alias Ecto.Bench.User
 
 inputs = %{
-  "Small 1 Thousand" =>
-    1..1_000 |> Enum.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
-  "Medium 100 Thousand" =>
-    1..100_000 |> Enum.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
-  "Big 1 Million" =>
-    1..1_000_000 |> Enum.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
-  "Time attr" =>
-    1..100_000 |> Enum.map(fn _ -> %{name: "Alice", time_attr: ~T[21:25:04.361140]} end),
-  "Date attr" => 1..100_000 |> Enum.map(fn _ -> %{name: "Alice", date_attr: ~D[2018-06-20]} end),
-  "NaiveDateTime attr" =>
+  "1. Small 1 Thousand" =>
+    1..1_000 |> Stream.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
+  "2. Medium 100 Thousand" =>
+    1..100_000 |> Stream.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
+  "3. Big 1 Million" =>
+    1..1_000_000 |> Stream.map(fn _ -> %{name: "Alice", email: "email@email.com"} end),
+  "4. Time attr" =>
+    1..100_000 |> Stream.map(fn _ -> %{name: "Alice", time_attr: ~T[21:25:04.361140]} end),
+  "5. Date attr" => 1..100_000 |> Stream.map(fn _ -> %{name: "Alice", date_attr: ~D[2018-06-20]} end),
+  "6. NaiveDateTime attr" =>
     1..100_000
-    |> Enum.map(fn _ -> %{name: "Alice", naive_datetime_attr: ~N[2019-06-20 21:32:07.424178]} end),
-  "UUID attr" =>
+    |> Stream.map(fn _ -> %{name: "Alice", naive_datetime_attr: ~N[2019-06-20 21:32:07.424178]} end),
+  "7. UUID attr" =>
     1..100_000
-    |> Enum.map(fn _ -> %{name: "Alice", uuid: Ecto.UUID.bingenerate()} end)
+    |> Stream.map(fn _ -> %{name: "Alice", uuid: Ecto.UUID.bingenerate()} end)
 }
 
 jobs = %{
-  "Pg Loader" => fn data -> Enum.map(data, &Ecto.Bench.PgRepo.load(User, &1)) end,
+  "Control" => fn stream -> stream |> Stream.map(fn _data -> true end) |> Stream.run() end,
+  "Pg Loader" => fn stream -> stream |> Stream.map(&Ecto.Bench.PgRepo.load(User, &1)) |> Stream.run() end,
   "MyXQL Loader" => fn data -> Enum.map(data, &Ecto.Bench.MyXQLRepo.load(User, &1)) end
 }