Как проверить контрольную сумму пришедших данных?

Question

[QTusers]

Есть у меня один скрипт на Python , который позволяет копировать данные таблицы из СУБД (SqLike, SQlServer) в Postgres.
Как запросить хэш сумму отправляемых таблиц (данных), запросить хэш сумму принятых таблиц (данных) и произвести их сравнение?

Comments

[Akina]

x=2+2
y=2+2
if x<>y then panic()

[QTusers]

«Пользователь удалён», Мне нужно по работе

[QTusers]

«Пользователь удалён», А также для саморазвития

[pfg21]

в sql протоколе есть хеш-суммы ??
после копирования данных из одной бд в другую, еще раз прочитать данные из источника и получателя и сравнить меж собой

[QTusers]

pfg21, нет

[Vitsliputsli]

QTusers, хеш-таблиц очевидно будет разным в разных СУБД. Да и зачем каждый раз сравнивать? Просто напишите тесты для скрипта.

[d'Ivan]

Данные в СУБД эфемерны. Вот получил ты данные со всеми печатями, а спустя мгновение они снова изменились.

[QTusers]

Vitsliputsli, Где можно посмотреть примеры тестов для скрипта

[QTusers]

Everything_is_not_so_bad, Данные будут запрашиваться с интервалом в 20 дней

[QTusers]

Akina, Как это понять????

[Akina]

QTusers, очень просто. Если при выполнении операции не возникло ошибки, то записано в таблицы будет ровно то, что было передано серверу. И прочитано из таблиц будет ровно то, что было записано. Чудес не бывает. Так что в описанном процессе начудесить может только программа переноса.

[Olteya]

Если хотите через хеш, попробуйте написать на пайтоне скрипт, который будет считать хеш по МД5, посчитайте суммы для нужной таблицы для СУБД источника и приемника и сравните.
Не являюсь специалистом по пайтон, но найденный пример кажется похожим на правду:

import hashlib
import psycopg2
import sqlite3

def calculate_md5(cursor, table_name):
    cursor.execute(f'SELECT * FROM {table_name}')
    rows = cursor.fetchall()
    md5 = hashlib.md5()
    for row in rows:
        md5.update(str(row).encode('utf-8'))
    return md5.hexdigest()

# SQLite
sqlite_conn = sqlite3.connect('source.db')
sqlite_cursor = sqlite_conn.cursor()
sqlite_md5 = calculate_md5(sqlite_cursor, 'source_table')

# PostgreSQL
pg_conn = psycopg2.connect(
    dbname="target_db", user="user", password="password", host="localhost"
)
pg_cursor = pg_conn.cursor()
pg_md5 = calculate_md5(pg_cursor, 'target_table')

# Сравнение
if sqlite_md5 == pg_md5:
    print("Контрольные суммы совпадают.")
else:
    print("Контрольные суммы не совпадают.")