This is an automated email from the ASF dual-hosted git repository.
totalo 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 3c4063a0042 lower case for repository table name (#19656)
3c4063a0042 is described below
commit 3c4063a00428c41645efdcfe0d65757fd4e5c9c2
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jul 28 22:57:30 2022 +0800
lower case for repository table name (#19656)
---
.../mode/repository/standalone/jdbc/JDBCRepository.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-repository/shardingsphere-standalone-mode-repository-provider/shardingsphere-standalone-mode-repository-jdbc/shardingsphere-standalone-mode-repository-jdbc-core/src/main/java/org/apache/shardingsphere/mode/repository/standalone/jdbc/JDBCRepository.java
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-repository/
[...]
index bf6ce34511d..ddaa342883b 100644
---
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-repository/shardingsphere-standalone-mode-repository-provider/shardingsphere-standalone-mode-repository-jdbc/shardingsphere-standalone-mode-repository-jdbc-core/src/main/java/org/apache/shardingsphere/mode/repository/standalone/jdbc/JDBCRepository.java
+++
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-repository/shardingsphere-standalone-mode-repository-provider/shardingsphere-standalone-mode-repository-jdbc/shardingsphere-standalone-mode-repository-jdbc-core/src/main/java/org/apache/shardingsphere/mode/repository/standalone/jdbc/JDBCRepository.java
@@ -49,14 +49,14 @@ public abstract class JDBCRepository implements
StandalonePersistRepository {
protected void initTable(final String jdbcUrl, final String user, final
String password) {
connection = DriverManager.getConnection(jdbcUrl, user, password);
try (Statement statement = connection.createStatement()) {
- statement.execute("DROP TABLE IF EXISTS REPOSITORY");
- statement.execute("CREATE TABLE REPOSITORY(id varchar(36) PRIMARY
KEY, key TEXT, value TEXT, parent TEXT)");
+ statement.execute("DROP TABLE IF EXISTS repository");
+ statement.execute("CREATE TABLE repository(id varchar(36) PRIMARY
KEY, key TEXT, value TEXT, parent TEXT)");
}
}
@Override
public String get(final String key) {
- try (PreparedStatement preparedStatement =
connection.prepareStatement("SELECT value FROM REPOSITORY WHERE key = ?")) {
+ try (PreparedStatement preparedStatement =
connection.prepareStatement("SELECT value FROM repository WHERE key = ?")) {
preparedStatement.setString(1, key);
try (ResultSet resultSet = preparedStatement.executeQuery()) {
if (resultSet.next()) {
@@ -71,7 +71,7 @@ public abstract class JDBCRepository implements
StandalonePersistRepository {
@Override
public List<String> getChildrenKeys(final String key) {
- try (PreparedStatement preparedStatement =
connection.prepareStatement("SELECT key FROM REPOSITORY WHERE parent = ?")) {
+ try (PreparedStatement preparedStatement =
connection.prepareStatement("SELECT key FROM repository WHERE parent = ?")) {
preparedStatement.setString(1, key);
try (ResultSet resultSet = preparedStatement.executeQuery()) {
List<String> resultChildren = new LinkedList<>();
@@ -122,7 +122,7 @@ public abstract class JDBCRepository implements
StandalonePersistRepository {
}
private void insert(final String key, final String value, final String
parent) throws SQLException {
- try (PreparedStatement preparedStatement =
connection.prepareStatement("INSERT INTO REPOSITORY VALUES(?, ?, ?, ?)")) {
+ try (PreparedStatement preparedStatement =
connection.prepareStatement("INSERT INTO repository VALUES(?, ?, ?, ?)")) {
preparedStatement.setString(1, UUID.randomUUID().toString());
preparedStatement.setString(2, key);
preparedStatement.setString(3, value);
@@ -132,7 +132,7 @@ public abstract class JDBCRepository implements
StandalonePersistRepository {
}
private void update(final String key, final String value) throws
SQLException {
- try (PreparedStatement preparedStatement =
connection.prepareStatement("UPDATE REPOSITORY SET value = ? WHERE key = ?")) {
+ try (PreparedStatement preparedStatement =
connection.prepareStatement("UPDATE repository SET value = ? WHERE key = ?")) {
preparedStatement.setString(1, value);
preparedStatement.setString(2, key);
preparedStatement.executeUpdate();
@@ -141,7 +141,7 @@ public abstract class JDBCRepository implements
StandalonePersistRepository {
@Override
public void delete(final String key) {
- try (PreparedStatement preparedStatement =
connection.prepareStatement("DELETE FROM REPOSITORY WHERE key = ?")) {
+ try (PreparedStatement preparedStatement =
connection.prepareStatement("DELETE FROM repository WHERE key = ?")) {
preparedStatement.setString(1, key);
preparedStatement.executeUpdate();
} catch (final SQLException ex) {