We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7ddb2ba commit edfffb7Copy full SHA for edfffb7
src/common/codeine/db/mysql/DbUtils.java
@@ -154,7 +154,12 @@ private Connection getConnection(boolean useCompression) {
154
String mysqlAddress = hostSelector.mysql().host() + ":" + hostSelector.mysql().port();
155
String jdbcUrl = "jdbc:mysql://" + mysqlAddress + "/" + MysqlConstants.DB_NAME + "?useCompression=true";
156
try {
157
- return getDBConnection(jdbcUrl, hostSelector.mysql());
+ if (globalConfigurationJsonStore.get().large_deployment()) {
158
+ return DriverManager
159
+ .getConnection(jdbcUrl, hostSelector.mysql().user(), hostSelector.mysql().password());
160
+ } else {
161
+ return getDBConnection(jdbcUrl, hostSelector.mysql());
162
+ }
163
} catch (SQLException e) {
164
throw new ConnectToDatabaseException(jdbcUrl, e);
165
}
0 commit comments