# Start ClickHouse DB Server
./run.sh init

# Inspect what is inside the DB
./run.sh inspect

# Inspect what is inside the DB on the web
./run.sh web

# Versioned migrations (change-based migrations)
# replace `NAME` with a proper title
./run.sh migrate NAME

# Apply changes (from desired schema)
./run.sh apply

# Start ClickHouse DB Server
./run.sh init

# inspect DB to see the initial state (you should see default table only)
./run.sh inspect

# create test database
echo -e 'CREATE DATABASE `test` ENGINE Atomic;' > schema.sql

# show the difference between desired state and actual DB state
./run.sh diff ch schema.sql

# Create `migrations` directory
mkdir migrations

# schema migration
./run.sh migrate create_test_db

# show the difference between desired state and the latest migrations state
./run.sh diff migrations schema.sql

# apply the changes from the migrations state to the actual DB
./run.sh apply

# show the difference between desired state and the latest migrations state
./run.sh diff ch schema.sql

# inspect DB
./run.sh inspect

# append the creation of the log table
echo "CREATE TABLE \`test\`.\`orders_log\` (  
  \`before.id\` Int64,
  \`before.date\` DateTime,
  \`before.price\` Int64,
  \`before.cancelled\` Bool,
  
  \`after.id\` Int64,
  \`after.date\` DateTime,
  \`after.price\` Int64,
  \`after.cancelled\` Bool,
  
  \`source.lsn\` UInt64,
  op String
) engine = MergeTree order by (\`source.lsn\`);" >> schema.sql

# schema migration
./run.sh migrate create_log_table

# apply the changes from the desired state to the actual DB
./run.sh apply

# append the creation of the cdc table
echo "CREATE TABLE \`test\`.\`orders_cdc\` (
  id Int64,
  date DateTime,
  price Int64,
  cancelled Bool,
  
  version UInt64,
  deleted UInt8
) engine = ReplacingMergeTree(version, deleted) order by (id);" >> schema.sql

# schema migration
./run.sh migrate create_cdc_table

# apply the changes from the desired state to the actual DB
./run.sh apply

# append the creation of the cdc table
echo "CREATE MATERIALIZED VIEW \`test\`.\`mview_orders_cdc\`
TO \`test\`.\`orders_cdc\`
AS SELECT
  if(op = 'd', \`before.id\`, \`after.id\`) AS id,
  if(op = 'd', \`before.date\`, \`after.date\`) AS date,
  if(op = 'd', \`before.price\`, \`after.price\`) AS price,
  if(op = 'd', \`before.cancelled\`, \`after.cancelled\`) AS cancelled,
  
  \`source.lsn\` AS version,
  if(op = 'd', 1, 0) AS deleted
FROM \`test\`.\`orders_log\`
WHERE (op = 'c' or op = 'u' or op = 'd');" >> schema.sql

# schema migration
./run.sh migrate create_mview_cdc

# apply the changes from the desired state to the actual DB
./run.sh apply

./run.sh web

# modify `schema.sql` (e.g. add `before.note` and `after.note` columns to `orders_log`, add `note` column to `orders_cdc`, and update `mview_orders_cdc` to insert `note` correctly and rename it to `mview_orders_cdc_new`)

# schema migration
./run.sh migrate updated_tables_and_mview

# apply the changes from the desired state to the actual DB
./run.sh apply

# rename `mview_orders_cdc_new` to `mview_orders_cdc`

# schema migration
./run.sh migrate rename_mview

# apply the changes from the desired state to the actual DB
./run.sh apply