diff --git a/README.md b/README.md index e71a42c..1d3ecd0 100644 --- a/README.md +++ b/README.md @@ -39,14 +39,9 @@ ###### Example:- EXCHANGE_EXTRACT_SQL.json ``` { - "customers" : "SELECT * FROM customers;", - "employees" : "SELECT * FROM employees;", - "offices" : "SELECT * FROM offices;", - "orderdetails" : "SELECT * FROM orderdetails;", - "orders" : "SELECT * FROM orders;", - "payments" : "SELECT * FROM payments;", - "productlines" : "SELECT * FROM productlines;", - "products" : "SELECT * FROM products;" + "customers" : "SELECT *, now() AS '_source_loaded_at' FROM customers;", + "employees" : "SELECT *, now() AS '_source_loaded_at' FROM employees;", + "offices" : "SELECT *, now() AS '_source_loaded_at' FROM offices;" } ``` ### Project Tree diff --git a/config/EXCHANGE_EXTRACT_SQL.json b/config/EXCHANGE_EXTRACT_SQL.json index 5a62e81..e6c2973 100644 --- a/config/EXCHANGE_EXTRACT_SQL.json +++ b/config/EXCHANGE_EXTRACT_SQL.json @@ -1,4 +1,19 @@ { - "contacts" : "SELECT * FROM contacts;", - "transactions" : "SELECT * FROM transactions;" + "bookings" : "SELECT *, now() AS '_source_loaded_at' FROM bookings;", + "companies" : "SELECT *, now() AS '_source_loaded_at' FROM companies;", + "contacts" : "SELECT id, company_id, country_id, deleted_at, created_at, updated_at, now() AS '_source_loaded_at' FROM contacts;", + "countries" : "SELECT *, now() AS '_source_loaded_at' FROM countries;", + "currencies" : "SELECT *, now() AS '_source_loaded_at' FROM currencies;", + "currency_rates" : "SELECT *, now() AS '_source_loaded_at' FROM currency_rates;", + "employees" : "SELECT *, now() AS '_source_loaded_at' FROM employees;", + "groups" : "SELECT *, now() AS '_source_loaded_at' FROM groups;", + "group_transactions" : "SELECT *, now() AS '_source_loaded_at' FROM group_transactions;", + "segments" : "SELECT *, now() AS '_source_loaded_at' FROM segments;", + "segment_companies" : "SELECT *, now() AS '_source_loaded_at' FROM segment_companies;", + "service_types" : "SELECT *, now() AS '_source_loaded_at' FROM service_types;", + "transactions" : "SELECT *, now() AS '_source_loaded_at' FROM transactions;", + "transaction_detail" : "SELECT *, now() AS '_source_loaded_at' FROM transaction_detail;", + "users" : "SELECT id, name, email, type, status, deleted_at, created_at, updated_at, now() AS '_source_loaded_at' FROM users;", + "user_email_verifications" : "SELECT id,email now() AS '_source_loaded_at' FROM users;", + "wallets" : "SELECT *, now() AS '_source_loaded_at' FROM wallets;" } \ No newline at end of file