技術共有

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

 

データ ウェアハウス 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);
    }

このコードは、Spring Boot と Druid 接続プールを使用して Hive データベース接続を構成する例です。通過方法を示しています@ConfigurationProperties構成プロパティのバインドを簡素化するためのアノテーションと Spring の使用方法@Bean作成および管理する注釈DataSourceそしてJdbcTemplate豆。以下は、このコードの詳しい説明です。

1. @ConfigurationProperties(prefix = "hive")

• 効果: このアノテーションは、構成ファイル (application.propertiesまたはapplication.yml) プレフィックスはhiveのプロパティは現在のクラスにバインドされています (HiveDruidConfig ） 分野。これにより、データベース接続やその他の関連パラメーターの構成が非常に便利になり、集中化されます。
• 例： あなたがいる場合application.propertiesがあるhive.url=jdbc:hive2://...、それでurlフィールドには自動的に値が割り当てられます。

2. @Data

• 効果 : このアノテーションは、クラスのフィールドの getter、setter、equals、hashCode、および toString メソッドを自動的に生成する Lombok ライブラリから取得されます。これにより定型コードが減り、クラスがよりクリーンになります。

3. フィールドの定義

• クラスには複数のプライベート フィールドが定義されており、Hive データベース接続と Druid 接続プールの構成パラメーターに対応します。

4. dataSource()方法

• 効果: この方法では、@Bean Spring コンテナによって管理される Bean を返すことを示すアノテーション。この例では、DruidDataSource例として、これは Druid 接続プールの実装です。
• 構成: DruidDataSource のさまざまなプロパティは、メソッド内の setter メソッドを通じて設定され、これらのプロパティはクラス フィールドの値から取得され、これらの値が渡されます。@ConfigurationProperties設定ファイルから取得します。
• 戻り値:メソッドは設定された値を返します。DruidDataSourceインスタンスの場合、Spring コンテナはそれを という名前のインスタンスとして登録します。hiveDruidDataSource豆。

5. hiveDruidTemplate()方法

• 効果：この方法も使われています@Beanアノテーション。JdbcTemplateインスタンス。このインスタンスはデータベース操作を簡素化するために使用されます。
• パラメータ: メソッドはDataSource渡される型パラメータ@Qualifier("hiveDruidDataSource")注釈は名前を使用して指定されます。hiveDruidDataSourceデータソース Bean。
• 戻り値:メソッドは設定された値を返します。JdbcTemplateインスタンスの場合、Spring コンテナはそれを という名前のインスタンスとして登録します。hiveDruidTemplate豆。

要約する

このコードは渡す方法を示しています@ConfigurationPropertiesそして@Beanデータベース接続を構成および管理するための注釈。 Druid 接続プールを使用することで、データベース操作のパフォーマンスと安定性をさらに向上させることができます。同時に、それを通して、JdbcTemplateを使用すると、開発者は大量の JDBC コードを記述することなく、データベース操作をより簡単に実行できます。