Condivisione della tecnologia

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

 

Pratica HIVE del 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);
    }

Questo codice è un esempio dell'utilizzo del pool di connessioni Spring Boot e Druid per configurare una connessione al database Hive.Mostra come passare@ConfigurationPropertiesAnnotazioni per semplificare l'associazione delle proprietà di configurazione e come utilizzare Spring@BeanAnnotazioni da creare e gestireDataSourceEJdbcTemplate Fagiolo. Quella che segue è una spiegazione didattica dettagliata di questo codice:

1. @ConfigurationProperties(prefix = "hive")

• effetto: questa annotazione viene utilizzata per aggiungere file di configurazione (comeapplication.propertiesOapplication.yml) nel prefisso èhiveLe proprietà di sono legate alla classe corrente (HiveDruidConfig ) campo. Ciò rende la configurazione delle connessioni al database e di altri parametri correlati molto comoda e centralizzata.
• esempio: Se seiapplication.propertiesC'èhive.url=jdbc:hive2://...,COSÌurlAl campo verrà assegnato automaticamente un valore.

2. @Data

• effetto : Questa annotazione proviene dalla libreria Lombok, che genera automaticamente metodi getter, setter, equals, hashCode e toString per i campi della classe. Ciò riduce il codice standard e rende le classi più pulite.

3. Definizione del campo

• Nella classe sono definiti più campi privati, che corrispondono ai parametri di configurazione della connessione al database Hive e del pool di connessioni Druid.

4. dataSource()metodo

• effetto: Questo metodo utilizza@Bean Annotazione, che indica che restituirà un Bean, che sarà gestito dal contenitore Spring.In questo esempio, crea e configura aDruidDataSourceAd esempio, questa è l'implementazione del pool di connessioni Druid.
• Configurazione: Varie proprietà di DruidDataSource vengono impostate tramite il metodo setter all'interno del metodo. Queste proprietà provengono dai valori dei campi della classe e questi valori vengono passati@ConfigurationPropertiesOttienilo dal file di configurazione.
• valore di ritorno:Il metodo restituisce il configuratoDruidDataSourceistanza, il contenitore Spring lo registrerà come istanza denominatahiveDruidDataSourceFagiolo.

5. hiveDruidTemplate()metodo

• effetto: Viene utilizzato anche questo metodo@Beanannotazione, che crea un fileJdbcTemplateIstanza, questa istanza viene utilizzata per semplificare le operazioni del database.
• parametro: il metodo riceve aDataSourceparametri di tipo, passati@Qualifier("hiveDruidDataSource")L'annotazione viene specificata utilizzando il nomehiveDruidDataSourceBean di origine dati.
• valore di ritorno:Il metodo restituisce il configuratoJdbcTemplateistanza, il contenitore Spring lo registrerà come istanza denominatahiveDruidTemplateFagiolo.

Riassumere

Questo codice mostra come passare@ConfigurationPropertiesE@Bean Annotazioni per configurare e gestire le connessioni al database. Utilizzando il pool di connessioni Druid, le prestazioni e la stabilità delle operazioni del database possono essere ulteriormente migliorate.Allo stesso tempo, attraversoJdbcTemplate, gli sviluppatori possono eseguire operazioni sul database in modo più pratico senza scrivere una grande quantità di codice JDBC.