Add sushi dbt project (#4)

Co-authored-by: Chris Rericha <67359577+crericha@users.noreply.github.com>

Author: izeigerman

tests/projects/sushi_dbt/.gitignore

@@ -0,0 +1,4 @@
+
+target/
+dbt_packages/
+logs/

tests/projects/sushi_dbt/README.md

@@ -0,0 +1,15 @@
+Welcome to your new dbt project!
+
+### Using the starter project
+
+Try running the following commands:
+- dbt run
+- dbt test
+
+
+### Resources:
+- Learn more about dbt [in the docs](https://docs.getdbt.com/docs/introduction)
+- Check out [Discourse](https://discourse.getdbt.com/) for commonly asked questions and answers
+- Join the [chat](https://community.getdbt.com/) on Slack for live discussions and support
+- Find [dbt events](https://events.getdbt.com) near you
+- Check out [the blog](https://blog.getdbt.com/) for the latest news on dbt's development and best practices

tests/projects/sushi_dbt/analyses/.gitkeep

@@ -0,0 +1,29 @@
+
+name: 'sushi'
+version: '1.0.0'
+config-version: 2
+profile: 'sushi'
+
+model-paths: ["models"]
+analysis-paths: ["analyses"]
+test-paths: ["tests"]
+seed-paths: ["seeds"]
+macro-paths: ["macros"]
+snapshot-paths: ["snapshots"]
+
+target-path: "target"  # directory which will store compiled SQL files
+clean-targets:         # directories to be removed by `dbt clean`
+  - "target"
+  - "dbt_packages"
+
+# Configuring models
+# Full documentation: https://docs.getdbt.com/docs/configuring-models
+
+models:
+  sushi:
+    cleansed:
+      +schema: cleansed
+      +materialized: table
+    db:
+      +schema: db
+      +materialized: table

tests/projects/sushi_dbt/dbt_project.yml

@@ -0,0 +1,3 @@
+SELECT DISTINCT
+  customer_id::INT AS customer_id
+FROM {{ source('raw', 'orders') }}

tests/projects/sushi_dbt/macros/.gitkeep

@@ -0,0 +1,19 @@
+{{
+    config(
+        materialized='incremental',
+        incremental_strategy='delete+insert',
+        cluster_by=['ds'],
+        unique_key=['ds'],
+    )
+}}
+
+SELECT
+  id::DOUBLE AS id, /* Primary key */
+  name::TEXT AS name, /* Name of the sushi */
+  price::DOUBLE AS price, /* Price of the sushi */
+  ds::TEXT AS ds /* Date */
+FROM {{ source('raw', 'items') }}
+{% if is_incremental() %}
+WHERE
+  ds > (select max(ds) from {{ this }})
+{% endif %}

tests/projects/sushi_dbt/models/cleansed/customers.sql

@@ -0,0 +1,20 @@
+{{
+    config(
+        materialized='incremental',
+        incremental_strategy='delete+insert',
+        cluster_by=['ds'],
+        unique_key=['ds']
+    )
+}}
+
+SELECT
+  id::INT AS id, /* Primary key */
+  order_id::INT AS order_id, /* Order id */
+  item_id::INT AS item_id, /* Item id */
+  quantity::INT AS quantity, /* Quantity of items ordered */
+  ds::TEXT AS ds /* Date of order */
+FROM {{ source('raw', 'order_items') }}
+{% if is_incremental() %}
+WHERE
+  ds > (select max(ds) from {{ this }})
+{% endif %}

tests/projects/sushi_dbt/models/cleansed/items.sql

@@ -0,0 +1,21 @@
+{{
+    config(
+        materialized='incremental',
+        incremental_strategy='delete+insert',
+        cluster_by=['ds'],
+        unique_key=['ds']
+    )
+}}
+
+SELECT
+  id::INT AS id, /* Primary key */
+  customer_id::INT AS customer_id, /* Id of customer who made the order */
+  waiter_id::INT AS waiter_id, /* Id of waiter who took the order */
+  start_ts::TEXT AS start_ts, /* Start timestamp */
+  end_ts::TEXT AS end_ts, /* End timestamp */
+  ds::TEXT AS ds /* Date of order */
+FROM {{ source('raw', 'orders') }}
+{% if is_incremental() %}
+WHERE
+  ds > (select max(ds) from {{ this }})
+{% endif %}

tests/projects/sushi_dbt/models/cleansed/order_items.sql

@@ -0,0 +1,14 @@
+version: 2
+
+models:
+  - name: items
+  - name: orders
+  - name: order_items
+  - name: customers
+  - name: waiters
+sources:
+  - name: raw
+    tables:
+      - name: items
+      - name: orders
+      - name: order_items