You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by xi...@apache.org on 2020/12/03 04:57:53 UTC
[shardingsphere] branch master updated: Fix type: from mySQL to
mysql for variable name (#8484)
This is an automated email from the ASF dual-hosted git repository.
xiaoyu 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 7e33487 Fix type: from mySQL to mysql for variable name (#8484)
7e33487 is described below
commit 7e33487ed0e9e3df7db40ede89a1b85fc3040c7e
Author: Liang Zhang <te...@163.com>
AuthorDate: Thu Dec 3 12:57:38 2020 +0800
Fix type: from mySQL to mysql for variable name (#8484)
---
.../scaling/mysql/component/MySQLBinlogDumperTest.java | 8 ++++----
.../scaling/mysql/component/MySQLImporterTest.java | 4 ++--
.../scaling/mysql/component/MySQLJdbcDumperTest.java | 10 +++++-----
3 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLBinlogDumperTest.java b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLBinlogDumperTest.java
index 035df28..d7d3a2a 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLBinlogDumperTest.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLBinlogDumperTest.java
@@ -57,7 +57,7 @@ public final class MySQLBinlogDumperTest {
private static final String URL = "jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false;MODE=MySQL";
- private MySQLBinlogDumper mySQLBinlogDumper;
+ private MySQLBinlogDumper mysqlBinlogDumper;
private MemoryChannel channel;
@@ -68,8 +68,8 @@ public final class MySQLBinlogDumperTest {
initTableData(dumperConfig);
channel = new MemoryChannel(records -> {
});
- mySQLBinlogDumper = new MySQLBinlogDumper(dumperConfig, new BinlogPosition("binlog-000001", 4L));
- mySQLBinlogDumper.setChannel(channel);
+ mysqlBinlogDumper = new MySQLBinlogDumper(dumperConfig, new BinlogPosition("binlog-000001", 4L));
+ mysqlBinlogDumper.setChannel(channel);
}
private DumperConfiguration mockDumperConfiguration() {
@@ -160,6 +160,6 @@ public final class MySQLBinlogDumperTest {
@SneakyThrows({NoSuchMethodException.class, ReflectiveOperationException.class})
private void invokeHandleEvent(final JdbcUri uri, final AbstractBinlogEvent event) {
- ReflectionUtil.invokeMethod(mySQLBinlogDumper, "handleEvent", new Class[]{JdbcUri.class, AbstractBinlogEvent.class}, new Object[]{uri, event});
+ ReflectionUtil.invokeMethod(mysqlBinlogDumper, "handleEvent", new Class[]{JdbcUri.class, AbstractBinlogEvent.class}, new Object[]{uri, event});
}
}
diff --git a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLImporterTest.java b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLImporterTest.java
index b99cddc..32ff399 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLImporterTest.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLImporterTest.java
@@ -42,8 +42,8 @@ public final class MySQLImporterTest {
@Test
public void assertCreateSqlBuilder() {
- MySQLImporter mySQLImporter = new MySQLImporter(importerConfig, dataSourceManager);
- String insertSQL = mySQLImporter.createSQLBuilder(Maps.newHashMap()).buildInsertSQL(mockDataRecord());
+ MySQLImporter mysqlImporter = new MySQLImporter(importerConfig, dataSourceManager);
+ String insertSQL = mysqlImporter.createSQLBuilder(Maps.newHashMap()).buildInsertSQL(mockDataRecord());
assertThat(insertSQL, is("INSERT INTO `t_order`(`id`,`name`) VALUES(?,?) ON DUPLICATE KEY UPDATE `name`=VALUES(`name`)"));
}
diff --git a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLJdbcDumperTest.java b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLJdbcDumperTest.java
index 0885747..b5d1f23 100644
--- a/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLJdbcDumperTest.java
+++ b/shardingsphere-scaling/shardingsphere-scaling-mysql/src/test/java/org/apache/shardingsphere/scaling/mysql/component/MySQLJdbcDumperTest.java
@@ -46,7 +46,7 @@ public final class MySQLJdbcDumperTest {
private DataSourceManager dataSourceManager;
- private MySQLJdbcDumper mySQLJdbcDumper;
+ private MySQLJdbcDumper mysqlJdbcDumper;
@Mock
private Connection connection;
@@ -54,7 +54,7 @@ public final class MySQLJdbcDumperTest {
@Before
public void setUp() {
dataSourceManager = new DataSourceManager();
- mySQLJdbcDumper = new MySQLJdbcDumper(mockInventoryDumperConfiguration(), dataSourceManager);
+ mysqlJdbcDumper = new MySQLJdbcDumper(mockInventoryDumperConfiguration(), dataSourceManager);
}
private InventoryDumperConfiguration mockInventoryDumperConfiguration() {
@@ -89,8 +89,8 @@ public final class MySQLJdbcDumperTest {
when(resultSet.getMetaData()).thenReturn(resultSetMetaData);
when(resultSetMetaData.getColumnType(1)).thenReturn(Types.TIMESTAMP);
when(resultSetMetaData.getColumnType(2)).thenReturn(Types.VARCHAR);
- mySQLJdbcDumper.readValue(resultSet, 1);
- mySQLJdbcDumper.readValue(resultSet, 2);
+ mysqlJdbcDumper.readValue(resultSet, 1);
+ mysqlJdbcDumper.readValue(resultSet, 2);
verify(resultSet).getString(1);
verify(resultSet).getObject(2);
}
@@ -98,7 +98,7 @@ public final class MySQLJdbcDumperTest {
@Test
public void assertCreatePreparedStatement() throws SQLException {
when(connection.prepareStatement("", ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY)).thenReturn(mock(PreparedStatement.class));
- PreparedStatement preparedStatement = mySQLJdbcDumper.createPreparedStatement(connection, "");
+ PreparedStatement preparedStatement = mysqlJdbcDumper.createPreparedStatement(connection, "");
verify(preparedStatement).setFetchSize(Integer.MIN_VALUE);
}
}