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"

)