Skip to content

adding logging to see how big the drift is #45

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
cindysx89 merged 4 commits into from
Jul 16, 2025
Merged

adding logging to see how big the drift is #45

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
e986dde
adding logging to see how big the drift is
cindysx89 Jul 16, 2025
0157ebe
formatting
cindysx89 Jul 16, 2025
f66d27f
using .execute instead
cindysx89 Jul 16, 2025
a8506e8
changing when to call log_row_drift
cindysx89 Jul 16, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
17 changes: 17 additions & 0 deletions models/table.rb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -115,6 +115,22 @@ def copy
end
end

def log_row_drift
source_sql = "SELECT COUNT(*) AS count FROM #{source_name}"
dest_sql = "SELECT COUNT(*) AS count FROM #{destination_name}"

source_result = source_connection.execute(source_sql)
dest_result = destination_connection.execute(dest_sql)

source_count = source_result.first['count'].to_i
dest_count = dest_result.first['count'].to_i
drift = source_count - dest_count

logger.info "Drift for #{source_name}: source=#{source_count}, destination=#{dest_count}, drift=#{drift}"
rescue => e
logger.error "Error calculating drift for #{source_name}: #{e.message}"
end

def copy_now
started_at = Time.now
return 0 unless (self.enabled? && self.check)
Expand Down Expand Up @@ -143,6 +159,7 @@ def copy_now
merge_results(temp_table_name, merge_to_table_name)
update_max_values(temp_table_name)

log_row_drift
destination_connection.execute("DROP TABLE #{temp_table_name};")
end

Expand Down
Loading