You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2020/10/12 06:38:54 UTC
[shardingsphere] branch master updated: Update mysql data source
checker (#7742)
This is an automated email from the ASF dual-hosted git repository.
zhangyonglun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 9b7287a Update mysql data source checker (#7742)
9b7287a is described below
commit 9b7287a086c45f019b130404e48197b3eacfeba6
Author: avalon5666 <64...@users.noreply.github.com>
AuthorDate: Mon Oct 12 14:38:42 2020 +0800
Update mysql data source checker (#7742)
* Update mysql data source checker
* Fix unit test
---
.../apache/shardingsphere/scaling/mysql/MySQLDataSourceChecker.java | 1 +
.../shardingsphere/scaling/mysql/MySQLDataSourceCheckerTest.java | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceChecker.java b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceChecker.java
index 62c8326e..b03e6dd 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceChecker.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/main/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceChecker.java
@@ -47,6 +47,7 @@ public final class MySQLDataSourceChecker extends AbstractDataSourceChecker {
static {
REQUIRED_VARIABLES.put("LOG_BIN", "ON");
REQUIRED_VARIABLES.put("BINLOG_FORMAT", "ROW");
+ REQUIRED_VARIABLES.put("BINLOG_ROW_IMAGE", "FULL");
}
@Override
diff --git a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceCheckerTest.java b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceCheckerTest.java
index 856d440..3943633 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceCheckerTest.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/MySQLDataSourceCheckerTest.java
@@ -96,9 +96,9 @@ public final class MySQLDataSourceCheckerTest {
@Test
public void assertCheckVariableSuccess() throws SQLException {
when(resultSet.next()).thenReturn(true, true);
- when(resultSet.getString(2)).thenReturn("ON", "ROW");
+ when(resultSet.getString(2)).thenReturn("ON", "ROW", "FULL");
dataSourceChecker.checkVariable(dataSources);
- verify(preparedStatement, Mockito.times(2)).executeQuery();
+ verify(preparedStatement, Mockito.times(3)).executeQuery();
}
@Test(expected = PrepareFailedException.class)