From ac29d06220a465ef708bcb88779f591bbc750253 Mon Sep 17 00:00:00 2001 From: Yam ZhengLim Date: Fri, 31 Mar 2023 11:37:57 +0800 Subject: [PATCH] Exchange add source loaded datetime --- config/EXCHANGE_EXTRACT_SQL.json | 85 ++++++++++++++++---------------- 1 file changed, 43 insertions(+), 42 deletions(-) diff --git a/config/EXCHANGE_EXTRACT_SQL.json b/config/EXCHANGE_EXTRACT_SQL.json index c1be1ba..3cbcd22 100644 --- a/config/EXCHANGE_EXTRACT_SQL.json +++ b/config/EXCHANGE_EXTRACT_SQL.json @@ -1,44 +1,45 @@ { - "activity_log" : "SELECT * FROM activity_log;", - "addresses" : "SELECT * FROM addresses;", - "announcements" : "SELECT * FROM announcements;", - "announcement_segment" : "SELECT * FROM announcement_segment;", - "banks" : "SELECT * FROM banks;", - "bank_logs" : "SELECT * FROM bank_logs;", - "bookings" : "SELECT * FROM bookings;", - "booking_logs" : "SELECT * FROM booking_logs", - "companies" : "SELECT * FROM companies;", - "contacts" : "SELECT * FROM contacts;", - "countries" : "SELECT * FROM countries;", - "currencies" : "SELECT * FROM currencies;", - "currency_logs" : "SELECT * FROM currency_logs;", - "currency_rates" : "SELECT * FROM currency_rates;", - "currency_rate_logs" : "SELECT * FROM currency_rate_logs;", - "districts" : "SELECT * FROM districts;", - "documents" : "SELECT * FROM documents;", - "employees" : "SELECT * FROM employees;", - "failed_jobs" : "SELECT * FROM failed_jobs;", - "files" : "SELECT id, document_id, REPLACE(REPLACE(REPLACE(file, '\n', '
'),'|', '|'),'\\\\','\\') AS 'file', file_type, deleted_at, created_at, updated_at FROM files;", - "groups" : "SELECT * FROM groups;", - "group_transactions" : "SELECT * FROM group_transactions;", - "jobs" : "SELECT * FROM jobs;", - "migrations" : "SELECT * FROM migrations;", - "model_has_roles" : "SELECT * FROM model_has_roles;", - "notifications" : "SELECT * FROM notifications;", - "password_resets" : "SELECT * FROM password_resets;", - "permissions" : "SELECT * FROM permissions;", - "roles" : "SELECT * FROM roles;", - "role_has_permissions" : "SELECT * FROM role_has_permissions;", - "segments" : "SELECT * FROM segments;", - "segment_companies" : "SELECT * FROM segment_companies;", - "segment_constants" : "SELECT * FROM segment_constants;", - "service_types" : "SELECT * FROM service_types;", - "states" : "SELECT * FROM states;", - "transactions" : "SELECT * FROM transactions;", - "transaction_detail" : "SELECT id, transaction_id, REPLACE(REPLACE(REPLACE(product_code, '\n', '
'),'|', '|'),'\\\\','\\') AS product_code, REPLACE(REPLACE(REPLACE(product_name, '\n', '
'),'|', '|'),'\\\\','\\') AS product_name, quantity, price, amount, deleted_at, created_at, updated_at FROM `transaction_detail`;", - "transaction_logs" : "SELECT * FROM transaction_logs", - "users" : "SELECT id, name, email, type, status, remember_token, active_at, deleted_at, created_at, updated_at FROM users;", - "user_email_verifications" : "SELECT * FROM user_email_verifications;", - "wallets" : "SELECT * FROM wallets;", - "wallet_logs" : "SELECT * FROM wallet_logs" + "activity_log" : "SELECT *, now() AS _source_loaded_datetime FROM activity_log;", + "addresses" : "SELECT *, now() AS _source_loaded_datetime FROM addresses;", + "announcements" : "SELECT *, now() AS _source_loaded_datetime FROM announcements;", + "announcement_segment" : "SELECT *, now() AS _source_loaded_datetime FROM announcement_segment;", + "banks" : "SELECT *, now() AS _source_loaded_datetime FROM banks;", + "bank_logs" : "SELECT *, now() AS _source_loaded_datetime FROM bank_logs;", + "bookings" : "SELECT *, now() AS _source_loaded_datetime FROM bookings;", + "booking_logs" : "SELECT *, now() AS _source_loaded_datetime FROM booking_logs", + "companies" : "SELECT *, now() AS _source_loaded_datetime FROM companies;", + "contacts" : "SELECT *, now() AS _source_loaded_datetime FROM contacts;", + "countries" : "SELECT *, now() AS _source_loaded_datetime FROM countries;", + "currencies" : "SELECT *, now() AS _source_loaded_datetime FROM currencies;", + "currency_logs" : "SELECT *, now() AS _source_loaded_datetime FROM currency_logs;", + "currency_rates" : "SELECT *, now() AS _source_loaded_datetime FROM currency_rates;", + "currency_rate_logs" : "SELECT *, now() AS _source_loaded_datetime FROM currency_rate_logs;", + "districts" : "SELECT *, now() AS _source_loaded_datetime FROM districts;", + "documents" : "SELECT *, now() AS _source_loaded_datetime FROM documents;", + "employees" : "SELECT *, now() AS _source_loaded_datetime FROM employees;", + "failed_jobs" : "SELECT *, now() AS _source_loaded_datetime FROM failed_jobs;", + "files" : "SELECT id, document_id, REPLACE(REPLACE(REPLACE(file, '\n', '
'),'|', '|'),'\\\\','\\') AS 'file', file_type, deleted_at, created_at, updated_at, now() AS _source_loaded_datetime FROM files;", + "groups" : "SELECT *, now() AS _source_loaded_datetime FROM groups;", + "group_transactions" : "SELECT *, now() AS _source_loaded_datetime FROM group_transactions;", + "jobs" : "SELECT *, now() AS _source_loaded_datetime FROM jobs;", + "migrations" : "SELECT *, now() AS _source_loaded_datetime FROM migrations;", + "model_has_roles" : "SELECT *, now() AS _source_loaded_datetime FROM model_has_roles;", + "notifications" : "SELECT *, now() AS _source_loaded_datetime FROM notifications;", + "password_resets" : "SELECT *, now() AS _source_loaded_datetime FROM password_resets;", + "permissions" : "SELECT *, now() AS _source_loaded_datetime FROM permissions;", + "roles" : "SELECT *, now() AS _source_loaded_datetime FROM roles;", + "role_has_permissions" : "SELECT *, now() AS _source_loaded_datetime FROM role_has_permissions;", + "seasonal_segment" : "SELECT *, now() AS _source_loaded_datetime FROM seasonal_segment;", + "segments" : "SELECT *, now() AS _source_loaded_datetime FROM segments;", + "segment_companies" : "SELECT *, now() AS _source_loaded_datetime FROM segment_companies;", + "segment_constants" : "SELECT *, now() AS _source_loaded_datetime FROM segment_constants;", + "service_types" : "SELECT *, now() AS _source_loaded_datetime FROM service_types;", + "states" : "SELECT *, now() AS _source_loaded_datetime FROM states;", + "transactions" : "SELECT *, now() AS _source_loaded_datetime FROM transactions;", + "transaction_detail" : "SELECT id, transaction_id, REPLACE(REPLACE(REPLACE(product_code, '\n', '
'),'|', '|'),'\\\\','\\') AS product_code, REPLACE(REPLACE(REPLACE(product_name, '\n', '
'),'|', '|'),'\\\\','\\') AS product_name, quantity, price, amount, deleted_at, created_at, updated_at, now() AS _source_loaded_datetime FROM `transaction_detail`;", + "transaction_logs" : "SELECT *, now() AS _source_loaded_datetime FROM transaction_logs", + "users" : "SELECT id, name, email, type, status, remember_token, active_at, deleted_at, created_at, updated_at, now() AS _source_loaded_datetime FROM users;", + "user_email_verifications" : "SELECT *, now() AS _source_loaded_datetime FROM user_email_verifications;", + "wallets" : "SELECT *, now() AS _source_loaded_datetime FROM wallets;", + "wallet_logs" : "SELECT *, now() AS _source_loaded_datetime FROM wallet_logs" } \ No newline at end of file