PostgreSQL ਅਤੇ MySQL ਵਿਚਕਾਰ ਕ੍ਰਾਸ ਪ੍ਰਤੀਕ੍ਰਿਤੀ

ਮੈਂ PostgreSQL ਅਤੇ MySQL ਵਿਚਕਾਰ ਕਰਾਸ-ਰਿਪਲੀਕੇਸ਼ਨ ਦੀ ਰੂਪਰੇਖਾ ਦੇਵਾਂਗਾ, ਅਤੇ ਨਾਲ ਹੀ ਦੋ ਡਾਟਾਬੇਸ ਸਰਵਰਾਂ ਵਿਚਕਾਰ ਕਰਾਸ-ਰਿਪਲੀਕੇਸ਼ਨ ਸਥਾਪਤ ਕਰਨ ਲਈ ਵਿਧੀਆਂ। ਆਮ ਤੌਰ 'ਤੇ, ਕਰਾਸ-ਰਿਪਲੀਕੇਟਡ ਡੇਟਾਬੇਸ ਨੂੰ ਸਮਰੂਪ ਕਿਹਾ ਜਾਂਦਾ ਹੈ, ਅਤੇ ਇਹ ਇੱਕ RDBMS ਸਰਵਰ ਤੋਂ ਦੂਜੇ ਵਿੱਚ ਜਾਣ ਦਾ ਇੱਕ ਸੁਵਿਧਾਜਨਕ ਤਰੀਕਾ ਹੈ।

PostgreSQL ਅਤੇ MySQL ਡੇਟਾਬੇਸ ਨੂੰ ਆਮ ਤੌਰ 'ਤੇ ਰਿਲੇਸ਼ਨਲ ਮੰਨਿਆ ਜਾਂਦਾ ਹੈ, ਪਰ ਵਾਧੂ ਐਕਸਟੈਂਸ਼ਨਾਂ ਦੇ ਨਾਲ ਉਹ NoSQL ਸਮਰੱਥਾਵਾਂ ਦੀ ਪੇਸ਼ਕਸ਼ ਕਰਦੇ ਹਨ। ਇੱਥੇ ਅਸੀਂ ਇੱਕ ਸੰਬੰਧਤ DBMS ਦ੍ਰਿਸ਼ਟੀਕੋਣ ਤੋਂ PostgreSQL ਅਤੇ MySQL ਵਿਚਕਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਬਾਰੇ ਚਰਚਾ ਕਰਾਂਗੇ।

ਅਸੀਂ ਪੂਰੇ ਅੰਦਰੂਨੀ ਕਾਰਜਾਂ ਦਾ ਵਰਣਨ ਨਹੀਂ ਕਰਾਂਗੇ, ਸਿਰਫ ਬੁਨਿਆਦੀ ਸਿਧਾਂਤਾਂ ਦਾ ਵਰਣਨ ਕਰਾਂਗੇ ਤਾਂ ਜੋ ਤੁਹਾਨੂੰ ਡੇਟਾਬੇਸ ਸਰਵਰਾਂ, ਫਾਇਦਿਆਂ, ਸੀਮਾਵਾਂ ਅਤੇ ਵਰਤੋਂ ਦੇ ਮਾਮਲਿਆਂ ਦੇ ਵਿਚਕਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦੀ ਸੰਰਚਨਾ ਕਰਨ ਦਾ ਇੱਕ ਵਿਚਾਰ ਪ੍ਰਾਪਤ ਹੋਵੇ।

ਆਮ ਤੌਰ 'ਤੇ, ਦੋ ਇੱਕੋ ਜਿਹੇ ਡੇਟਾਬੇਸ ਸਰਵਰਾਂ ਵਿਚਕਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਜਾਂ ਤਾਂ ਬਾਈਨਰੀ ਮੋਡ ਵਿੱਚ ਕੀਤੀ ਜਾਂਦੀ ਹੈ ਜਾਂ ਇੱਕ ਮਾਸਟਰ (ਉਰਫ਼ ਪ੍ਰਕਾਸ਼ਕ, ਮਾਸਟਰ, ਜਾਂ ਕਿਰਿਆਸ਼ੀਲ) ਅਤੇ ਇੱਕ ਗੁਲਾਮ (ਗਾਹਕ, ਸਟੈਂਡਬਾਏ, ਜਾਂ ਪੈਸਿਵ) ਵਿਚਕਾਰ ਪੁੱਛਗਿੱਛਾਂ ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਕੀਤੀ ਜਾਂਦੀ ਹੈ। ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦਾ ਉਦੇਸ਼ ਸਲੇਵ ਸਾਈਡ 'ਤੇ ਮਾਸਟਰ ਡੇਟਾਬੇਸ ਦੀ ਅਸਲ-ਸਮੇਂ ਦੀ ਕਾਪੀ ਪ੍ਰਦਾਨ ਕਰਨਾ ਹੈ। ਇਸ ਸਥਿਤੀ ਵਿੱਚ, ਡੇਟਾ ਨੂੰ ਮਾਸਟਰ ਤੋਂ ਸਲੇਵ ਵਿੱਚ ਟ੍ਰਾਂਸਫਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਯਾਨੀ ਕਿਰਿਆਸ਼ੀਲ ਤੋਂ ਪੈਸਿਵ ਵਿੱਚ, ਕਿਉਂਕਿ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਿਰਫ ਇੱਕ ਦਿਸ਼ਾ ਵਿੱਚ ਕੀਤੀ ਜਾਂਦੀ ਹੈ. ਪਰ ਤੁਸੀਂ ਦੋਨਾਂ ਦਿਸ਼ਾਵਾਂ ਵਿੱਚ ਦੋ ਡੇਟਾਬੇਸ ਦੇ ਵਿਚਕਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸੈਟ ਅਪ ਕਰ ਸਕਦੇ ਹੋ, ਤਾਂ ਜੋ ਡੇਟਾ ਨੂੰ ਇੱਕ ਐਕਟਿਵ-ਐਕਟਿਵ ਕੌਂਫਿਗਰੇਸ਼ਨ ਵਿੱਚ ਸਲੇਵ ਤੋਂ ਮਾਸਟਰ ਵਿੱਚ ਟ੍ਰਾਂਸਫਰ ਕੀਤਾ ਜਾ ਸਕੇ। ਇਹ ਸਭ, ਕੈਸਕੇਡਿੰਗ ਰੀਪਲੀਕੇਸ਼ਨ ਸਮੇਤ, ਦੋ ਜਾਂ ਦੋ ਤੋਂ ਵੱਧ ਇੱਕੋ ਜਿਹੇ ਡੇਟਾਬੇਸ ਸਰਵਰਾਂ ਵਿਚਕਾਰ ਸੰਭਵ ਹੈ। ਕਿਰਿਆਸ਼ੀਲ-ਸਰਗਰਮ ਜਾਂ ਕਿਰਿਆਸ਼ੀਲ-ਪੈਸਿਵ ਸੰਰਚਨਾ ਲੋੜ, ਸ਼ੁਰੂਆਤੀ ਸੰਰਚਨਾ ਵਿੱਚ ਅਜਿਹੀਆਂ ਸਮਰੱਥਾਵਾਂ ਦੀ ਉਪਲਬਧਤਾ ਜਾਂ ਬਾਹਰੀ ਸੰਰਚਨਾ ਹੱਲਾਂ ਅਤੇ ਮੌਜੂਦਾ ਟਰੇਡ-ਆਫਸ ਦੀ ਵਰਤੋਂ 'ਤੇ ਨਿਰਭਰ ਕਰਦੀ ਹੈ।

ਵਰਣਿਤ ਸੰਰਚਨਾ ਵੱਖ-ਵੱਖ ਡਾਟਾਬੇਸ ਸਰਵਰਾਂ ਵਿਚਕਾਰ ਸੰਭਵ ਹੈ। ਸਰਵਰ ਨੂੰ ਕਿਸੇ ਹੋਰ ਡੇਟਾਬੇਸ ਸਰਵਰ ਤੋਂ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਕੀਤੇ ਡੇਟਾ ਨੂੰ ਸਵੀਕਾਰ ਕਰਨ ਲਈ ਕੌਂਫਿਗਰ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ ਅਤੇ ਫਿਰ ਵੀ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਕੀਤੇ ਡੇਟਾ ਦੇ ਅਸਲ-ਸਮੇਂ ਦੇ ਸਨੈਪਸ਼ਾਟ ਨੂੰ ਬਣਾਈ ਰੱਖਿਆ ਜਾ ਸਕਦਾ ਹੈ। MySQL ਅਤੇ PostgreSQL ਇਹਨਾਂ ਵਿੱਚੋਂ ਜ਼ਿਆਦਾਤਰ ਸੰਰਚਨਾਵਾਂ ਨੂੰ ਅੰਦਰ-ਅੰਦਰ ਜਾਂ ਤੀਜੀ-ਧਿਰ ਐਕਸਟੈਂਸ਼ਨਾਂ ਰਾਹੀਂ ਪੇਸ਼ ਕਰਦੇ ਹਨ, ਜਿਸ ਵਿੱਚ ਬਾਈਨਰੀ ਲੌਗ ਵਿਧੀਆਂ, ਡਿਸਕ ਲੌਕਿੰਗ, ਅਤੇ ਸਟੇਟਮੈਂਟ- ਅਤੇ ਰੋ-ਅਧਾਰਿਤ ਢੰਗ ਸ਼ਾਮਲ ਹਨ।

MySQL ਅਤੇ PostgreSQL ਵਿਚਕਾਰ ਕਰਾਸ ਰੀਪਲੀਕੇਸ਼ਨ ਇੱਕ ਡਾਟਾਬੇਸ ਸਰਵਰ ਤੋਂ ਦੂਜੇ ਡੇਟਾਬੇਸ ਸਰਵਰ ਵਿੱਚ ਇੱਕ ਵਾਰ ਮਾਈਗਰੇਸ਼ਨ ਲਈ ਲੋੜੀਂਦਾ ਹੈ। ਇਹ ਡੇਟਾਬੇਸ ਵੱਖ-ਵੱਖ ਪ੍ਰੋਟੋਕੋਲ ਦੀ ਵਰਤੋਂ ਕਰਦੇ ਹਨ, ਇਸਲਈ ਉਹਨਾਂ ਨੂੰ ਸਿੱਧੇ ਲਿੰਕ ਕਰਨਾ ਸੰਭਵ ਨਹੀਂ ਹੈ। ਡੇਟਾ ਐਕਸਚੇਂਜ ਸਥਾਪਤ ਕਰਨ ਲਈ, ਤੁਸੀਂ ਇੱਕ ਬਾਹਰੀ ਓਪਨ ਸੋਰਸ ਟੂਲ ਦੀ ਵਰਤੋਂ ਕਰ ਸਕਦੇ ਹੋ, ਉਦਾਹਰਨ ਲਈ pg_chameleon.

pg_chameleon ਕੀ ਹੈ

pg_chameleon ਪਾਈਥਨ 3 ਵਿੱਚ MySQL ਤੋਂ PostgreSQL ਤੱਕ ਇੱਕ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਪ੍ਰਣਾਲੀ ਹੈ। ਇਹ ਓਪਨ ਸੋਰਸ mysql-ਰਿਪਲੀਕੇਸ਼ਨ ਲਾਇਬ੍ਰੇਰੀ ਦੀ ਵਰਤੋਂ ਕਰਦਾ ਹੈ, ਪਾਈਥਨ ਵਿੱਚ ਵੀ। ਕਤਾਰ ਚਿੱਤਰਾਂ ਨੂੰ MySQL ਟੇਬਲਾਂ ਤੋਂ ਕੱਢਿਆ ਜਾਂਦਾ ਹੈ ਅਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ JSONB ਵਸਤੂਆਂ ਵਜੋਂ ਸਟੋਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਅਤੇ ਫਿਰ pl/pgsql ਫੰਕਸ਼ਨ ਦੁਆਰਾ ਡੀਕ੍ਰਿਪਟ ਕੀਤਾ ਜਾਂਦਾ ਹੈ ਅਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਦੁਬਾਰਾ ਤਿਆਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ।

pg_chameleon ਦੀਆਂ ਵਿਸ਼ੇਸ਼ਤਾਵਾਂ

ਇੱਕੋ ਕਲੱਸਟਰ ਤੋਂ ਕਈ MySQL ਸਕੀਮਾਂ ਨੂੰ ਇੱਕ ਤੋਂ ਕਈ ਸੰਰਚਨਾ ਵਿੱਚ ਇੱਕ ਸਿੰਗਲ ਟਾਰਗੇਟ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਦੁਹਰਾਇਆ ਜਾ ਸਕਦਾ ਹੈ।
ਸਰੋਤ ਅਤੇ ਟੀਚਾ ਸਕੀਮਾ ਨਾਮ ਇੱਕੋ ਨਹੀਂ ਹੋ ਸਕਦੇ ਹਨ।
ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਡੇਟਾ ਇੱਕ ਕੈਸਕੇਡਡ MySQL ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਤੋਂ ਪ੍ਰਾਪਤ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ।
ਉਹ ਟੇਬਲ ਜੋ ਨਕਲ ਨਹੀਂ ਕਰ ਸਕਦੀਆਂ ਜਾਂ ਗਲਤੀਆਂ ਪੈਦਾ ਨਹੀਂ ਕਰ ਸਕਦੀਆਂ ਹਨ, ਨੂੰ ਬਾਹਰ ਰੱਖਿਆ ਗਿਆ ਹੈ।
ਹਰੇਕ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਫੰਕਸ਼ਨ ਡੈਮਨ ਦੁਆਰਾ ਨਿਯੰਤਰਿਤ ਕੀਤਾ ਜਾਂਦਾ ਹੈ।
YAML-ਅਧਾਰਿਤ ਮਾਪਦੰਡਾਂ ਅਤੇ ਸੰਰਚਨਾ ਫਾਈਲਾਂ ਦੁਆਰਾ ਨਿਯੰਤਰਣ.

ਉਦਾਹਰਨ:

ਹੋਸਟ
ਵੀਐਮ 1
ਵੀਐਮ 2

OS ਸੰਸਕਰਣ
CentOS Linux 7.6 x86_64
CentOS Linux 7.5 x86_64

DB ਸਰਵਰ ਸੰਸਕਰਣ
MySQL 5.7.26
PostgreSQL 10.5

DB ਪੋਰਟ
3306
5433

IP ਐਡਰੈੱਸ
192.168.56.102
192.168.56.106

ਸ਼ੁਰੂ ਕਰਨ ਲਈ, pg_chameleon ਨੂੰ ਸਥਾਪਿਤ ਕਰਨ ਲਈ ਸਾਰੇ ਲੋੜੀਂਦੇ ਹਿੱਸੇ ਤਿਆਰ ਕਰੋ। ਇਹ ਉਦਾਹਰਨ ਪਾਈਥਨ 3.6.8 ਨੂੰ ਇੰਸਟਾਲ ਕਰਦੀ ਹੈ, ਜੋ ਵਰਚੁਅਲ ਵਾਤਾਵਰਨ ਬਣਾਉਂਦਾ ਅਤੇ ਕਿਰਿਆਸ਼ੀਲ ਕਰਦਾ ਹੈ।

$> wget https://www.python.org/ftp/python/3.6.8/Python-3.6.8.tar.xz
$> tar -xJf Python-3.6.8.tar.xz
$> cd Python-3.6.8
$> ./configure --enable-optimizations
$> make altinstall

Python3.6 ਨੂੰ ਸਫਲਤਾਪੂਰਵਕ ਸਥਾਪਿਤ ਕਰਨ ਤੋਂ ਬਾਅਦ, ਤੁਹਾਨੂੰ ਬਾਕੀ ਲੋੜਾਂ ਨੂੰ ਪੂਰਾ ਕਰਨ ਦੀ ਲੋੜ ਹੈ, ਜਿਵੇਂ ਕਿ ਇੱਕ ਵਰਚੁਅਲ ਵਾਤਾਵਰਨ ਬਣਾਉਣਾ ਅਤੇ ਕਿਰਿਆਸ਼ੀਲ ਕਰਨਾ। ਇਸ ਤੋਂ ਇਲਾਵਾ, ਪਾਈਪ ਮੋਡੀਊਲ ਨੂੰ ਨਵੀਨਤਮ ਸੰਸਕਰਣ ਲਈ ਅੱਪਡੇਟ ਕੀਤਾ ਗਿਆ ਹੈ ਅਤੇ pg_chameleon ਨੂੰ ਇੰਸਟਾਲ ਕਰਨ ਲਈ ਵਰਤਿਆ ਗਿਆ ਹੈ। ਹੇਠਾਂ ਦਿੱਤੀਆਂ ਕਮਾਂਡਾਂ pg_chameleon 2.0.9 ਨੂੰ ਜਾਣਬੁੱਝ ਕੇ ਸਥਾਪਿਤ ਕਰਦੀਆਂ ਹਨ, ਹਾਲਾਂਕਿ ਨਵੀਨਤਮ ਸੰਸਕਰਣ 2.0.10 ਹੈ। ਅੱਪਡੇਟ ਕੀਤੇ ਸੰਸਕਰਣ ਵਿੱਚ ਨਵੇਂ ਬੱਗ ਤੋਂ ਬਚਣ ਲਈ ਇਹ ਜ਼ਰੂਰੀ ਹੈ।

$> python3.6 -m venv venv
$> source venv/bin/activate
(venv) $> pip install pip --upgrade
(venv) $> pip install pg_chameleon==2.0.9

ਅਸੀਂ ਫਿਰ pg_chameleon ਨੂੰ ਸਮਰੱਥ ਬਣਾਉਣ ਅਤੇ ਡਿਫਾਲਟ ਡਾਇਰੈਕਟਰੀਆਂ ਅਤੇ ਸੰਰਚਨਾ ਫਾਈਲਾਂ ਬਣਾਉਣ ਲਈ set_configuration_files ਆਰਗੂਮੈਂਟ ਦੇ ਨਾਲ pg_chameleon (ਗ੍ਰਿਗਟ ਇੱਕ ਕਮਾਂਡ ਹੈ) ਨੂੰ ਕਾਲ ਕਰਦੇ ਹਾਂ।

(venv) $> chameleon set_configuration_files
creating directory /root/.pg_chameleon
creating directory /root/.pg_chameleon/configuration/
creating directory /root/.pg_chameleon/logs/
creating directory /root/.pg_chameleon/pid/
copying configuration  example in /root/.pg_chameleon/configuration//config-example.yml

ਹੁਣ ਅਸੀਂ config-example.yml ਦੀ ਇੱਕ ਕਾਪੀ default.yml ਦੇ ਰੂਪ ਵਿੱਚ ਬਣਾਉਂਦੇ ਹਾਂ ਤਾਂ ਜੋ ਇਹ ਡਿਫਾਲਟ ਸੰਰਚਨਾ ਫਾਈਲ ਬਣ ਜਾਵੇ। ਇਸ ਉਦਾਹਰਨ ਲਈ ਇੱਕ ਨਮੂਨਾ ਸੰਰਚਨਾ ਫਾਇਲ ਹੇਠਾਂ ਦਿੱਤੀ ਗਈ ਹੈ।

$> cat default.yml
---
#global settings
pid_dir: '~/.pg_chameleon/pid/'
log_dir: '~/.pg_chameleon/logs/'
log_dest: file
log_level: info
log_days_keep: 10
rollbar_key: ''
rollbar_env: ''

# type_override allows the user to override the default type conversion into a different one.
type_override:
  "tinyint(1)":
    override_to: boolean
    override_tables:
      - "*"

#postgres  destination connection
pg_conn:
  host: "192.168.56.106"
  port: "5433"
  user: "usr_replica"
  password: "pass123"
  database: "db_replica"
  charset: "utf8"

sources:
  mysql:
    db_conn:
      host: "192.168.56.102"
      port: "3306"
      user: "usr_replica"
      password: "pass123"
      charset: 'utf8'
      connect_timeout: 10
    schema_mappings:
      world_x: pgworld_x
    limit_tables:
#      - delphis_mediterranea.foo
    skip_tables:
#      - delphis_mediterranea.bar
    grant_select_to:
      - usr_readonly
    lock_timeout: "120s"
    my_server_id: 100
    replica_batch_size: 10000
    replay_max_rows: 10000
    batch_retention: '1 day'
    copy_max_memory: "300M"
    copy_mode: 'file'
    out_dir: /tmp
    sleep_loop: 1
    on_error_replay: continue
    on_error_read: continue
    auto_maintenance: "disabled"
    gtid_enable: No
    type: mysql
    skip_events:
      insert:
        - delphis_mediterranea.foo #skips inserts on the table delphis_mediterranea.foo
      delete:
        - delphis_mediterranea #skips deletes on schema delphis_mediterranea
      update:

ਇਸ ਉਦਾਹਰਨ ਵਿੱਚ ਸੰਰਚਨਾ ਫਾਇਲ ਇੱਕ ਨਮੂਨਾ pg_chameleon ਫਾਇਲ ਹੈ ਜਿਸ ਵਿੱਚ ਸਰੋਤ ਅਤੇ ਟਾਰਗੇਟ ਵਾਤਾਵਰਣ ਦੇ ਅਨੁਕੂਲ ਹੋਣ ਲਈ ਮਾਮੂਲੀ ਸੋਧਾਂ ਹਨ, ਅਤੇ ਹੇਠਾਂ ਸੰਰਚਨਾ ਫਾਇਲ ਦੇ ਵੱਖ-ਵੱਖ ਭਾਗਾਂ ਦੀ ਇੱਕ ਸੰਖੇਪ ਜਾਣਕਾਰੀ ਹੈ।

default.yml ਕੌਂਫਿਗਰੇਸ਼ਨ ਫਾਈਲ ਵਿੱਚ ਗਲੋਬਲ ਸੈਟਿੰਗਾਂ ਦਾ ਇੱਕ ਭਾਗ ਹੁੰਦਾ ਹੈ, ਜਿੱਥੇ ਤੁਸੀਂ ਸੈਟਿੰਗਾਂ ਦਾ ਪ੍ਰਬੰਧਨ ਕਰ ਸਕਦੇ ਹੋ ਜਿਵੇਂ ਕਿ ਲਾਕ ਫਾਈਲ ਦੀ ਸਥਿਤੀ, ਲੌਗਸ ਦੀ ਸਥਿਤੀ, ਲੌਗਸ ਲਈ ਸਟੋਰੇਜ ਦੀ ਮਿਆਦ ਆਦਿ। ਅੱਗੇ ਟਾਈਪ ਓਵਰਰਾਈਡ ਸੈਕਸ਼ਨ ਆਉਂਦਾ ਹੈ, ਜਿੱਥੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦੇ ਦੌਰਾਨ ਓਵਰਰਾਈਡਿੰਗ ਕਿਸਮਾਂ ਲਈ ਨਿਯਮਾਂ ਦਾ ਇੱਕ ਸਮੂਹ। ਉਦਾਹਰਨ ਇੱਕ ਟਾਈਪ ਓਵਰਰਾਈਡਿੰਗ ਨਿਯਮ ਲਈ ਡਿਫੌਲਟ ਹੈ ਜੋ tinyint(1) ਨੂੰ ਬੂਲੀਅਨ ਮੁੱਲ ਵਿੱਚ ਬਦਲਦਾ ਹੈ। ਅਗਲੇ ਭਾਗ ਵਿੱਚ, ਅਸੀਂ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਨਾਲ ਕੁਨੈਕਸ਼ਨ ਵੇਰਵੇ ਨਿਰਧਾਰਤ ਕਰਦੇ ਹਾਂ। ਸਾਡੇ ਕੇਸ ਵਿੱਚ, ਇਹ ਇੱਕ PostgreSQL ਡੇਟਾਬੇਸ ਹੈ, ਮਨੋਨੀਤ pg_conn. ਪਿਛਲੇ ਭਾਗ ਵਿੱਚ, ਅਸੀਂ ਸਰੋਤ ਡੇਟਾ ਨੂੰ ਦਰਸਾਉਂਦੇ ਹਾਂ, ਯਾਨੀ ਸਰੋਤ ਡੇਟਾਬੇਸ ਦੇ ਕਨੈਕਸ਼ਨ ਮਾਪਦੰਡ, ਸਰੋਤ ਅਤੇ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਵਿਚਕਾਰ ਮੈਪਿੰਗ ਸਕੀਮ, ਟੇਬਲ ਜਿਨ੍ਹਾਂ ਨੂੰ ਛੱਡਣ ਦੀ ਲੋੜ ਹੈ, ਉਡੀਕ ਸਮਾਂ, ਮੈਮੋਰੀ, ਪੈਕੇਜ ਦਾ ਆਕਾਰ। ਨੋਟ ਕਰੋ ਕਿ "ਸਰੋਤ" ਬਹੁਵਚਨ ਹੈ, ਮਤਲਬ ਕਿ ਅਸੀਂ ਕਈ-ਤੋਂ-ਇੱਕ ਕੌਂਫਿਗਰੇਸ਼ਨ ਸੈਟ ਅਪ ਕਰਨ ਲਈ ਇੱਕ ਸਿੰਗਲ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਵਿੱਚ ਕਈ ਸਰੋਤ ਡੇਟਾਬੇਸ ਜੋੜ ਸਕਦੇ ਹਾਂ।

ਉਦਾਹਰਨ ਡੇਟਾਬੇਸ world_x ਵਿੱਚ ਕਤਾਰਾਂ ਦੇ ਨਾਲ 4 ਟੇਬਲ ਹਨ ਜੋ MySQL ਕਮਿਊਨਿਟੀ ਉਦਾਹਰਨਾਂ ਵਜੋਂ ਪੇਸ਼ ਕਰਦਾ ਹੈ। ਇਸ ਨੂੰ ਡਾਊਨਲੋਡ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ ਇੱਥੇ. ਨਮੂਨਾ ਡੇਟਾਬੇਸ ਕਤਾਰਾਂ ਬਣਾਉਣ ਅਤੇ ਆਯਾਤ ਕਰਨ ਲਈ ਨਿਰਦੇਸ਼ਾਂ ਦੇ ਨਾਲ ਟਾਰ ਅਤੇ ਸੰਕੁਚਿਤ ਪੁਰਾਲੇਖ ਦੇ ਰੂਪ ਵਿੱਚ ਆਉਂਦਾ ਹੈ।

MySQL ਅਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ, ਇੱਕ ਵਿਸ਼ੇਸ਼ ਉਪਭੋਗਤਾ ਉਸੇ ਨਾਮ ਨਾਲ ਬਣਾਇਆ ਗਿਆ ਹੈ usr_replica. MySQL ਵਿੱਚ, ਇਸ ਨੂੰ ਸਾਰੀਆਂ ਨਕਲ ਕੀਤੀਆਂ ਟੇਬਲਾਂ ਲਈ ਵਾਧੂ ਪੜ੍ਹਨ ਦੇ ਅਧਿਕਾਰ ਦਿੱਤੇ ਗਏ ਹਨ।

mysql> CREATE USER usr_replica ;
mysql> SET PASSWORD FOR usr_replica='pass123';
mysql> GRANT ALL ON world_x.* TO 'usr_replica';
mysql> GRANT RELOAD ON *.* to 'usr_replica';
mysql> GRANT REPLICATION CLIENT ON *.* to 'usr_replica';
mysql> GRANT REPLICATION SLAVE ON *.* to 'usr_replica';
mysql> FLUSH PRIVILEGES;

PostgreSQL ਪਾਸੇ, ਇੱਕ db_replica ਡੇਟਾਬੇਸ ਬਣਾਇਆ ਗਿਆ ਹੈ ਜੋ MySQL ਡੇਟਾਬੇਸ ਤੋਂ ਤਬਦੀਲੀਆਂ ਨੂੰ ਸਵੀਕਾਰ ਕਰੇਗਾ। PostgreSQL ਵਿੱਚ ਯੂਜ਼ਰ usr_replica ਨੂੰ ਆਪਣੇ ਆਪ ਦੋ ਸਕੀਮਾਂ, pgworld_x ਅਤੇ sch_chameleon ਦੇ ਮਾਲਕ ਵਜੋਂ ਸੰਰਚਿਤ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਜਿਸ ਵਿੱਚ ਕ੍ਰਮਵਾਰ ਅਸਲ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਟੇਬਲ ਅਤੇ ਰੀਪਲੀਕੇਸ਼ਨ ਡਾਇਰੈਕਟਰੀ ਟੇਬਲ ਹੁੰਦੇ ਹਨ। create_replica_schema ਆਰਗੂਮੈਂਟ ਆਟੋਮੈਟਿਕ ਕੌਂਫਿਗਰੇਸ਼ਨ ਲਈ ਜ਼ਿੰਮੇਵਾਰ ਹੈ, ਜਿਵੇਂ ਕਿ ਤੁਸੀਂ ਹੇਠਾਂ ਦੇਖੋਗੇ।

postgres=# CREATE USER usr_replica WITH PASSWORD 'pass123';
CREATE ROLE
postgres=# CREATE DATABASE db_replica WITH OWNER usr_replica;
CREATE DATABASE

MySQL ਡੇਟਾਬੇਸ ਨੂੰ ਕੁਝ ਪੈਰਾਮੀਟਰ ਤਬਦੀਲੀਆਂ ਨਾਲ ਸੰਰਚਿਤ ਕੀਤਾ ਗਿਆ ਹੈ ਤਾਂ ਜੋ ਇਸਨੂੰ ਹੇਠਾਂ ਦਰਸਾਏ ਅਨੁਸਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਲਈ ਤਿਆਰ ਕੀਤਾ ਜਾ ਸਕੇ। ਤਬਦੀਲੀਆਂ ਨੂੰ ਲਾਗੂ ਕਰਨ ਲਈ ਤੁਹਾਨੂੰ ਡਾਟਾਬੇਸ ਸਰਵਰ ਨੂੰ ਮੁੜ ਚਾਲੂ ਕਰਨ ਦੀ ਲੋੜ ਹੋਵੇਗੀ।

$> vi /etc/my.cnf
binlog_format= ROW
binlog_row_image=FULL
log-bin = mysql-bin
server-id = 1

ਹੁਣ ਦੋਵਾਂ ਡਾਟਾਬੇਸ ਸਰਵਰਾਂ ਨਾਲ ਕੁਨੈਕਸ਼ਨ ਦੀ ਜਾਂਚ ਕਰਨਾ ਮਹੱਤਵਪੂਰਨ ਹੈ ਤਾਂ ਜੋ pg_chameleon ਕਮਾਂਡਾਂ ਨੂੰ ਚਲਾਉਣ ਵੇਲੇ ਕੋਈ ਸਮੱਸਿਆ ਨਾ ਆਵੇ।

PostgreSQL ਨੋਡ 'ਤੇ:

$> mysql -u usr_replica -Ap'admin123' -h 192.168.56.102 -D world_x

MySQL ਨੋਡ 'ਤੇ:

$> psql -p 5433 -U usr_replica -h 192.168.56.106 db_replica

ਅਗਲੀਆਂ ਤਿੰਨ pg_chameleon (chameleon) ਕਮਾਂਡਾਂ ਵਾਤਾਵਰਣ ਨੂੰ ਤਿਆਰ ਕਰਦੀਆਂ ਹਨ, ਸਰੋਤ ਜੋੜਦੀਆਂ ਹਨ, ਅਤੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਨੂੰ ਸ਼ੁਰੂ ਕਰਦੀਆਂ ਹਨ। pg_chameleon ਲਈ create_replica_schema ਆਰਗੂਮੈਂਟ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਇੱਕ ਡਿਫਾਲਟ ਸਕੀਮਾ (sch_chameleon) ਅਤੇ ਇੱਕ ਰੀਪਲੀਕੇਸ਼ਨ ਸਕੀਮਾ (pgworld_x) ਬਣਾਉਂਦਾ ਹੈ, ਜਿਵੇਂ ਕਿ ਅਸੀਂ ਪਹਿਲਾਂ ਹੀ ਚਰਚਾ ਕੀਤੀ ਹੈ। add_source ਆਰਗੂਮੈਂਟ ਕੌਂਫਿਗਰੇਸ਼ਨ ਫਾਈਲ (default.yml) ਨੂੰ ਪੜ੍ਹ ਕੇ ਸੰਰਚਨਾ ਵਿੱਚ ਇੱਕ ਸਰੋਤ ਡੇਟਾਬੇਸ ਜੋੜਦਾ ਹੈ, ਅਤੇ ਸਾਡੇ ਕੇਸ ਵਿੱਚ ਇਹ mysql ਹੈ, ਅਤੇ init_replica ਸੰਰਚਨਾ ਫਾਈਲ ਵਿੱਚ ਪੈਰਾਮੀਟਰਾਂ ਦੇ ਅਧਾਰ ਤੇ ਸੰਰਚਨਾ ਸ਼ੁਰੂ ਕਰਦਾ ਹੈ।

$> chameleon create_replica_schema --debug
$> chameleon add_source --config default --source mysql --debug
$> chameleon init_replica --config default --source mysql --debug

ਇਹਨਾਂ ਤਿੰਨਾਂ ਕਮਾਂਡਾਂ ਦਾ ਆਉਟਪੁੱਟ ਸਪਸ਼ਟ ਤੌਰ ਤੇ ਦਰਸਾਉਂਦਾ ਹੈ ਕਿ ਉਹਨਾਂ ਨੂੰ ਸਫਲਤਾਪੂਰਵਕ ਚਲਾਇਆ ਗਿਆ ਸੀ। ਕਿਸੇ ਵੀ ਕਰੈਸ਼ ਜਾਂ ਸਿੰਟੈਕਸ ਦੀਆਂ ਗਲਤੀਆਂ ਦੀ ਰਿਪੋਰਟ ਸਮੱਸਿਆ ਨੂੰ ਕਿਵੇਂ ਹੱਲ ਕਰਨ ਦੇ ਸੰਕੇਤਾਂ ਦੇ ਨਾਲ ਸਧਾਰਨ, ਸਪਸ਼ਟ ਸੰਦੇਸ਼ਾਂ ਵਿੱਚ ਕੀਤੀ ਜਾਂਦੀ ਹੈ।

ਅੰਤ ਵਿੱਚ, ਅਸੀਂ start_replica ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸ਼ੁਰੂ ਕਰਦੇ ਹਾਂ ਅਤੇ ਇੱਕ ਸਫਲਤਾ ਸੁਨੇਹਾ ਪ੍ਰਾਪਤ ਕਰਦੇ ਹਾਂ।

$> chameleon start_replica --config default --source mysql 
output: Starting the replica process for source mysql

ਸ਼ੋ_ਸਟੈਟਸ ਆਰਗੂਮੈਂਟ ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਥਿਤੀ ਦੀ ਪੁੱਛਗਿੱਛ ਕੀਤੀ ਜਾ ਸਕਦੀ ਹੈ, ਅਤੇ ਗਲਤੀਆਂ ਨੂੰ show_errors ਆਰਗੂਮੈਂਟ ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਦੇਖਿਆ ਜਾ ਸਕਦਾ ਹੈ।

ਨਤੀਜਾ

ਜਿਵੇਂ ਕਿ ਅਸੀਂ ਪਹਿਲਾਂ ਹੀ ਕਿਹਾ ਹੈ, ਹਰੇਕ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਫੰਕਸ਼ਨ ਡੈਮਨ ਦੁਆਰਾ ਨਿਯੰਤਰਿਤ ਕੀਤਾ ਜਾਂਦਾ ਹੈ। ਉਹਨਾਂ ਨੂੰ ਦੇਖਣ ਲਈ, ਅਸੀਂ ਲੀਨਕਸ ps ਕਮਾਂਡ ਨਾਲ ਪ੍ਰਕਿਰਿਆ ਸਾਰਣੀ ਦੀ ਪੁੱਛਗਿੱਛ ਕਰਦੇ ਹਾਂ, ਜਿਵੇਂ ਕਿ ਹੇਠਾਂ ਦਿਖਾਇਆ ਗਿਆ ਹੈ।

ਨਤੀਜਾ

ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਨੂੰ ਉਦੋਂ ਤੱਕ ਕੌਂਫਿਗਰ ਨਹੀਂ ਮੰਨਿਆ ਜਾਂਦਾ ਹੈ ਜਦੋਂ ਤੱਕ ਅਸੀਂ ਇਸਦੀ ਅਸਲ ਸਮੇਂ ਵਿੱਚ ਜਾਂਚ ਨਹੀਂ ਕਰਦੇ, ਜਿਵੇਂ ਕਿ ਹੇਠਾਂ ਦਿਖਾਇਆ ਗਿਆ ਹੈ। ਅਸੀਂ ਇੱਕ ਸਾਰਣੀ ਬਣਾਉਂਦੇ ਹਾਂ, MySQL ਡਾਟਾਬੇਸ ਵਿੱਚ ਕੁਝ ਰਿਕਾਰਡ ਸ਼ਾਮਲ ਕਰਦੇ ਹਾਂ, ਅਤੇ ਡੈਮਨ ਨੂੰ ਅੱਪਡੇਟ ਕਰਨ ਲਈ ਅਤੇ ਟੇਬਲ ਨੂੰ ਰਿਕਾਰਡਾਂ ਨਾਲ PostgreSQL ਡਾਟਾਬੇਸ ਵਿੱਚ ਨਕਲ ਕਰਨ ਲਈ pg_chameleon ਵਿੱਚ ਸਿੰਕ_ਟੇਬਲ ਆਰਗੂਮੈਂਟ ਨੂੰ ਕਾਲ ਕਰਦੇ ਹਾਂ।

mysql> create table t1 (n1 int primary key, n2 varchar(10));
Query OK, 0 rows affected (0.01 sec)
mysql> insert into t1 values (1,'one');
Query OK, 1 row affected (0.00 sec)
mysql> insert into t1 values (2,'two');
Query OK, 1 row affected (0.00 sec)

$> chameleon sync_tables --tables world_x.t1 --config default --source mysql
Sync tables process for source mysql started.

ਟੈਸਟ ਦੇ ਨਤੀਜਿਆਂ ਦੀ ਪੁਸ਼ਟੀ ਕਰਨ ਲਈ, ਅਸੀਂ PostgreSQL ਡੇਟਾਬੇਸ ਤੋਂ ਟੇਬਲ ਦੀ ਪੁੱਛਗਿੱਛ ਕਰਦੇ ਹਾਂ ਅਤੇ ਕਤਾਰਾਂ ਨੂੰ ਆਉਟਪੁੱਟ ਕਰਦੇ ਹਾਂ।

$> psql -p 5433 -U usr_replica -d db_replica -c "select * from pgworld_x.t1";
 n1 |  n2
----+-------
  1 | one
  2 | two

ਜੇਕਰ ਅਸੀਂ ਮਾਈਗ੍ਰੇਸ਼ਨ ਕਰ ਰਹੇ ਹਾਂ, ਤਾਂ ਹੇਠਾਂ ਦਿੱਤੀਆਂ pg_chameleon ਕਮਾਂਡਾਂ ਇਸਦਾ ਅੰਤ ਹੋਣਗੀਆਂ। ਕਮਾਂਡਾਂ ਨੂੰ ਚਲਾਉਣ ਦੀ ਲੋੜ ਹੈ ਜਦੋਂ ਸਾਨੂੰ ਇਹ ਯਕੀਨੀ ਹੋ ਜਾਂਦਾ ਹੈ ਕਿ ਸਾਰੀਆਂ ਟਾਰਗੇਟ ਟੇਬਲਾਂ ਦੀਆਂ ਕਤਾਰਾਂ ਨੂੰ ਦੁਹਰਾਇਆ ਗਿਆ ਹੈ, ਅਤੇ ਨਤੀਜਾ ਸਰੋਤ ਡੇਟਾਬੇਸ ਜਾਂ ਰੀਪਲੀਕੇਸ਼ਨ ਸਕੀਮ (sch_chameleon) ਦੇ ਹਵਾਲੇ ਤੋਂ ਬਿਨਾਂ ਇੱਕ ਸਾਫ਼-ਸੁਥਰਾ ਮਾਈਗਰੇਟ ਕੀਤਾ PostgreSQL ਡੇਟਾਬੇਸ ਹੋਵੇਗਾ।

$> chameleon stop_replica --config default --source mysql 
$> chameleon detach_replica --config default --source mysql --debug

ਜੇਕਰ ਲੋੜੀਦਾ ਹੋਵੇ, ਤਾਂ ਤੁਸੀਂ ਮੂਲ ਸੰਰਚਨਾ ਅਤੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਕੀਮ ਨੂੰ ਮਿਟਾਉਣ ਲਈ ਹੇਠ ਲਿਖੀਆਂ ਕਮਾਂਡਾਂ ਦੀ ਵਰਤੋਂ ਕਰ ਸਕਦੇ ਹੋ।

$> chameleon drop_source --config default --source mysql --debug
$> chameleon drop_replica_schema --config default --source mysql --debug

pg_chameleon ਦੇ ਫਾਇਦੇ

ਆਸਾਨ ਸੈੱਟਅੱਪ ਅਤੇ ਸੰਰਚਨਾ.
ਸਪਸ਼ਟ ਗਲਤੀ ਸੁਨੇਹਿਆਂ ਨਾਲ ਅਸਾਨੀ ਨਾਲ ਸਮੱਸਿਆ ਦਾ ਨਿਪਟਾਰਾ ਕਰੋ ਅਤੇ ਅਸੰਗਤੀਆਂ ਦੀ ਪਛਾਣ ਕਰੋ।
ਬਾਕੀ ਸੰਰਚਨਾ ਨੂੰ ਬਦਲੇ ਬਿਨਾਂ ਸ਼ੁਰੂਆਤੀਕਰਣ ਤੋਂ ਬਾਅਦ ਵਾਧੂ ਵਿਸ਼ੇਸ਼ ਟੇਬਲਾਂ ਨੂੰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਵਿੱਚ ਜੋੜਿਆ ਜਾ ਸਕਦਾ ਹੈ।
ਇੱਕ ਸਿੰਗਲ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਲਈ ਮਲਟੀਪਲ ਸਰੋਤ ਡੇਟਾਬੇਸ ਨੂੰ ਕੌਂਫਿਗਰ ਕਰਨਾ ਸੰਭਵ ਹੈ, ਅਤੇ ਇਹ ਬਹੁਤ ਲਾਭਦਾਇਕ ਹੈ ਜੇਕਰ ਤੁਸੀਂ ਇੱਕ ਜਾਂ ਇੱਕ ਤੋਂ ਵੱਧ MySQL ਡੇਟਾਬੇਸ ਦੇ ਡੇਟਾ ਨੂੰ ਇੱਕ ਸਿੰਗਲ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਜੋੜ ਰਹੇ ਹੋ।
ਤੁਹਾਨੂੰ ਚੁਣੀਆਂ ਗਈਆਂ ਟੇਬਲਾਂ ਨੂੰ ਦੁਹਰਾਉਣ ਦੀ ਲੋੜ ਨਹੀਂ ਹੈ।

pg_chameleon ਦੇ ਨੁਕਸਾਨ

ਸਿਰਫ਼ MySQL 5.5 ਅਤੇ ਇਸਤੋਂ ਉੱਪਰ ਸਰੋਤ ਵਜੋਂ ਅਤੇ PostgreSQL 9.5 ਅਤੇ ਇਸ ਤੋਂ ਉੱਪਰ ਦੇ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਵਜੋਂ ਸਮਰਥਿਤ ਹੈ।
ਹਰੇਕ ਸਾਰਣੀ ਵਿੱਚ ਇੱਕ ਪ੍ਰਾਇਮਰੀ ਜਾਂ ਵਿਲੱਖਣ ਕੁੰਜੀ ਹੋਣੀ ਚਾਹੀਦੀ ਹੈ, ਨਹੀਂ ਤਾਂ ਟੇਬਲਾਂ ਨੂੰ init_replica ਪ੍ਰਕਿਰਿਆ ਦੌਰਾਨ ਸ਼ੁਰੂ ਕੀਤਾ ਜਾਂਦਾ ਹੈ ਪਰ ਦੁਹਰਾਇਆ ਨਹੀਂ ਜਾਂਦਾ ਹੈ।
ਵਨ-ਵੇ ਰਿਪਲੀਕੇਸ਼ਨ - ਸਿਰਫ਼ MySQL ਤੋਂ PostgreSQL ਤੱਕ। ਇਸਲਈ, ਇਹ ਸਿਰਫ "ਐਕਟਿਵ-ਪੈਸਿਵ" ਸਰਕਟ ਲਈ ਢੁਕਵਾਂ ਹੈ।
ਸਰੋਤ ਸਿਰਫ ਇੱਕ MySQL ਡੇਟਾਬੇਸ ਹੋ ਸਕਦਾ ਹੈ, ਅਤੇ ਇੱਕ ਸਰੋਤ ਵਜੋਂ PostgreSQL ਡੇਟਾਬੇਸ ਲਈ ਸਮਰਥਨ ਕੇਵਲ ਪ੍ਰਯੋਗਾਤਮਕ ਅਤੇ ਸੀਮਾਵਾਂ ਦੇ ਨਾਲ ਹੈ (ਹੋਰ ਜਾਣੋ ਇੱਥੇ)

pg_chameleon ਲਈ ਨਤੀਜੇ

MySQL ਤੋਂ PostgreSQL ਵਿੱਚ ਡੇਟਾਬੇਸ ਨੂੰ ਮਾਈਗਰੇਟ ਕਰਨ ਲਈ pg_chameleon ਵਿੱਚ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਵਿਧੀ ਬਹੁਤ ਵਧੀਆ ਹੈ। ਮਹੱਤਵਪੂਰਨ ਨਨੁਕਸਾਨ ਇਹ ਹੈ ਕਿ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਕੇਵਲ ਇੱਕ-ਤਰਫ਼ਾ ਹੈ, ਇਸਲਈ ਡਾਟਾਬੇਸ ਪੇਸ਼ੇਵਰ ਇਸ ਨੂੰ ਮਾਈਗਰੇਸ਼ਨ ਤੋਂ ਇਲਾਵਾ ਕਿਸੇ ਹੋਰ ਚੀਜ਼ ਲਈ ਵਰਤਣਾ ਚਾਹੁੰਦੇ ਹਨ। ਪਰ ਇੱਕ ਤਰਫਾ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦੀ ਸਮੱਸਿਆ ਨੂੰ ਇੱਕ ਹੋਰ ਓਪਨ ਸੋਰਸ ਟੂਲ - ਸਿਮਟ੍ਰਿਕਡੀਐਸ ਨਾਲ ਹੱਲ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ.

ਅਧਿਕਾਰਤ ਦਸਤਾਵੇਜ਼ਾਂ ਵਿੱਚ ਹੋਰ ਪੜ੍ਹੋ ਇੱਥੇ. ਕਮਾਂਡ ਲਾਈਨ ਮਦਦ ਮਿਲ ਸਕਦੀ ਹੈ ਇੱਥੇ.

SymmetricDS ਦੀ ਸੰਖੇਪ ਜਾਣਕਾਰੀ

SymmetricDS ਇੱਕ ਓਪਨ ਸੋਰਸ ਟੂਲ ਹੈ ਜੋ ਕਿਸੇ ਵੀ ਡਾਟਾਬੇਸ ਨੂੰ ਕਿਸੇ ਹੋਰ ਆਮ ਡੇਟਾਬੇਸ ਵਿੱਚ ਨਕਲ ਕਰਦਾ ਹੈ: Oracle, MongoDB, PostgreSQL, MySQL, SQL ਸਰਵਰ, MariaDB, DB2, Sybase, Greenplum, Informix, H2, Firebird ਅਤੇ ਹੋਰ ਕਲਾਉਡ ਡਾਟਾਬੇਸ ਉਦਾਹਰਣਾਂ, ਜਿਵੇਂ ਕਿ Redshift, ਅਜ਼ੂਰ, ਆਦਿ ਉਪਲਬਧ ਵਿਸ਼ੇਸ਼ਤਾਵਾਂ: ਡੇਟਾਬੇਸ ਅਤੇ ਫਾਈਲ ਸਿੰਕ੍ਰੋਨਾਈਜ਼ੇਸ਼ਨ, ਮਲਟੀ-ਮਾਸਟਰ ਡੇਟਾਬੇਸ ਰੀਪਲੀਕੇਸ਼ਨ, ਫਿਲਟਰਡ ਸਿੰਕ੍ਰੋਨਾਈਜ਼ੇਸ਼ਨ, ਟ੍ਰਾਂਸਫਾਰਮੇਸ਼ਨ ਅਤੇ ਹੋਰ। ਇਹ ਇੱਕ Java ਟੂਲ ਹੈ ਅਤੇ ਇਸ ਲਈ JRE ਜਾਂ JDK (ਵਰਜਨ 8.0 ਜਾਂ ਉੱਚਾ) ਦੀ ਇੱਕ ਮਿਆਰੀ ਰੀਲੀਜ਼ ਦੀ ਲੋੜ ਹੈ। ਇੱਥੇ, ਸਰੋਤ ਡੇਟਾਬੇਸ ਵਿੱਚ ਟਰਿਗਰਾਂ ਵਿੱਚ ਡੇਟਾ ਤਬਦੀਲੀਆਂ ਨੂੰ ਰਿਕਾਰਡ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ ਅਤੇ ਬੈਚਾਂ ਦੇ ਰੂਪ ਵਿੱਚ ਉਚਿਤ ਟਾਰਗੇਟ ਡੇਟਾਬੇਸ ਨੂੰ ਭੇਜਿਆ ਜਾ ਸਕਦਾ ਹੈ।

SymmetricDS ਵਿਸ਼ੇਸ਼ਤਾਵਾਂ

ਟੂਲ ਪਲੇਟਫਾਰਮ ਸੁਤੰਤਰ ਹੈ, ਮਤਲਬ ਕਿ ਦੋ ਜਾਂ ਦੋ ਤੋਂ ਵੱਧ ਵੱਖ-ਵੱਖ ਡੇਟਾਬੇਸ ਡੇਟਾ ਦਾ ਆਦਾਨ-ਪ੍ਰਦਾਨ ਕਰ ਸਕਦੇ ਹਨ।
ਰਿਲੇਸ਼ਨਲ ਡੇਟਾਬੇਸ ਡੇਟਾ ਪਰਿਵਰਤਨ ਰਿਕਾਰਡਾਂ ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਸਮਕਾਲੀ ਕੀਤੇ ਜਾਂਦੇ ਹਨ, ਜਦੋਂ ਕਿ ਫਾਈਲ ਸਿਸਟਮ-ਅਧਾਰਿਤ ਡੇਟਾਬੇਸ ਫਾਈਲ ਸਿੰਕ੍ਰੋਨਾਈਜ਼ੇਸ਼ਨ ਦੀ ਵਰਤੋਂ ਕਰਦੇ ਹਨ।
ਨਿਯਮਾਂ ਦੇ ਇੱਕ ਸੈੱਟ ਦੇ ਆਧਾਰ 'ਤੇ ਪੁਸ਼ ਅਤੇ ਪੁੱਲ ਵਿਧੀਆਂ ਦੀ ਵਰਤੋਂ ਕਰਦੇ ਹੋਏ ਦੋ-ਪੱਖੀ ਪ੍ਰਤੀਕ੍ਰਿਤੀ।
ਸੁਰੱਖਿਅਤ ਅਤੇ ਘੱਟ-ਬੈਂਡਵਿਡਥ ਨੈੱਟਵਰਕਾਂ 'ਤੇ ਡਾਟਾ ਟ੍ਰਾਂਸਫਰ ਸੰਭਵ ਹੈ।
ਆਟੋਮੈਟਿਕ ਰਿਕਵਰੀ ਜਦੋਂ ਨੋਡ ਇੱਕ ਅਸਫਲਤਾ ਅਤੇ ਆਟੋਮੈਟਿਕ ਅਪਵਾਦ ਰੈਜ਼ੋਲੂਸ਼ਨ ਤੋਂ ਬਾਅਦ ਓਪਰੇਸ਼ਨ ਮੁੜ ਸ਼ੁਰੂ ਕਰਦੇ ਹਨ।
ਕਲਾਉਡ ਅਨੁਕੂਲ ਅਤੇ ਸ਼ਕਤੀਸ਼ਾਲੀ ਐਕਸਟੈਂਸ਼ਨ APIs।

ਉਦਾਹਰਨ:

SymmetricDS ਨੂੰ ਦੋ ਵਿਕਲਪਾਂ ਵਿੱਚੋਂ ਇੱਕ ਵਿੱਚ ਸੰਰਚਿਤ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ:
ਇੱਕ ਮਾਸਟਰ (ਮਾਤਾ) ਨੋਡ ਜੋ ਦੋ ਸਲੇਵ (ਬੱਚੇ) ਨੋਡਾਂ ਵਿਚਕਾਰ ਡਾਟਾ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦਾ ਕੇਂਦਰੀ ਤੌਰ 'ਤੇ ਤਾਲਮੇਲ ਕਰਦਾ ਹੈ, ਅਤੇ ਚਾਈਲਡ ਨੋਡਾਂ ਵਿਚਕਾਰ ਸੰਚਾਰ ਸਿਰਫ ਮਾਤਾ-ਪਿਤਾ ਦੁਆਰਾ ਹੁੰਦਾ ਹੈ।
ਇੱਕ ਸਰਗਰਮ ਨੋਡ (ਨੋਡ 1) ਕਿਸੇ ਵਿਚੋਲੇ ਤੋਂ ਬਿਨਾਂ ਕਿਸੇ ਹੋਰ ਸਰਗਰਮ ਨੋਡ (ਨੋਡ 2) ਨਾਲ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਲਈ ਸੰਚਾਰ ਕਰ ਸਕਦਾ ਹੈ।

ਦੋਵਾਂ ਵਿਕਲਪਾਂ ਵਿੱਚ, ਪੁਸ਼ ਅਤੇ ਪੁੱਲ ਦੀ ਵਰਤੋਂ ਕਰਕੇ ਡੇਟਾ ਐਕਸਚੇਂਜ ਹੁੰਦਾ ਹੈ। ਇਸ ਉਦਾਹਰਨ ਵਿੱਚ ਅਸੀਂ ਇੱਕ ਸਰਗਰਮ-ਸਰਗਰਮ ਸੰਰਚਨਾ 'ਤੇ ਵਿਚਾਰ ਕਰਾਂਗੇ। ਪੂਰੇ ਆਰਕੀਟੈਕਚਰ ਦਾ ਵਰਣਨ ਕਰਨ ਵਿੱਚ ਬਹੁਤ ਸਮਾਂ ਲੱਗੇਗਾ, ਇਸ ਲਈ ਆਪਣੀ ਖੋਜ ਕਰੋ। ਅਗਵਾਈSymmetricDS ਡਿਵਾਈਸ ਬਾਰੇ ਹੋਰ ਜਾਣਨ ਲਈ।

ਸਿਮਟ੍ਰਿਕਡੀਐਸ ਨੂੰ ਸਥਾਪਿਤ ਕਰਨਾ ਬਹੁਤ ਸੌਖਾ ਹੈ: ਜ਼ਿਪ ਫਾਈਲ ਦਾ ਓਪਨ ਸੋਰਸ ਸੰਸਕਰਣ ਡਾਉਨਲੋਡ ਕਰੋ ਇੱਥੋਂ ਅਤੇ ਇਸ ਨੂੰ ਬਾਹਰ ਲੈ ਜਾਓ ਜਿੱਥੇ ਤੁਸੀਂ ਚਾਹੁੰਦੇ ਹੋ। ਹੇਠਾਂ ਦਿੱਤੀ ਸਾਰਣੀ ਇਸ ਉਦਾਹਰਨ ਵਿੱਚ SymmetricDS ਦੇ ਇੰਸਟਾਲੇਸ਼ਨ ਟਿਕਾਣੇ ਅਤੇ ਵਰਜਨ ਬਾਰੇ ਜਾਣਕਾਰੀ ਦਿੰਦੀ ਹੈ, ਨਾਲ ਹੀ ਡਾਟਾਬੇਸ ਵਰਜਨ, ਲੀਨਕਸ ਵਰਜਨ, IP ਐਡਰੈੱਸ, ਅਤੇ ਦੋਨੋ ਨੋਡਾਂ ਲਈ ਪੋਰਟਾਂ।

ਹੋਸਟ
ਵੀਐਮ 1
ਵੀਐਮ 2

OS ਸੰਸਕਰਣ
CentOS Linux 7.6 x86_64
CentOS Linux 7.6 x86_64

DB ਸਰਵਰ ਸੰਸਕਰਣ
MySQL 5.7.26
PostgreSQL 10.5

DB ਪੋਰਟ
3306
5832

IP ਐਡਰੈੱਸ
192.168.1.107
192.168.1.112

SymmetricDS ਸੰਸਕਰਣ
ਸਿਮਟ੍ਰਿਕਡੀਐਸ 3.9
ਸਿਮਟ੍ਰਿਕਡੀਐਸ 3.9

SymmetricDS ਇੰਸਟਾਲੇਸ਼ਨ ਮਾਰਗ
/usr/local/symmetric-server-3.9.20
/usr/local/symmetric-server-3.9.20

SymmetricDS ਨੋਡ ਨਾਮ
ਕਾਰਪੋਰੇਸ਼ਨ-000
ਸਟੋਰ-001

ਇੱਥੇ ਅਸੀਂ /usr/local/symmetric-server-3.9.20 ਵਿੱਚ SymmetricDS ਇੰਸਟਾਲ ਕਰਦੇ ਹਾਂ, ਅਤੇ ਵੱਖ-ਵੱਖ ਸਬ-ਡਾਇਰੈਕਟਰੀਆਂ ਅਤੇ ਫਾਈਲਾਂ ਉੱਥੇ ਸਟੋਰ ਕੀਤੀਆਂ ਜਾਣਗੀਆਂ। ਅਸੀਂ ਨਮੂਨੇ ਅਤੇ ਇੰਜਣ ਉਪ-ਡਾਇਰੈਕਟਰੀਆਂ ਵਿੱਚ ਦਿਲਚਸਪੀ ਰੱਖਦੇ ਹਾਂ. ਨਮੂਨਾ ਡਾਇਰੈਕਟਰੀ ਵਿੱਚ ਨੋਡ ਵਿਸ਼ੇਸ਼ਤਾਵਾਂ ਦੇ ਨਾਲ ਉਦਾਹਰਨ ਸੰਰਚਨਾ ਫਾਈਲਾਂ ਸ਼ਾਮਲ ਹਨ, ਨਾਲ ਹੀ ਤੁਹਾਨੂੰ ਜਲਦੀ ਸ਼ੁਰੂ ਕਰਨ ਲਈ SQL ਸਕ੍ਰਿਪਟਾਂ ਦੀ ਉਦਾਹਰਨ ਹੈ।

ਸੈਂਪਲ ਡਾਇਰੈਕਟਰੀ ਵਿੱਚ ਅਸੀਂ ਨੋਡ ਵਿਸ਼ੇਸ਼ਤਾਵਾਂ ਵਾਲੀਆਂ ਤਿੰਨ ਸੰਰਚਨਾ ਫਾਈਲਾਂ ਵੇਖਦੇ ਹਾਂ - ਨਾਮ ਇੱਕ ਖਾਸ ਸਕੀਮ ਵਿੱਚ ਨੋਡ ਦੀ ਪ੍ਰਕਿਰਤੀ ਨੂੰ ਦਰਸਾਉਂਦਾ ਹੈ।

corp-000.properties
store-001.properties
store-002.properties

ਸਿਮਟ੍ਰਿਕਡੀਐਸ ਕੋਲ ਬੁਨਿਆਦੀ 3-ਨੋਡ ਡਿਜ਼ਾਈਨ (ਵਿਕਲਪ 1) ਲਈ ਸਾਰੀਆਂ ਲੋੜੀਂਦੀਆਂ ਸੰਰਚਨਾ ਫਾਈਲਾਂ ਹਨ, ਅਤੇ ਉਹੀ ਫਾਈਲਾਂ 2-ਨੋਡ ਡਿਜ਼ਾਈਨ (ਵਿਕਲਪ 2) ਲਈ ਵਰਤੀਆਂ ਜਾ ਸਕਦੀਆਂ ਹਨ। ਸੈਂਪਲ ਡਾਇਰੈਕਟਰੀ ਤੋਂ vm1 ਹੋਸਟ 'ਤੇ ਇੰਜਣਾਂ ਲਈ ਲੋੜੀਂਦੀ ਸੰਰਚਨਾ ਫਾਈਲ ਦੀ ਨਕਲ ਕਰੋ। ਇਹ ਇਸ ਤਰ੍ਹਾਂ ਨਿਕਲਦਾ ਹੈ:

$> cat engines/corp-000.properties
engine.name=corp-000
db.driver=com.mysql.jdbc.Driver
db.url=jdbc:mysql://192.168.1.107:3306/replica_db?autoReconnect=true&useSSL=false
db.user=root
db.password=admin123
registration.url=
sync.url=http://192.168.1.107:31415/sync/corp-000
group.id=corp
external.id=000

SymmetricDS ਸੰਰਚਨਾ ਵਿੱਚ ਇਸ ਨੋਡ ਨੂੰ corp-000 ਕਿਹਾ ਜਾਂਦਾ ਹੈ, ਅਤੇ ਡੇਟਾਬੇਸ ਕਨੈਕਸ਼ਨ ਨੂੰ mysql jdbc ਡਰਾਈਵਰ ਦੁਆਰਾ ਹੈਂਡਲ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਜੋ ਉੱਪਰ ਦਿੱਤੀ ਕਨੈਕਸ਼ਨ ਸਤਰ ਅਤੇ ਲੌਗਇਨ ਪ੍ਰਮਾਣ ਪੱਤਰਾਂ ਦੀ ਵਰਤੋਂ ਕਰਦਾ ਹੈ। ਅਸੀਂ replica_db ਡੇਟਾਬੇਸ ਨਾਲ ਜੁੜਦੇ ਹਾਂ ਅਤੇ ਸਕੀਮਾ ਬਣਾਉਣ ਦੌਰਾਨ ਟੇਬਲ ਬਣਾਏ ਜਾਣਗੇ। sync.url ਦਿਖਾਉਂਦਾ ਹੈ ਕਿ ਸਮਕਾਲੀਕਰਨ ਲਈ ਨੋਡ ਨਾਲ ਕਿੱਥੇ ਸੰਪਰਕ ਕਰਨਾ ਹੈ।

ਹੋਸਟ vm2 'ਤੇ ਨੋਡ 2 ਨੂੰ ਸਟੋਰ-001 ਦੇ ਤੌਰ 'ਤੇ ਸੰਰਚਿਤ ਕੀਤਾ ਗਿਆ ਹੈ ਅਤੇ ਬਾਕੀ ਨੂੰ ਹੇਠਾਂ node.properties ਫਾਈਲ ਵਿੱਚ ਦਿੱਤਾ ਗਿਆ ਹੈ। ਨੋਡ ਸਟੋਰ-001 PostgreSQL ਡੇਟਾਬੇਸ ਨੂੰ ਚਲਾਉਂਦਾ ਹੈ ਅਤੇ pgdb_replica ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਡੇਟਾਬੇਸ ਹੈ। registration.url ਹੋਸਟ vm2 ਨੂੰ ਹੋਸਟ vm1 ਨਾਲ ਸੰਪਰਕ ਕਰਨ ਅਤੇ ਇਸ ਤੋਂ ਕੌਂਫਿਗਰੇਸ਼ਨ ਵੇਰਵੇ ਪ੍ਰਾਪਤ ਕਰਨ ਦੀ ਇਜਾਜ਼ਤ ਦਿੰਦਾ ਹੈ।

$> cat engines/store-001.properties
engine.name=store-001
db.driver=org.postgresql.Driver
db.url=jdbc:postgresql://192.168.1.112:5832/pgdb_replica
db.user=postgres
db.password=admin123
registration.url=http://192.168.1.107:31415/sync/corp-000
group.id=store
external.id=001

ਮੁਕੰਮਲ ਹੋਈ SymmetricDS ਉਦਾਹਰਨ ਵਿੱਚ ਦੋ ਡਾਟਾਬੇਸ ਸਰਵਰਾਂ (ਦੋ ਨੋਡਾਂ) ਵਿਚਕਾਰ ਦੋ-ਪੱਖੀ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਥਾਪਤ ਕਰਨ ਲਈ ਮਾਪਦੰਡ ਸ਼ਾਮਲ ਹਨ। ਹੇਠਾਂ ਦਿੱਤੇ ਕਦਮ ਹੋਸਟ vm1 (corp-000) 'ਤੇ ਕੀਤੇ ਗਏ ਹਨ, ਜੋ 4 ਟੇਬਲਾਂ ਨਾਲ ਇੱਕ ਉਦਾਹਰਨ ਸਕੀਮਾ ਬਣਾਏਗਾ। ਫਿਰ symadmin ਕਮਾਂਡ ਨਾਲ create-sym-tables ਨੂੰ ਚਲਾਉਣਾ ਡਾਇਰੈਕਟਰੀ ਟੇਬਲ ਬਣਾਉਂਦਾ ਹੈ ਜਿੱਥੇ ਨੋਡਾਂ ਵਿਚਕਾਰ ਨਕਲ ਦੇ ਨਿਯਮ ਅਤੇ ਦਿਸ਼ਾ ਸਟੋਰ ਕੀਤੀ ਜਾਵੇਗੀ। ਅੰਤ ਵਿੱਚ, ਨਮੂਨਾ ਡੇਟਾ ਟੇਬਲ ਵਿੱਚ ਲੋਡ ਕੀਤਾ ਜਾਂਦਾ ਹੈ।

vm1$> cd /usr/local/symmetric-server-3.9.20/bin
vm1$> ./dbimport --engine corp-000 --format XML create_sample.xml
vm1$> ./symadmin --engine corp-000 create-sym-tables
vm1$> ./dbimport --engine corp-000 insert_sample.sql

ਉਦਾਹਰਨ ਵਿੱਚ, ਆਈਟਮ ਅਤੇ ਆਈਟਮ_ਸੇਲਿੰਗ_ਕੀਮਤ ਟੇਬਲਾਂ ਨੂੰ ਕਾਰਪੋਰੇਸ਼ਨ-000 ਤੋਂ ਸਟੋਰ-001 ਤੱਕ ਦੁਹਰਾਉਣ ਲਈ ਸਵੈਚਲਿਤ ਤੌਰ 'ਤੇ ਕੌਂਫਿਗਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਅਤੇ ਸੇਲ ਟੇਬਲ (ਵਿਕਰੀ_ਟ੍ਰਾਂਜੈਕਸ਼ਨ ਅਤੇ ਸੇਲ_ਰਿਟਰਨ_ਲਾਈਨ_ਆਈਟਮ) ਸਟੋਰ-001 ਤੋਂ ਕਾਰਪੋਰੇਸ਼ਨ-000 ਤੱਕ ਦੁਹਰਾਉਣ ਲਈ ਸਵੈਚਲਿਤ ਤੌਰ 'ਤੇ ਕੌਂਫਿਗਰ ਕੀਤੀਆਂ ਜਾਂਦੀਆਂ ਹਨ। ਹੁਣ ਅਸੀਂ ਹੋਸਟ vm2 (store-001) ਉੱਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਇੱਕ ਸਕੀਮਾ ਬਣਾਉਂਦੇ ਹਾਂ ਤਾਂ ਜੋ ਇਸਨੂੰ corp-000 ਤੋਂ ਡਾਟਾ ਪ੍ਰਾਪਤ ਕਰਨ ਲਈ ਤਿਆਰ ਕੀਤਾ ਜਾ ਸਕੇ।

vm2$> cd /usr/local/symmetric-server-3.9.20/bin
vm2$> ./dbimport --engine store-001 --format XML create_sample.xml

ਇਹ ਜਾਂਚ ਕਰਨਾ ਯਕੀਨੀ ਬਣਾਓ ਕਿ vm1 'ਤੇ MySQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਉਦਾਹਰਨ ਟੇਬਲ ਅਤੇ SymmetricDS ਕੈਟਾਲਾਗ ਟੇਬਲ ਹਨ। ਨੋਟ ਕਰੋ ਕਿ SymmetricDS ਸਿਸਟਮ ਟੇਬਲ (sym_ ਨਾਲ ਪ੍ਰੀਫਿਕਸਡ) ਵਰਤਮਾਨ ਵਿੱਚ ਸਿਰਫ ਨੋਡ corp-000 'ਤੇ ਉਪਲਬਧ ਹਨ ਕਿਉਂਕਿ ਇਹ ਉਹ ਥਾਂ ਹੈ ਜਿੱਥੇ ਅਸੀਂ create-sym-tables ਕਮਾਂਡ ਚਲਾਉਂਦੇ ਹਾਂ ਅਤੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦਾ ਪ੍ਰਬੰਧਨ ਕਰਾਂਗੇ। ਅਤੇ ਨੋਡ ਸਟੋਰ-001 ਦੇ ਡੇਟਾਬੇਸ ਵਿੱਚ ਡੇਟਾ ਤੋਂ ਬਿਨਾਂ ਸਿਰਫ 4 ਉਦਾਹਰਣ ਟੇਬਲ ਹੋਣਗੇ।

ਸਾਰੇ। ਵਾਤਾਵਰਣ ਦੋਵਾਂ ਨੋਡਾਂ 'ਤੇ ਸਿਮ ਸਰਵਰ ਪ੍ਰਕਿਰਿਆਵਾਂ ਨੂੰ ਚਲਾਉਣ ਲਈ ਤਿਆਰ ਹੈ ਜਿਵੇਂ ਕਿ ਹੇਠਾਂ ਦਿਖਾਇਆ ਗਿਆ ਹੈ।

vm1$> cd /usr/local/symmetric-server-3.9.20/bin
vm1$> sym 2>&1 &

ਲੌਗ ਐਂਟਰੀਆਂ ਨੂੰ ਡਾਇਰੈਕਟਰੀ ਵਿੱਚ ਲੌਗ ਫੋਲਡਰ ਵਿੱਚ ਇੱਕ ਬੈਕਗ੍ਰਾਉਂਡ ਲੌਗ ਫਾਈਲ (symmetric.log) ਵਿੱਚ ਭੇਜਿਆ ਜਾਂਦਾ ਹੈ ਜਿੱਥੇ SymmetricDS ਇੰਸਟਾਲ ਹੈ, ਅਤੇ ਨਾਲ ਹੀ ਮਿਆਰੀ ਆਉਟਪੁੱਟ ਨੂੰ ਵੀ। ਸਿਮ ਸਰਵਰ ਨੂੰ ਹੁਣ ਨੋਡ ਸਟੋਰ-001 'ਤੇ ਸ਼ੁਰੂ ਕੀਤਾ ਜਾ ਸਕਦਾ ਹੈ।

vm2$> cd /usr/local/symmetric-server-3.9.20/bin
vm2$> sym 2>&1 &

ਜੇਕਰ ਤੁਸੀਂ vm2 ਹੋਸਟ 'ਤੇ ਸਿਮ ਸਰਵਰ ਪ੍ਰਕਿਰਿਆ ਚਲਾਉਂਦੇ ਹੋ, ਤਾਂ ਇਹ PostgreSQL ਡਾਟਾਬੇਸ ਵਿੱਚ SymmetricDS ਕੈਟਾਲਾਗ ਟੇਬਲ ਵੀ ਬਣਾਏਗਾ। ਜੇ ਤੁਸੀਂ ਦੋਵਾਂ ਨੋਡਾਂ 'ਤੇ ਸਿਮ ਸਰਵਰ ਪ੍ਰਕਿਰਿਆ ਨੂੰ ਚਲਾਉਂਦੇ ਹੋ, ਤਾਂ ਉਹ ਕਾਰਪ-000 ਤੋਂ ਸਟੋਰ-001 ਤੱਕ ਡੇਟਾ ਨੂੰ ਦੁਹਰਾਉਣ ਲਈ ਇੱਕ ਦੂਜੇ ਨਾਲ ਤਾਲਮੇਲ ਕਰਦੇ ਹਨ। ਜੇਕਰ ਕੁਝ ਸਕਿੰਟਾਂ ਬਾਅਦ ਅਸੀਂ ਦੋਵਾਂ ਪਾਸਿਆਂ ਦੀਆਂ ਸਾਰੀਆਂ 4 ਟੇਬਲਾਂ ਦੀ ਪੁੱਛਗਿੱਛ ਕਰਦੇ ਹਾਂ, ਤਾਂ ਅਸੀਂ ਦੇਖਾਂਗੇ ਕਿ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਫਲ ਸੀ। ਜਾਂ ਤੁਸੀਂ ਹੇਠਲੀ ਕਮਾਂਡ ਨਾਲ corp-001 ਤੋਂ ਨੋਡ ਸਟੋਰ-000 ਨੂੰ ਬੂਟਸਟਰੈਪ ਭੇਜ ਸਕਦੇ ਹੋ।

vm1$> ./symadmin --engine corp-000 reload-node 001

ਇਸ ਬਿੰਦੂ 'ਤੇ, ਨੋਡ ਕਾਰਪ-000 (ਹੋਸਟ: vm1) 'ਤੇ MySQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਆਈਟਮ ਸਾਰਣੀ ਵਿੱਚ ਇੱਕ ਨਵਾਂ ਰਿਕਾਰਡ ਸ਼ਾਮਲ ਕੀਤਾ ਗਿਆ ਹੈ, ਅਤੇ ਤੁਸੀਂ ਨੋਡ ਸਟੋਰ-001 (ਹੋਸਟ: vm2) 'ਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਵਿੱਚ ਇਸਦੀ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦੀ ਜਾਂਚ ਕਰ ਸਕਦੇ ਹੋ। ਅਸੀਂ ਡੇਟਾ ਨੂੰ corp-000 ਤੋਂ ਸਟੋਰ-001 ਵਿੱਚ ਲਿਜਾਣ ਲਈ ਇੱਕ ਪੁੱਲ ਓਪਰੇਸ਼ਨ ਦੇਖਦੇ ਹਾਂ।

mysql> insert into item values ('22000002','Jelly Bean');
Query OK, 1 row affected (0.00 sec)

vm2$> psql -p 5832 -U postgres pgdb_replica -c "select * from item"
 item_id  |   name
----------+-----------
 11000001 | Yummy Gum
 22000002 | Jelly Bean
(2 rows)

ਸਟੋਰ-001 ਤੋਂ ਕਾਰਪੋਰੇਸ਼ਨ-000 ਵਿੱਚ ਡੇਟਾ ਨੂੰ ਲਿਜਾਣ ਲਈ ਪੁਸ਼ ਓਪਰੇਸ਼ਨ ਕਰਨ ਲਈ, ਅਸੀਂ sale_transaction ਸਾਰਣੀ ਵਿੱਚ ਇੱਕ ਰਿਕਾਰਡ ਸ਼ਾਮਲ ਕਰਦੇ ਹਾਂ ਅਤੇ ਪੁਸ਼ਟੀ ਕਰਦੇ ਹਾਂ ਕਿ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਫਲ ਹੈ।

ਨਤੀਜਾ

ਅਸੀਂ MySQL ਅਤੇ PostgreSQL ਡੇਟਾਬੇਸ ਦੇ ਵਿਚਕਾਰ ਉਦਾਹਰਨ ਟੇਬਲ ਦੀ ਦੋ-ਤਰੀਕੇ ਨਾਲ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦਾ ਸਫਲ ਸੈੱਟਅੱਪ ਦੇਖਦੇ ਹਾਂ। ਨਵੇਂ ਉਪਭੋਗਤਾ ਟੇਬਲ ਲਈ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਥਾਪਤ ਕਰਨ ਲਈ, ਇਹਨਾਂ ਕਦਮਾਂ ਦੀ ਪਾਲਣਾ ਕਰੋ: ਅਸੀਂ ਉਦਾਹਰਨ ਲਈ ਟੇਬਲ t1 ਬਣਾਉਂਦੇ ਹਾਂ ਅਤੇ ਇਸਦੇ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਨਿਯਮਾਂ ਨੂੰ ਹੇਠਾਂ ਦਿੱਤੇ ਅਨੁਸਾਰ ਸੰਰਚਿਤ ਕਰਦੇ ਹਾਂ। ਇਸ ਤਰ੍ਹਾਂ ਅਸੀਂ corp-000 ਤੋਂ ਸਟੋਰ-001 ਤੱਕ ਸਿਰਫ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਨੂੰ ਕੌਂਫਿਗਰ ਕਰਦੇ ਹਾਂ।

mysql> create table  t1 (no integer);
Query OK, 0 rows affected (0.01 sec)

mysql> insert into sym_channel (channel_id,create_time,last_update_time) 
values ('t1',current_timestamp,current_timestamp);
Query OK, 1 row affected (0.01 sec)

mysql> insert into sym_trigger (trigger_id, source_table_name,channel_id,
last_update_time, create_time) values ('t1', 't1', 't1', current_timestamp,
current_timestamp);
Query OK, 1 row affected (0.01 sec)

mysql> insert into sym_trigger_router (trigger_id, router_id,
Initial_load_order, create_time,last_update_time) values ('t1',
'corp-2-store-1', 1, current_timestamp,current_timestamp);
Query OK, 1 row affected (0.01 sec)

ਕੌਂਫਿਗਰੇਸ਼ਨ ਨੂੰ ਫਿਰ ਸਕੀਮਾ ਤਬਦੀਲੀ ਬਾਰੇ ਸੂਚਿਤ ਕੀਤਾ ਜਾਂਦਾ ਹੈ, ਯਾਨੀ, ਇੱਕ ਨਵੀਂ ਸਾਰਣੀ ਨੂੰ ਜੋੜਨਾ, ਸਿੰਕ-ਟ੍ਰਿਗਰ ਆਰਗੂਮੈਂਟ ਦੇ ਨਾਲ symadmin ਕਮਾਂਡ ਦੀ ਵਰਤੋਂ ਕਰਦੇ ਹੋਏ, ਜੋ ਟੇਬਲ ਪਰਿਭਾਸ਼ਾਵਾਂ ਨੂੰ ਮੈਪ ਕਰਨ ਲਈ ਟਰਿਗਰਾਂ ਨੂੰ ਦੁਬਾਰਾ ਬਣਾਉਂਦਾ ਹੈ। send-schema ਨੂੰ ਨੋਡ ਸਟੋਰ-001 ਵਿੱਚ ਸਕੀਮਾ ਤਬਦੀਲੀਆਂ ਭੇਜਣ ਲਈ ਚਲਾਇਆ ਜਾਂਦਾ ਹੈ, ਅਤੇ ਟੇਬਲ t1 ਦੀ ਨਕਲ ਨੂੰ ਕੌਂਫਿਗਰ ਕੀਤਾ ਜਾਂਦਾ ਹੈ।

vm1$> ./symadmin -e corp-000 --node=001 sync-triggers    
vm1$> ./symadmin send-schema -e corp-000 --node=001 t1

SymmetricDS ਦੇ ਲਾਭ

ਆਸਾਨ ਸਥਾਪਨਾ ਅਤੇ ਸੰਰਚਨਾ, ਤਿੰਨ-ਨੋਡ ਜਾਂ ਦੋ-ਨੋਡ ਸਰਕਟ ਬਣਾਉਣ ਲਈ ਮਾਪਦੰਡਾਂ ਵਾਲੀਆਂ ਫਾਈਲਾਂ ਦਾ ਇੱਕ ਤਿਆਰ-ਬਣਾਇਆ ਸੈੱਟ ਵੀ ਸ਼ਾਮਲ ਹੈ।
ਕਰਾਸ-ਪਲੇਟਫਾਰਮ ਡੇਟਾਬੇਸ ਅਤੇ ਪਲੇਟਫਾਰਮ ਦੀ ਸੁਤੰਤਰਤਾ, ਸਰਵਰ, ਲੈਪਟਾਪ ਅਤੇ ਮੋਬਾਈਲ ਡਿਵਾਈਸਾਂ ਸਮੇਤ।
ਕਿਸੇ ਵੀ ਡੇਟਾਬੇਸ ਨੂੰ ਸਥਾਨਕ ਤੌਰ 'ਤੇ, WAN ਜਾਂ ਕਲਾਉਡ ਵਿੱਚ ਕਿਸੇ ਹੋਰ ਡੇਟਾਬੇਸ ਵਿੱਚ ਨਕਲ ਕਰੋ।
ਸੁਵਿਧਾਜਨਕ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਲਈ ਕੁਝ ਡੇਟਾਬੇਸ ਜਾਂ ਕਈ ਹਜ਼ਾਰਾਂ ਦੇ ਨਾਲ ਅਨੁਕੂਲ ਕੰਮ ਦੀ ਸੰਭਾਵਨਾ.
GUI ਅਤੇ ਸ਼ਾਨਦਾਰ ਸਮਰਥਨ ਦੇ ਨਾਲ ਭੁਗਤਾਨ ਕੀਤਾ ਸੰਸਕਰਣ।

SymmetricDS ਦੇ ਨੁਕਸਾਨ

ਤੁਹਾਨੂੰ ਕੈਟਾਲਾਗ ਟੇਬਲ ਨੂੰ ਲੋਡ ਕਰਨ ਲਈ SQL ਸਟੇਟਮੈਂਟਾਂ ਰਾਹੀਂ ਕਮਾਂਡ ਲਾਈਨ 'ਤੇ ਨਕਲ ਦੇ ਨਿਯਮਾਂ ਅਤੇ ਦਿਸ਼ਾ ਨੂੰ ਦਸਤੀ ਪਰਿਭਾਸ਼ਿਤ ਕਰਨ ਦੀ ਲੋੜ ਹੈ, ਜੋ ਕਿ ਅਸੁਵਿਧਾਜਨਕ ਹੋ ਸਕਦਾ ਹੈ।
ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਲਈ ਬਹੁਤ ਸਾਰੀਆਂ ਟੇਬਲਾਂ ਨੂੰ ਸੈਟ ਕਰਨਾ ਔਖਾ ਹੋ ਸਕਦਾ ਹੈ ਜਦੋਂ ਤੱਕ ਤੁਸੀਂ SQL ਸਟੇਟਮੈਂਟਾਂ ਬਣਾਉਣ ਲਈ ਸਕ੍ਰਿਪਟਾਂ ਦੀ ਵਰਤੋਂ ਨਹੀਂ ਕਰਦੇ ਜੋ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਦੇ ਨਿਯਮਾਂ ਅਤੇ ਦਿਸ਼ਾ ਨੂੰ ਪਰਿਭਾਸ਼ਿਤ ਕਰਦੇ ਹਨ।
ਲੌਗਸ ਵਿੱਚ ਬਹੁਤ ਜ਼ਿਆਦਾ ਜਾਣਕਾਰੀ ਦਰਜ ਕੀਤੀ ਜਾ ਰਹੀ ਹੈ, ਅਤੇ ਕਈ ਵਾਰ ਤੁਹਾਨੂੰ ਲੌਗ ਫਾਈਲ ਨੂੰ ਸਾਫ਼ ਕਰਨ ਦੀ ਲੋੜ ਹੁੰਦੀ ਹੈ ਤਾਂ ਜੋ ਇਹ ਬਹੁਤ ਜ਼ਿਆਦਾ ਥਾਂ ਨਾ ਲਵੇ।

SymmetricDS ਲਈ ਨਤੀਜੇ

ਸਿਮਟ੍ਰਿਕਡੀਐਸ ਤੁਹਾਨੂੰ ਫਾਈਲਾਂ ਨੂੰ ਦੁਹਰਾਉਣ ਅਤੇ ਸਮਕਾਲੀ ਕਰਨ ਲਈ ਦੋ, ਤਿੰਨ, ਜਾਂ ਇੱਥੋਂ ਤੱਕ ਕਿ ਕਈ ਹਜ਼ਾਰ ਨੋਡਾਂ ਦੇ ਵਿਚਕਾਰ ਦੋ-ਪੱਖੀ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਥਾਪਤ ਕਰਨ ਦੀ ਆਗਿਆ ਦਿੰਦਾ ਹੈ. ਇਹ ਇੱਕ ਵਿਲੱਖਣ ਟੂਲ ਹੈ ਜੋ ਸੁਤੰਤਰ ਤੌਰ 'ਤੇ ਬਹੁਤ ਸਾਰੇ ਕੰਮ ਕਰਦਾ ਹੈ, ਜਿਵੇਂ ਕਿ ਇੱਕ ਨੋਡ 'ਤੇ ਲੰਬੇ ਸਮੇਂ ਦੇ ਡਾਊਨਟਾਈਮ ਤੋਂ ਬਾਅਦ ਆਟੋਮੈਟਿਕ ਡਾਟਾ ਰਿਕਵਰੀ, HTTPS ਦੁਆਰਾ ਨੋਡਾਂ ਵਿਚਕਾਰ ਸੁਰੱਖਿਅਤ ਅਤੇ ਕੁਸ਼ਲ ਡੇਟਾ ਐਕਸਚੇਂਜ, ਨਿਯਮਾਂ ਦੇ ਇੱਕ ਸਮੂਹ ਦੇ ਅਧਾਰ ਤੇ ਆਟੋਮੈਟਿਕ ਸੰਘਰਸ਼ ਪ੍ਰਬੰਧਨ, ਆਦਿ। ਕਿਸੇ ਵੀ ਡੇਟਾਬੇਸ ਦੇ ਵਿਚਕਾਰ ਪ੍ਰਤੀਕ੍ਰਿਤੀ, ਇਸਲਈ, ਇਸਦੀ ਵਰਤੋਂ ਕਈ ਤਰ੍ਹਾਂ ਦੇ ਦ੍ਰਿਸ਼ਾਂ ਲਈ ਕੀਤੀ ਜਾ ਸਕਦੀ ਹੈ, ਜਿਸ ਵਿੱਚ ਮਾਈਗ੍ਰੇਸ਼ਨ, ਮਾਈਗ੍ਰੇਸ਼ਨ, ਵੰਡ, ਫਿਲਟਰਿੰਗ, ਅਤੇ ਪਲੇਟਫਾਰਮਾਂ ਵਿੱਚ ਡੇਟਾ ਦਾ ਪਰਿਵਰਤਨ ਸ਼ਾਮਲ ਹੈ।

ਉਦਾਹਰਨ ਅਧਿਕਾਰੀ 'ਤੇ ਆਧਾਰਿਤ ਹੈ ਤੇਜ਼ ਗਾਈਡ SymmetricDS ਦੁਆਰਾ. IN ਉਪਯੋਗ ਪੁਸਤਕ ਸਿਮਟ੍ਰਿਕਡੀਐਸ ਦੇ ਨਾਲ ਪ੍ਰਤੀਕ੍ਰਿਤੀ ਸਥਾਪਤ ਕਰਨ ਵਿੱਚ ਸ਼ਾਮਲ ਵੱਖ-ਵੱਖ ਧਾਰਨਾਵਾਂ ਦਾ ਵਿਸਥਾਰ ਵਿੱਚ ਵਰਣਨ ਕਰਦਾ ਹੈ।

ਸਰੋਤ: www.habr.com