在 Hbase 步骤上的 spring apache phoenix 集成

Question

我是 Apache phoenix 的新手。如何将 Apache phoenix 与 spring 一起使用。连接到 spring 和 Apache phoenix 的步骤是什么。如何使用 phoenix 连接详细信息配置 jdbc 模板。

Answer 1

1) 首先将特定的 Apache Phoenix 依赖添加到您的 pom.xml 文件中

2) 像这样创建数据源对象：

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="driverClassName" value="org.apache.phoenix.jdbc.PhoenixDriver" />
    <property name="url" value="jdbc:phoenix:localhost" />
</bean>

3) 将数据源注入到你的 dao 类中

<bean id="someDao" class="com.stackoverlow.SomeDao">
    <property name="dataSource" ref="dataSource" />
</bean>

4) 实现你的 dao

 public class SomeDao extends NamedParameterJdbcDaoSupport  {

        @Override
        public void insert(final SomeEntity someEntity) {
            String sql = "upsert into someEntities(id, field) values (:id, :field)";
            getNamedParameterJdbcTemplate().update(sql, new BeanPropertySqlParameterSource(someEntity));
        }
    }