first commit

Author: sangeethailango

.formatter.exs

@@ -0,0 +1,4 @@
+# Used by "mix format"
+[
+  inputs: ["{mix,.formatter}.exs", "{config,lib,test}/**/*.{ex,exs}"]
+]

.gitignore

@@ -0,0 +1,26 @@
+# The directory Mix will write compiled artifacts to.
+/_build/
+
+# If you run "mix test --cover", coverage assets end up here.
+/cover/
+
+# The directory Mix downloads your dependencies sources to.
+/deps/
+
+# Where third-party dependencies like ExDoc output generated docs.
+/doc/
+
+# Ignore .fetch files in case you like to edit your project deps locally.
+/.fetch
+
+# If the VM crashes, it generates a dump, let's ignore it too.
+erl_crash.dump
+
+# Also ignore archive artifacts (built via "mix archive.build").
+*.ez
+
+# Ignore package tarball (built via "mix hex.build").
+sql_ecto-*.tar
+
+# Temporary files, for example, from tests.
+/tmp/

README.md

@@ -0,0 +1,21 @@
+# SqlEcto
+
+**TODO: Add description**
+
+## Installation
+
+If [available in Hex](https://hex.pm/docs/publish), the package can be installed
+by adding `sql_ecto` to your list of dependencies in `mix.exs`:
+
+```elixir
+def deps do
+  [
+    {:sql_ecto, "~> 0.1.0"}
+  ]
+end
+```
+
+Documentation can be generated with [ExDoc](https://github.com/elixir-lang/ex_doc)
+and published on [HexDocs](https://hexdocs.pm). Once published, the docs can
+be found at <https://hexdocs.pm/sql_ecto>.
+

config/config.exs

@@ -0,0 +1,11 @@
+import Config
+
+config :sql_ecto, SqlEcto.Repo,
+  database: "sql_ecto_repo",
+  username: "sangeetha",
+  password: "postgres",
+  hostname: "localhost"
+
+
+config :sql_ecto,
+  ecto_repos: [SqlEcto.Repo]

lib/sql_ecto.ex

@@ -0,0 +1,18 @@
+defmodule SqlEcto do
+  @moduledoc """
+  Documentation for `SqlEcto`.
+  """
+
+  @doc """
+  Hello world.
+
+  ## Examples
+
+      iex> SqlEcto.hello()
+      :world
+
+  """
+  def hello do
+    :world
+  end
+end

lib/sql_ecto/application.ex

@@ -0,0 +1,19 @@
+defmodule SqlEcto.Application do
+  # See https://hexdocs.pm/elixir/Application.html
+  # for more information on OTP Applications
+  @moduledoc false
+
+  use Application
+
+  @impl true
+  def start(_type, _args) do
+    children = [
+      SqlEcto.Repo,
+    ]
+
+    # See https://hexdocs.pm/elixir/Supervisor.html
+    # for other strategies and supported options
+    opts = [strategy: :one_for_one, name: SqlEcto.Supervisor]
+    Supervisor.start_link(children, opts)
+  end
+end

lib/sql_ecto/database/create_hr_database.sql

@@ -0,0 +1,60 @@
+CREATE TABLE regions (
+	region_id SERIAL PRIMARY KEY,
+	region_name CHARACTER VARYING (25)
+);
+
+CREATE TABLE countries (
+	country_id CHARACTER (2) PRIMARY KEY,
+	country_name CHARACTER VARYING (40),
+	region_id INTEGER NOT NULL,
+	FOREIGN KEY (region_id) REFERENCES regions (region_id) ON UPDATE CASCADE ON DELETE CASCADE
+);
+
+CREATE TABLE locations (
+	location_id SERIAL PRIMARY KEY,
+	street_address CHARACTER VARYING (40),
+	postal_code CHARACTER VARYING (12),
+	city CHARACTER VARYING (30) NOT NULL,
+	state_province CHARACTER VARYING (25),
+	country_id CHARACTER (2) NOT NULL,
+	FOREIGN KEY (country_id) REFERENCES countries (country_id) ON UPDATE CASCADE ON DELETE CASCADE
+);
+
+CREATE TABLE departments (
+	department_id SERIAL PRIMARY KEY,
+	department_name CHARACTER VARYING (30) NOT NULL,
+	location_id INTEGER,
+	FOREIGN KEY (location_id) REFERENCES locations (location_id) ON UPDATE CASCADE ON DELETE CASCADE
+);
+
+CREATE TABLE jobs (
+	job_id SERIAL PRIMARY KEY,
+	job_title CHARACTER VARYING (35) NOT NULL,
+	min_salary NUMERIC (8, 2),
+	max_salary NUMERIC (8, 2)
+);
+
+CREATE TABLE employees (
+	employee_id SERIAL PRIMARY KEY,
+	first_name CHARACTER VARYING (20),
+	last_name CHARACTER VARYING (25) NOT NULL,
+	email CHARACTER VARYING (100) NOT NULL,
+	phone_number CHARACTER VARYING (20),
+	hire_date DATE NOT NULL,
+	job_id INTEGER NOT NULL,
+	salary NUMERIC (8, 2) NOT NULL,
+	manager_id INTEGER,
+	department_id INTEGER,
+	FOREIGN KEY (job_id) REFERENCES jobs (job_id) ON UPDATE CASCADE ON DELETE CASCADE,
+	FOREIGN KEY (department_id) REFERENCES departments (department_id) ON UPDATE CASCADE ON DELETE CASCADE,
+	FOREIGN KEY (manager_id) REFERENCES employees (employee_id) ON UPDATE CASCADE ON DELETE CASCADE
+);
+
+CREATE TABLE dependents (
+	dependent_id SERIAL PRIMARY KEY,
+	first_name CHARACTER VARYING (50) NOT NULL,
+	last_name CHARACTER VARYING (50) NOT NULL,
+	relationship CHARACTER VARYING (25) NOT NULL,
+	employee_id INTEGER NOT NULL,
+	FOREIGN KEY (employee_id) REFERENCES employees (employee_id) ON DELETE CASCADE ON UPDATE CASCADE
+);

lib/sql_ecto/database/insert_into_hr_database.sql

@@ -0,0 +1,21 @@
+defmodule SqlEcto.Hr.Country do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:country_id, :string, []}
+
+  schema "countries" do
+
+    field :country_name, :string
+    field :region_id, :integer
+
+  end
+
+  def changeset(countries, _params) do
+    countries
+    |> validate_required(:region_id)
+    |> validate_length(:country_id, max: 2)
+    |> validate_length(:country_name, max: 40)
+
+  end
+end

lib/sql_ecto/hr/country.ex

@@ -0,0 +1,19 @@
+defmodule SqlEcto.Hr.Department do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:department_id, :integer, []}
+
+  schema "departments" do
+
+    field :department_name, :string
+    field :location_id, :integer
+
+  end
+
+  def changeset(departments, _params) do
+    departments
+    |> validate_required(:department_name)
+    |> validate_length(:department_name, max: 30)
+  end
+end

lib/sql_ecto/hr/department.ex

@@ -0,0 +1,26 @@
+defmodule SqlEcto.Hr.Dependent do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:dependent_id, :integer, []}
+
+  schema "dependents" do
+
+    field :first_name, :string
+    field :last_name, :string
+    field :relationship, :string
+    field :employee_id, :integer
+
+  end
+
+  def changeset(dependents, _params) do
+    dependents
+    |> validate_required(:first_name)
+    |> validate_required(:last_name)
+    |> validate_required(:relationship)
+    |> validate_required(:employee_id)
+    |> validate_length(:first_name, max: 50)
+    |> validate_length(:last_name, max: 50)
+    |> validate_length(:relationship, max: 25)
+  end
+end

lib/sql_ecto/hr/dependent.ex

@@ -0,0 +1,37 @@
+defmodule SqlEcto.Hr.Employee do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:employee_id, :integer, []}
+
+  schema "employees" do
+
+    field :first_name, :string
+    field :last_name, :string
+    field :email, :string
+    field :phone_number, :string
+    field :hire_date, :date
+    field :salary, :decimal
+    field :manager_id, :integer
+    field :job_id, :integer
+    field :department_id, :integer
+
+  end
+
+  def changeset(employees, _params) do
+    employees
+    |> validate_required(:last_name)
+    |> validate_required(:email)
+    |> validate_required(:phone_number)
+    |> validate_required(:hire_date)
+    |> validate_required(:job_id)
+    |> validate_required(:salary)
+    |> validate_inclusion(:salary, [8, 2])
+    |> validate_length(:first_name, max: 20)
+    |> validate_length(:last_name, max: 25)
+    |> validate_length(:email, max: 100)
+    |> validate_length(:phone_number, max: 20)
+    |> validate_length(:job_title, max: 35)
+    |> validate_length(:job_title, max: 35)
+  end
+end

lib/sql_ecto/hr/employee.ex

@@ -0,0 +1,21 @@
+defmodule SqlEcto.Hr.Job do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:job_id, :integer, []}
+
+  schema "jobs" do
+
+    field :job_title, :string
+    field :min_salary, :decimal
+    field :max_salary, :decimal
+
+  end
+
+  def changeset(jobs, _params) do
+    jobs
+    |> validate_required(:job_title)
+    |> validate_inclusion(:min_salary, [8, 2])
+    |> validate_length(:job_title, max: 35)
+  end
+end

lib/sql_ecto/hr/job.ex

@@ -0,0 +1,27 @@
+defmodule SqlEcto.Hr.Location do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:location_id, :integer, []}
+
+  schema "locations" do
+
+    field :street_address, :string
+    field :postal_code, :string
+    field :city, :string
+    field :state_province, :string
+    field :country_id, :string
+
+  end
+
+  def changeset(locations, _params) do
+    locations
+    |> validate_required(:city)
+    |> validate_required(:country_id)
+    |> validate_length(:street_address, max: 40)
+    |> validate_length(:postal_code, max: 12)
+    |> validate_length(:city, max: 30)
+    |> validate_length(:state_province, max: 25)
+    |> validate_length(:country_id, max: 2)
+  end
+end

lib/sql_ecto/hr/location.ex

@@ -0,0 +1,17 @@
+defmodule SqlEcto.Hr.Region do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:region_id, :integer, []}
+
+  schema "regions" do
+
+    field :region_name, :string
+
+  end
+
+  def changeset(regions, _params) do
+    regions
+    |> validate_length(:region_name, max: 25)
+  end
+end

lib/sql_ecto/hr/region.ex

@@ -0,0 +1,5 @@
+defmodule SqlEcto.Repo do
+  use Ecto.Repo,
+    otp_app: :sql_ecto,
+    adapter: Ecto.Adapters.Postgres
+end

lib/sql_ecto/repo.ex

@@ -0,0 +1,29 @@
+defmodule SqlEcto.MixProject do
+  use Mix.Project
+
+  def project do
+    [
+      app: :sql_ecto,
+      version: "0.1.0",
+      elixir: "~> 1.14",
+      start_permanent: Mix.env() == :prod,
+      deps: deps()
+    ]
+  end
+
+  # Run "mix help compile.app" to learn about applications.
+  def application do
+    [
+      extra_applications: [:logger],
+      mod: {SqlEcto.Application, []}
+    ]
+  end
+
+  # Run "mix help deps" to learn about dependencies.
+   defp deps do
+    [
+      {:ecto_sql, "~> 3.0"},
+      {:postgrex, ">= 0.0.0"}
+    ]
+  end
+end

mix.exs

@@ -0,0 +1,8 @@
+%{
+  "db_connection": {:hex, :db_connection, "2.6.0", "77d835c472b5b67fc4f29556dee74bf511bbafecdcaf98c27d27fa5918152086", [:mix], [{:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "c2f992d15725e721ec7fbc1189d4ecdb8afef76648c746a8e1cad35e3b8a35f3"},
+  "decimal": {:hex, :decimal, "2.1.1", "5611dca5d4b2c3dd497dec8f68751f1f1a54755e8ed2a966c2633cf885973ad6", [:mix], [], "hexpm", "53cfe5f497ed0e7771ae1a475575603d77425099ba5faef9394932b35020ffcc"},
+  "ecto": {:hex, :ecto, "3.10.3", "eb2ae2eecd210b4eb8bece1217b297ad4ff824b4384c0e3fdd28aaf96edd6135", [:mix], [{:decimal, "~> 1.6 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "44bec74e2364d491d70f7e42cd0d690922659d329f6465e89feb8a34e8cd3433"},
+  "ecto_sql": {:hex, :ecto_sql, "3.10.2", "6b98b46534b5c2f8b8b5f03f126e75e2a73c64f3c071149d32987a5378b0fdbd", [:mix], [{:db_connection, "~> 2.4.1 or ~> 2.5", [hex: :db_connection, repo: "hexpm", optional: false]}, {:ecto, "~> 3.10.0", [hex: :ecto, repo: "hexpm", optional: false]}, {:myxql, "~> 0.6.0", [hex: :myxql, repo: "hexpm", optional: true]}, {:postgrex, "~> 0.16.0 or ~> 0.17.0 or ~> 1.0", [hex: :postgrex, repo: "hexpm", optional: true]}, {:tds, "~> 2.1.1 or ~> 2.2", [hex: :tds, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.0 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "68c018debca57cb9235e3889affdaec7a10616a4e3a80c99fa1d01fdafaa9007"},
+  "postgrex": {:hex, :postgrex, "0.17.3", "c92cda8de2033a7585dae8c61b1d420a1a1322421df84da9a82a6764580c503d", [:mix], [{:db_connection, "~> 2.1", [hex: :db_connection, repo: "hexpm", optional: false]}, {:decimal, "~> 1.5 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: false]}, {:jason, "~> 1.0", [hex: :jason, repo: "hexpm", optional: true]}, {:table, "~> 0.1.0", [hex: :table, repo: "hexpm", optional: true]}], "hexpm", "946cf46935a4fdca7a81448be76ba3503cff082df42c6ec1ff16a4bdfbfb098d"},
+  "telemetry": {:hex, :telemetry, "1.2.1", "68fdfe8d8f05a8428483a97d7aab2f268aaff24b49e0f599faa091f1d4e7f61c", [:rebar3], [], "hexpm", "dad9ce9d8effc621708f99eac538ef1cbe05d6a874dd741de2e689c47feafed5"},
+}

mix.lock

@@ -0,0 +1,8 @@
+defmodule SqlEctoTest do
+  use ExUnit.Case
+  doctest SqlEcto
+
+  test "greets the world" do
+    assert SqlEcto.hello() == :world
+  end
+end

test/sql_ecto_test.exs

@@ -0,0 +1 @@
+ExUnit.start()