diff options
| author | Zuul <zuul@review.opendev.org> | 2020-11-30 09:39:24 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2020-11-30 09:39:24 +0000 |
| commit | 77c043062b2ea651684be2059fd7b27a29e6e684 (patch) | |
| tree | 809ba4a066be864b675555b56e975b952e59bf91 /trove | |
| parent | cc57e32c48f4a2acc3b0c57e50573cda3ce5ac98 (diff) | |
| parent | df82af30f21b89097597bf471c2aa5a08d19386c (diff) | |
| download | trove-77c043062b2ea651684be2059fd7b27a29e6e684.tar.gz | |
Merge "Get slave_pos to choose latest replica"
Diffstat (limited to 'trove')
| -rw-r--r-- | trove/guestagent/datastore/mariadb/service.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/trove/guestagent/datastore/mariadb/service.py b/trove/guestagent/datastore/mariadb/service.py index aa603d99..891e37fb 100644 --- a/trove/guestagent/datastore/mariadb/service.py +++ b/trove/guestagent/datastore/mariadb/service.py @@ -57,10 +57,14 @@ class MariaDBApp(mysql_service.BaseMySqlApp): with mysql_util.SqlClient(self.get_engine()) as client: return client.execute('SELECT @@global.gtid_binlog_pos').first()[0] + def _get_gtid_slave_executed(self): + with mysql_util.SqlClient(self.get_engine()) as client: + return client.execute('SELECT @@global.gtid_slave_pos').first()[0] + def get_last_txn(self): master_UUID = self._get_master_UUID() last_txn_id = '0' - gtid_executed = self._get_gtid_executed() + gtid_executed = self._get_gtid_slave_executed() for gtid_set in gtid_executed.split(','): uuid_set = gtid_set.split('-') if str(uuid_set[1]) == str(master_UUID): |