Compartilhamento de tecnologia

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

 

Prática HIVE de data warehouse

@ConfigurationProperties(prefix = "hive")
@Data
public class HiveDruidConfig {
 
    private String url;
    private String user;
    private String password;
    private String driverClassName;
    private int initialSize;
    private int minIdle;
    private int maxActive;
    private int maxWait;
    private int timeBetweenEvictionRunsMillis;
    private int minEvictableIdleTimeMillis;
    private String validationQuery;
    private boolean testWhileIdle;
    private boolean testOnBorrow;
    private boolean testOnReturn;
    private boolean poolPreparedStatements;
    private int maxPoolPreparedStatementPerConnectionSize;
 
    @Bean(name = "hiveDruidDataSource")
    @Qualifier("hiveDruidDataSource")
    public DataSource dataSource() {
        DruidDataSource datasource = new DruidDataSource();
        datasource.setUrl(url);
        datasource.setUsername(user);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);
 
        // pool configuration
        datasource.setInitialSize(initialSize);
        datasource.setMinIdle(minIdle);
        datasource.setMaxActive(maxActive);
        datasource.setMaxWait(maxWait);
        datasource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
        datasource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
        datasource.setValidationQuery(validationQuery);
        datasource.setTestWhileIdle(testWhileIdle);
        datasource.setTestOnBorrow(testOnBorrow);
        datasource.setTestOnReturn(testOnReturn);
        datasource.setPoolPreparedStatements(poolPreparedStatements);
        datasource.setMaxPoolPreparedStatementPerConnectionSize(maxPoolPreparedStatementPerConnectionSize);
        return datasource;
    }
 
    @Bean(name = "hiveDruidTemplate")
    public JdbcTemplate hiveDruidTemplate(@Qualifier("hiveDruidDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

Este código é um exemplo de uso do pool de conexões Spring Boot e Druid para configurar uma conexão de banco de dados Hive.Mostra como passar@ConfigurationPropertiesAnotações para simplificar a vinculação de propriedades de configuração e como usar o Spring@BeanAnotações para criar e gerenciarDataSourceeJdbcTemplate Feijão. A seguir está uma explicação de ensino detalhada deste código:

1. @ConfigurationProperties(prefix = "hive")

• efeito: Esta anotação é usada para adicionar arquivos de configuração (comoapplication.propertiesouapplication.yml) no prefixo éhiveAs propriedades de estão vinculadas à classe atual (HiveDruidConfig ) campo. Isso torna a configuração de conexões de banco de dados e outros parâmetros relacionados muito conveniente e centralizada.
• exemplo: Se você estiverapplication.propertiesHáhive.url=jdbc:hive2://...,EntãourlO campo receberá automaticamente um valor.

2. @Data

• efeito : Esta anotação vem da biblioteca Lombok, que gera automaticamente os métodos getter, setter, equals, hashCode e toString para os campos da classe. Isso reduz o código clichê e torna as classes mais limpas.

3. Definição de campo

• Vários campos privados são definidos na classe, que correspondem aos parâmetros de configuração da conexão do banco de dados Hive e do pool de conexões Druid.

4. dataSource()método

• efeito: Este método usa@Bean Anotação, indicando que retornará um Bean, que será gerenciado pelo container Spring.Neste exemplo, ele cria e configura umDruidDataSourceExemplo, esta é a implementação do pool de conexões Druid.
• Configuração: Várias propriedades de DruidDataSource são definidas por meio do método setter dentro do método. Essas propriedades vêm dos valores dos campos da classe e esses valores são passados.@ConfigurationPropertiesObtenha-o no arquivo de configuração.
• valor de retorno:O método retorna o configuradoDruidDataSourceinstância, o contêiner Spring irá registrá-lo como uma instância chamadahiveDruidDataSourceFeijão.

5. hiveDruidTemplate()método

• efeito: Este método também é usado@Beananotação, que cria umaJdbcTemplateInstância, esta instância é usada para simplificar as operações do banco de dados.
• parâmetro: o método recebe umDataSourceparâmetros de tipo, passados@Qualifier("hiveDruidDataSource")A anotação é especificada usando o nomehiveDruidDataSourceFeijão DataSource.
• valor de retorno:O método retorna o configuradoJdbcTemplateinstância, o contêiner Spring irá registrá-lo como uma instância chamadahiveDruidTemplateFeijão.

Resumir

Este código mostra como passar@ConfigurationPropertiese@Bean Anotações para configurar e gerenciar conexões de banco de dados. Ao usar o pool de conexões Druid, o desempenho e a estabilidade das operações de banco de dados podem ser melhorados ainda mais.Ao mesmo tempo, atravésJdbcTemplate, os desenvolvedores podem realizar operações de banco de dados de maneira mais conveniente, sem escrever uma grande quantidade de código JDBC.