An Ecto-inspired DSL for defining Datalog programs.

use ExDatalog.Schema in a module to declare relations, facts, rules, and queries. The module then exposes program/0, materialize/0,1, and query/2 functions.

Example

defmodule FamilyRules do
  use ExDatalog.Schema

  relation :parent do
    field :parent, :atom
    field :child, :atom
  end

  relation :ancestor do
    field :ancestor, :atom
    field :descendant, :atom
  end

  fact parent(:alice, :bob)
  fact parent(:bob, :carol)

  rule ancestor(X, Y) do
    parent(X, Y)
  end

  rule ancestor(X, Z) do
    parent(X, Y)
    ancestor(Y, Z)
  end

  query :descendants_of_alice do
    find Y
    where ancestor(:alice, Y)
  end
end

{:ok, knowledge} = FamilyRules.materialize()
FamilyRules.query(:descendants_of_alice, knowledge)
#=> [:bob, :carol]

Relation DSL

Relations declare named schemas with typed fields:

relation :parent do
  field :parent, :atom
  field :child, :atom
end

Supported field types: :atom, :integer, :string, :any.

Fact DSL

Facts assert ground tuples:

fact parent(:alice, :bob)

Bulk facts:

facts :parent do
  row :alice, :bob
  row :bob, :carol
end

Rule DSL

Rules derive new facts. Uppercase identifiers are logic variables, lowercase atoms and :atoms are constants, and _ is a wildcard:

rule ancestor(X, Y) do
  parent(X, Y)
end

Negation uses not_:

rule bachelor(p) do
  male(p)
  not_ married(p, _)
end

Constraints use named predicates:

rule high_earner(P) do
  income(P, S)
  gt(S, 100_000)
end

Supported constraints: eq, neq, gt, gte, lt, lte, add, sub, mul, div, is_integer, is_binary, is_atom, starts_with, contains, member.

Query DSL

Queries define named post-materialization lookups:

query :all_ancestors do
  find X, Y
  where ancestor(X, Y)
end

Queries operate on materialized knowledge and use Knowledge.match/3 internally.

Aggregate Syntax (Preview)

Aggregates are not yet supported. Using agg(...) in a rule head or body raises ExDatalog.DSL.CompileError at compile time:

rule employee_count(dept, agg(:count, emp)) do
  employee(emp, dept)
end
#=> ** (ExDatalog.DSL.CompileError) aggregates are not yet supported (planned for v0.6.0)

Backward Compatibility

The DSL compiles into the existing Program builder API. All existing builder APIs (Program.add_relation/3, Program.add_fact/3, Program.add_rule/2,3,4, ExDatalog.materialize/2) continue to work.