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());
}