|
@@ -176,9 +176,9 @@ fi
|
|
|
run_sql() {
|
|
run_sql() {
|
|
|
local sql="$1"
|
|
local sql="$1"
|
|
|
if [[ "$CLICKHOUSE_EXEC_MODE" == "docker" ]]; then
|
|
if [[ "$CLICKHOUSE_EXEC_MODE" == "docker" ]]; then
|
|
|
- docker exec -i "$CLICKHOUSE_CONTAINER" clickhouse-client "${CH_ARGS[@]}" --query "$sql"
|
|
|
|
|
|
|
+ docker exec "$CLICKHOUSE_CONTAINER" clickhouse-client "${CH_ARGS[@]}" --query "$sql"
|
|
|
else
|
|
else
|
|
|
- clickhouse-client "${CH_ARGS[@]}" --query "$sql"
|
|
|
|
|
|
|
+ clickhouse-client "${CH_ARGS[@]}" --query "$sql" </dev/null
|
|
|
fi
|
|
fi
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -303,7 +303,7 @@ FROM ${DB_NAME}.${SRC_TABLE} AS src
|
|
|
LEFT JOIN ${DB_NAME}.${DST_TABLE} AS dst ON src.log_id = dst.log_id
|
|
LEFT JOIN ${DB_NAME}.${DST_TABLE} AS dst ON src.log_id = dst.log_id
|
|
|
WHERE src.time >= toDateTime('${month_start}')
|
|
WHERE src.time >= toDateTime('${month_start}')
|
|
|
AND src.time < addMonths(toDateTime('${month_start}'), 1)
|
|
AND src.time < addMonths(toDateTime('${month_start}'), 1)
|
|
|
- AND dst.log_id IS NULL
|
|
|
|
|
|
|
+ AND empty(dst.log_id)
|
|
|
EOF
|
|
EOF
|
|
|
}
|
|
}
|
|
|
|
|
|