Skip to content

Commit 7a22ce5

Browse files
core-libcore-lib
committed
兼容表明区分大小写的数据库设置
1 parent 3b3c993 commit 7a22ce5

4 files changed

Lines changed: 19 additions & 19 deletions

File tree

‎src/main/java/io/sqlman/dialect/AbstractDialectSupport.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -49,9 +49,9 @@ public SqlVersion detect(Connection connection) throws SQLException {
4949
dql.append(" ERROR_MESSAGE AS errorMessage,");
5050
dql.append(" TIME_EXECUTED AS timeExecuted");
5151
dql.append(" FROM");
52-
dql.append(" ").append(table.toUpperCase());
52+
dql.append(" ").append(table);
5353
dql.append(" WHERE");
54-
dql.append(" ID = (SELECT MAX(ID) FROM ").append(table.toUpperCase()).append(")");
54+
dql.append(" ID = (SELECT MAX(ID) FROM ").append(table).append(")");
5555

5656
PreparedStatement statement = connection.prepareStatement(dql.toString());
5757
ResultSet result = statement.executeQuery();
@@ -82,7 +82,7 @@ public SqlVersion detect(Connection connection) throws SQLException {
8282
public void update(Connection connection, SqlVersion version) throws SQLException {
8383
StringBuilder dml = new StringBuilder();
8484

85-
dml.append(" INSERT INTO ").append(table.toUpperCase()).append(" (");
85+
dml.append(" INSERT INTO ").append(table).append(" (");
8686
dml.append(" NAME,");
8787
dml.append(" VERSION,");
8888
dml.append(" ORDINAL,");
@@ -116,17 +116,17 @@ public void update(Connection connection, SqlVersion version) throws SQLExceptio
116116

117117
@Override
118118
public void remove(Connection connection) throws SQLException {
119-
connection.prepareStatement("DROP TABLE " + table.toUpperCase() + "").executeUpdate();
119+
connection.prepareStatement("DROP TABLE " + table + "").executeUpdate();
120120
}
121121

122122
@Override
123123
public void lockup(Connection connection) throws SQLException {
124-
connection.prepareStatement("CREATE TABLE " + table.toUpperCase() + "_LOCK (NIL INTEGER)").executeUpdate();
124+
connection.prepareStatement("CREATE TABLE " + table + "_LOCK (NIL INTEGER)").executeUpdate();
125125
}
126126

127127
@Override
128128
public void unlock(Connection connection) throws SQLException {
129-
connection.prepareStatement("DROP TABLE " + table.toUpperCase() + "_LOCK").executeUpdate();
129+
connection.prepareStatement("DROP TABLE " + table + "_LOCK").executeUpdate();
130130
}
131131

132132
@Override

‎src/main/java/io/sqlman/dialect/OracleDialectSupport.java‎

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -26,11 +26,11 @@ public void create(Connection connection) throws SQLException {
2626

2727
ddl.append(" DECLARE EXISTED NUMBER;");
2828
ddl.append(" BEGIN");
29-
ddl.append(" SELECT COUNT(1) INTO EXISTED FROM USER_TABLES WHERE TABLE_NAME = UPPER('").append(table.toUpperCase()).append("');");
29+
ddl.append(" SELECT COUNT(1) INTO EXISTED FROM USER_TABLES WHERE TABLE_NAME = UPPER('").append(table).append("');");
3030
ddl.append(" IF EXISTED = 0");
3131
ddl.append(" THEN");
3232
ddl.append(" EXECUTE IMMEDIATE");
33-
ddl.append(" 'CREATE TABLE ").append(table.toUpperCase()).append(" (");
33+
ddl.append(" 'CREATE TABLE ").append(table).append(" (");
3434
ddl.append(" ID INT NOT NULL PRIMARY KEY,");
3535
ddl.append(" NAME VARCHAR(255) NOT NULL,");
3636
ddl.append(" VERSION VARCHAR(24) NOT NULL,");
@@ -45,19 +45,19 @@ public void create(Connection connection) throws SQLException {
4545
ddl.append(" TIME_EXECUTED DATE NOT NULL");
4646
ddl.append(" )';");
4747
ddl.append(" EXECUTE IMMEDIATE");
48-
ddl.append(" 'CREATE SEQUENCE ").append(table.toUpperCase()).append("_SEQUENCE");
48+
ddl.append(" 'CREATE SEQUENCE ").append(table).append("_SEQUENCE");
4949
ddl.append(" INCREMENT BY 1");
5050
ddl.append(" START WITH 1");
5151
ddl.append(" NOMAXVALUE");
5252
ddl.append(" NOMINVALUE");
5353
ddl.append(" NOCACHE';");
5454
ddl.append(" EXECUTE IMMEDIATE");
55-
ddl.append(" 'CREATE OR REPLACE TRIGGER ").append(table.toUpperCase()).append("_TRIGGER");
55+
ddl.append(" 'CREATE OR REPLACE TRIGGER ").append(table).append("_TRIGGER");
5656
ddl.append(" BEFORE INSERT");
57-
ddl.append(" ON ").append(table.toUpperCase());
57+
ddl.append(" ON ").append(table);
5858
ddl.append(" FOR EACH ROW");
5959
ddl.append(" BEGIN");
60-
ddl.append(" SELECT ").append(table.toUpperCase()).append("_SEQUENCE.NEXTVAL INTO :NEW.ID FROM DUAL;");
60+
ddl.append(" SELECT ").append(table).append("_SEQUENCE.NEXTVAL INTO :NEW.ID FROM DUAL;");
6161
ddl.append(" END;';");
6262
ddl.append(" END IF;");
6363
ddl.append(" END;");
@@ -67,8 +67,8 @@ public void create(Connection connection) throws SQLException {
6767

6868
@Override
6969
public void remove(Connection connection) throws SQLException {
70-
connection.prepareStatement("DROP TRIGGER " + table.toUpperCase() + "_TRIGGER").executeUpdate();
71-
connection.prepareStatement("DROP SEQUENCE " + table.toUpperCase() + "_SEQUENCE").executeUpdate();
70+
connection.prepareStatement("DROP TRIGGER " + table + "_TRIGGER").executeUpdate();
71+
connection.prepareStatement("DROP SEQUENCE " + table + "_SEQUENCE").executeUpdate();
7272
super.remove(connection);
7373
}
7474
}

‎src/main/java/io/sqlman/dialect/SQLServerDialectSupport.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public SQLServerDialectSupport() {
1919
}
2020

2121
public SQLServerDialectSupport(String table) {
22-
super(table.toUpperCase());
22+
super(table);
2323
}
2424

2525
@Override
@@ -29,9 +29,9 @@ public void create(Connection connection) throws SQLException {
2929
ddl.append(" IF NOT EXISTS(");
3030
ddl.append(" SELECT *");
3131
ddl.append(" FROM SYSOBJECTS");
32-
ddl.append(" WHERE ID = OBJECT_ID('").append(table.toUpperCase()).append("')");
32+
ddl.append(" WHERE ID = OBJECT_ID('").append(table).append("')");
3333
ddl.append(" )");
34-
ddl.append(" CREATE TABLE ").append(table.toUpperCase()).append(" (");
34+
ddl.append(" CREATE TABLE ").append(table).append(" (");
3535
ddl.append(" ID INT NOT NULL PRIMARY KEY IDENTITY(1, 1),");
3636
ddl.append(" NAME VARCHAR(255) NOT NULL,");
3737
ddl.append(" VERSION VARCHAR(24) NOT NULL,");

‎src/main/java/io/sqlman/dialect/SQLiteDialectSupport.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,14 @@ public SQLiteDialectSupport() {
1717
}
1818

1919
public SQLiteDialectSupport(String table) {
20-
super(table.toUpperCase());
20+
super(table);
2121
}
2222

2323
@Override
2424
public void create(Connection connection) throws SQLException {
2525
StringBuilder ddl = new StringBuilder();
2626

27-
ddl.append(" CREATE TABLE IF NOT EXISTS ").append(table.toUpperCase()).append(" (");
27+
ddl.append(" CREATE TABLE IF NOT EXISTS ").append(table).append(" (");
2828
ddl.append(" ID INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,");
2929
ddl.append(" NAME VARCHAR(225) NOT NULL,");
3030
ddl.append(" VERSION VARCHAR(24) NOT NULL,");

0 commit comments

Comments
 (0)