Partage de technologie

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

 

Pratique de l'entrepôt de données HIVE

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

Ce code est un exemple d'utilisation du pool de connexions Spring Boot et Druid pour configurer une connexion à la base de données Hive.Il montre comment réussir@ConfigurationPropertiesAnnotations pour simplifier la liaison des propriétés de configuration et comment utiliser Spring@BeanAnnotations à créer et à gérerDataSourceetJdbcTemplate Haricot. Ce qui suit est une explication pédagogique détaillée de ce code :

1. @ConfigurationProperties(prefix = "hive")

• effet: Cette annotation est utilisée pour ajouter des fichiers de configuration (tels queapplication.propertiesouapplication.yml) dans le préfixe esthiveLes propriétés de sont liées à la classe actuelle (HiveDruidConfig ) champ. Cela rend la configuration des connexions à la base de données et d’autres paramètres associés très pratique et centralisée.
• exemple: Si vous êtesapplication.propertiesIl y ahive.url=jdbc:hive2://...,DoncurlLe champ se verra automatiquement attribuer une valeur.

2. @Data

• effet : Cette annotation provient de la bibliothèque Lombok, qui génère automatiquement les méthodes getter, setter, equals, hashCode et toString pour les champs de la classe. Cela réduit le code passe-partout et rend les classes plus propres.

3. Définition du champ

• Plusieurs champs privés sont définis dans la classe, qui correspondent aux paramètres de configuration de la connexion à la base de données Hive et du pool de connexion Druid.

4. dataSource()méthode

• effet: Cette méthode utilise@Bean Annotation, indiquant qu'il renverra un Bean, qui sera géré par le conteneur Spring.Dans cet exemple, il crée et configure unDruidDataSourceExemple, il s'agit de l'implémentation du pool de connexions Druid.
• Configuration: Diverses propriétés de DruidDataSource sont définies via la méthode setter à l'intérieur de la méthode. Ces propriétés proviennent des valeurs des champs de classe, et ces valeurs sont transmises.@ConfigurationPropertiesRécupérez-le à partir du fichier de configuration.
• valeur de retour:La méthode renvoie le configuréDruidDataSourceinstance, le conteneur Spring l'enregistrera en tant qu'instance nomméehiveDruidDataSourceHaricot.

5. hiveDruidTemplate()méthode

• effet: Cette méthode est également utilisée@Beanannotation, qui crée unJdbcTemplateInstance, cette instance est utilisée pour simplifier les opérations de base de données.
• paramètre: la méthode reçoit unDataSourceparamètres de type, transmis@Qualifier("hiveDruidDataSource")L'annotation est spécifiée à l'aide du nomhiveDruidDataSourceBean DataSource.
• valeur de retour:La méthode renvoie le configuréJdbcTemplateinstance, le conteneur Spring l'enregistrera en tant qu'instance nomméehiveDruidTemplateHaricot.

Résumer

Ce code montre comment passer@ConfigurationPropertieset@Bean Annotations pour configurer et gérer les connexions à la base de données. En utilisant le pool de connexions Druid, les performances et la stabilité des opérations de base de données peuvent être encore améliorées.En même temps, à traversJdbcTemplate, les développeurs peuvent effectuer des opérations de base de données plus facilement sans écrire une grande quantité de code JDBC.