diff options
author | root <root@vps-18a7a2b7.vps.ovh.ca> | 2024-02-14 16:09:24 -0500 |
---|---|---|
committer | root <root@vps-18a7a2b7.vps.ovh.ca> | 2024-02-14 16:09:24 -0500 |
commit | 94171073449ee8505971c6ef695bb7b5d1c96520 (patch) | |
tree | 5550f0e400482af2b8073a15be8a813e2874bf97 | |
parent | 93a9a34bbac850137a7c722325080c2a8908db97 (diff) |
cleanup
-rwxr-xr-x | src/mariadb-push-replica.sh | 30 |
1 files changed, 13 insertions, 17 deletions
diff --git a/src/mariadb-push-replica.sh b/src/mariadb-push-replica.sh index f4077cc..c9b513b 100755 --- a/src/mariadb-push-replica.sh +++ b/src/mariadb-push-replica.sh | |||
@@ -71,7 +71,6 @@ stop_mariadb_server_and_remove_database_files() | |||
71 | set -e | 71 | set -e |
72 | set -o pipefail | 72 | set -o pipefail |
73 | [ -e "$livedb" ] || return 0 | 73 | [ -e "$livedb" ] || return 0 |
74 | |||
75 | if [ "$(systemctl is-active mariadb)" = active ] | 74 | if [ "$(systemctl is-active mariadb)" = active ] |
76 | then | 75 | then |
77 | systemctl stop mariadb | 76 | systemctl stop mariadb |
@@ -135,14 +134,12 @@ to | |||
135 | create_replication_user() | 134 | create_replication_user() |
136 | { | 135 | { |
137 | mariadb --skip-reconnect -t <<. | 136 | mariadb --skip-reconnect -t <<. |
138 | |||
139 | create or replace | 137 | create or replace |
140 | user | 138 | user |
141 | '$2'@'$1' | 139 | '$2'@'$1' |
142 | identified by | 140 | identified by |
143 | '$3' | 141 | '$3' |
144 | ; | 142 | ; |
145 | |||
146 | grant replication slave | 143 | grant replication slave |
147 | on | 144 | on |
148 | *.* | 145 | *.* |
@@ -319,18 +316,18 @@ save_array() | |||
319 | 316 | ||
320 | mariadb_scan_databases() | 317 | mariadb_scan_databases() |
321 | { | 318 | { |
322 | set -- $(mktemp) | 319 | set -- "$(mktemp)" |
323 | declare -g -a primary_dbs | 320 | declare -g -a primary_dbs |
324 | save_array primary_dbs from lines <( | 321 | save_array primary_dbs from lines <( |
325 | run_primary \ | 322 | run_primary mariadb_list_databases \ |
326 | mariadb_list_databases </dev/null 2>"$1" | | 323 | </dev/null 2>"$1" | |
327 | sort -u | 324 | sort -u |
328 | ) | 325 | ) |
329 | 326 | ||
330 | declare -g -a replica_dbs | 327 | declare -g -a replica_dbs |
331 | save_array replica_dbs from lines <( | 328 | save_array replica_dbs from lines <( |
332 | run_replica \ | 329 | run_replica mariadb_list_databases \ |
333 | mariadb_list_databases </dev/null 2>>"$1" | | 330 | </dev/null 2>>"$1" | |
334 | sort -u | 331 | sort -u |
335 | ) | 332 | ) |
336 | 333 | ||
@@ -401,7 +398,8 @@ main() | |||
401 | choose_mariadbdump_target_databases databases "$@" | 398 | choose_mariadbdump_target_databases databases "$@" |
402 | if [ ${#databases[@]} -gt 0 ] | 399 | if [ ${#databases[@]} -gt 0 ] |
403 | then | 400 | then |
404 | run_replica mariadb_install_replication_credentials \ | 401 | run_replica \ |
402 | mariadb_install_replication_credentials \ | ||
405 | "$primary_host" \ | 403 | "$primary_host" \ |
406 | "$replication_user" \ | 404 | "$replication_user" \ |
407 | "$replication_password" | 405 | "$replication_password" |
@@ -413,13 +411,11 @@ main() | |||
413 | --gtid \ | 411 | --gtid \ |
414 | --single-transaction \ | 412 | --single-transaction \ |
415 | --databases "${databases[@]}" | 413 | --databases "${databases[@]}" |
416 | run_replica show_all_databases | 414 | run_replica \ |
415 | show_all_databases | ||
417 | fi | 416 | fi |
418 | #run_replica mariadb <<< 'show slave status\G' | 417 | gtid=$(run_primary |
419 | #run_primary mariadb <<< 'show master status\G' | 418 | mariadb_get_primary_gtid </dev/null) |
420 | #run_replica showvars | ||
421 | #run_replica mariadb <<< 'show slave status\G' | ||
422 | gtid=$(run_primary mariadb_get_primary_gtid) | ||
423 | [ "$gtid" ] && run_replica wait_on_gtid "$gtid" | 419 | [ "$gtid" ] && run_replica wait_on_gtid "$gtid" |
424 | } | 420 | } |
425 | 421 | ||
@@ -466,8 +462,8 @@ select | |||
466 | , @@server_id | 462 | , @@server_id |
467 | , count(schema_name) as 'databases' | 463 | , count(schema_name) as 'databases' |
468 | , user() as 'login' | 464 | , user() as 'login' |
469 | , @@gtid_slave_pos | 465 | , @@gtid_slave_pos as 'replica gtid' |
470 | , @@gtid_binlog_pos | 466 | , @@gtid_binlog_pos as 'primary gtid' |
471 | from | 467 | from |
472 | information_schema.schemata | 468 | information_schema.schemata |
473 | \G | 469 | \G |