Exd v0.1.1 Exd.Sink.SQL View Source
A sink that inserts output into a SQL-compatible datastore
Options
:table_name- Name of table in which to store sink results:key_column_name- Name of column in which to store document key:data_column_name- Name of column in which to store document data
Usage
Query.new() |> Query.from(“jobs”, {…}) |> Query.where(“jobs.salary”, :>, 10000) |> Query.into(
Exd.Sink.SQL,
hostname: "localhost",
database: "my-database",
username: "postgres",
password: "postgres",
datakey: "jobs.title"
)