Java 类com.facebook.presto.plugin.jdbc.BaseJdbcConfig 实例源码
项目:presto
文件:MySqlClientModule.java
@Override
public void configure(Binder binder)
{
binder.bind(JdbcClient.class).to(MySqlClient.class).in(Scopes.SINGLETON);
configBinder(binder).bindConfig(BaseJdbcConfig.class);
configBinder(binder).bindConfig(MySqlConfig.class);
}
项目:presto
文件:MySqlClient.java
@Inject
public MySqlClient(JdbcConnectorId connectorId, BaseJdbcConfig config, MySqlConfig mySqlConfig)
throws SQLException
{
super(connectorId, config, "`", new Driver());
connectionProperties.setProperty("nullCatalogMeansCurrent", "false");
if (mySqlConfig.isAutoReconnect()) {
connectionProperties.setProperty("autoReconnect", String.valueOf(mySqlConfig.isAutoReconnect()));
connectionProperties.setProperty("maxReconnects", String.valueOf(mySqlConfig.getMaxReconnects()));
}
if (mySqlConfig.getConnectionTimeout() != null) {
connectionProperties.setProperty("connectTimeout", String.valueOf(mySqlConfig.getConnectionTimeout().toMillis()));
}
}
项目:presto-template-connector
文件:TemplateClientModule.java
public void configure(Binder binder) {
binder.bind(JdbcClient.class).to(TemplateClient.class).in(Scopes.SINGLETON);
configBinder(binder).bindConfig(BaseJdbcConfig.class);
configBinder(binder).bindConfig(TemplateConfig.class);
}
项目:presto-teradata-connector
文件:TeradataClientModule.java
public void configure(Binder binder) {
binder.bind(JdbcClient.class).to(TeradataClient.class).in(Scopes.SINGLETON);
configBinder(binder).bindConfig(BaseJdbcConfig.class);
configBinder(binder).bindConfig(TeradataConfig.class);
}
项目:presto
文件:PostgreSqlClientModule.java
@Override
public void configure(Binder binder)
{
binder.bind(JdbcClient.class).to(PostgreSqlClient.class).in(Scopes.SINGLETON);
configBinder(binder).bindConfig(BaseJdbcConfig.class);
}
项目:presto
文件:PostgreSqlClient.java
@Inject
public PostgreSqlClient(JdbcConnectorId connectorId, BaseJdbcConfig config)
throws SQLException
{
super(connectorId, config, "\"", new Driver());
}