* Uses the provided connection to query the schema versions and compare them. * @param {Connection} connection * @internal * @ignore
(connection)
| 914 | * @ignore |
| 915 | */ |
| 916 | async compareSchemaVersions(connection) { |
| 917 | const versions = new Set(); |
| 918 | const response1 = await connection.send(new requests.QueryRequest(_selectSchemaVersionLocal), null); |
| 919 | if (response1 && response1.rows && response1.rows.length === 1) { |
| 920 | versions.add(response1.rows[0]['schema_version'].toString()); |
| 921 | } |
| 922 | const response2 = await connection.send(new requests.QueryRequest(_selectSchemaVersionPeers), null); |
| 923 | if (response2 && response2.rows) { |
| 924 | for (const row of response2.rows) { |
| 925 | const value = row['schema_version']; |
| 926 | if (!value) { |
| 927 | continue; |
| 928 | } |
| 929 | versions.add(value.toString()); |
| 930 | } |
| 931 | } |
| 932 | return versions.size === 1; |
| 933 | } |
| 934 | } |
| 935 | |
| 936 | /** |
no test coverage detected