Unverified Commit 3ddc5df2 authored by aiwenmo's avatar aiwenmo Committed by GitHub

[Fix-1072][metadata] Fix invalid oracle validationQuery (#1078)

* [Fix-1072][metadata] Fix invalid oracle validationQuery

* fix checkstyle
Co-authored-by: 's avatarwenmo <32723967+wenmo@users.noreply.github.com>
parent b65861d3
......@@ -120,7 +120,7 @@ public abstract class AbstractJdbcDriver extends AbstractDriver {
return this;
}
private void createDataSource(DruidDataSource ds, DriverConfig config) {
protected void createDataSource(DruidDataSource ds, DriverConfig config) {
ds.setName(config.getName().replaceAll(":", ""));
ds.setUrl(config.getUrl());
ds.setDriverClassName(getDriverClass());
......
......@@ -33,6 +33,8 @@ import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import com.alibaba.druid.pool.DruidDataSource;
/**
* OracleDriver
*
......@@ -129,4 +131,20 @@ public class OracleDriver extends AbstractJdbcDriver {
public Map<String, String> getFlinkColumnTypeConversion() {
return new HashMap<>();
}
@Override
protected void createDataSource(DruidDataSource ds, DriverConfig config) {
ds.setName(config.getName().replaceAll(":", ""));
ds.setUrl(config.getUrl());
ds.setDriverClassName(getDriverClass());
ds.setUsername(config.getUsername());
ds.setPassword(config.getPassword());
ds.setValidationQuery("select 1 from dual");
ds.setTestWhileIdle(true);
ds.setBreakAfterAcquireFailure(true);
ds.setFailFast(true);
ds.setInitialSize(1);
ds.setMaxActive(8);
ds.setMinIdle(5);
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment