phoenix_代码中使用phoenix

刺骨的言语ヽ痛彻心扉 2022-05-25 08:41 496阅读 0赞

代码中使用phoenix

1) 基础使用

maven配置：

<groupId>org.apache.phoenix</groupId>

<artifactId>phoenix\-core</artifactId>

<version>4.6.0-HBase-0.98</version>

</dependency>

**package** com.harvetech.service;

**import** java.sql.Connection;

**import** java.sql.DriverManager;

**import** java.sql.ResultSet;

**import** java.sql.SQLException;

**import** java.sql.Statement;

**public** **class** PhoenixService \{

**private** **static** String *driver* = "org.apache.phoenix.jdbc.PhoenixDriver";

**public** **static** **void** main(String\[\] args) **throws** SQLException \{

**try**\{

Class.*forName*(*driver*);

\} **catch**(ClassNotFoundException e) \{

e.printStackTrace();

Connection con = DriverManager.*getConnection*("jdbc:phoenix:192.168.110.97,192.168.110.98,192.168.110.99:2181");

Statement stmt = con.createStatement();

String sql = "select \* from \\"harve\_role\\"";

ResultSet rset = stmt.executeQuery(sql);

**while** (rset.next()) \{

System.***out***.println(rset.getString("name"));

stmt.close();

con.close();

2) 抽成工具类

**package** com.harvetech.utils;

**import** java.sql.Connection;

**import** java.sql.DriverManager;

**import** java.sql.ResultSet;

**import** java.sql.SQLException;

**import** java.sql.Statement;

**public** **class** HbaseSqlUtils \{

**private** **static** String *driver* = "org.apache.phoenix.jdbc.PhoenixDriver";

**private** **static** String *zkAddress* = "192.168.110.97,192.168.110.98,192.168.110.99:2181";

**private** **static** Connection *\_connection* = **null**;

**private** **static** HbaseSqlUtils *\_instance* = **null**;

**private** HbaseSqlUtils()\{

**try** \{

Class.*forName*(*driver*);

*\_connection* = DriverManager.*getConnection*("jdbc:phoenix:" + *zkAddress*);

\} **catch** (SQLException e) \{

e.printStackTrace();

\}**catch**(ClassNotFoundException e) \{

e.printStackTrace();

**public** **static** HbaseSqlUtils instance()\{

**if** (**null** == *\_instance*)\{

*\_instance* = **new** HbaseSqlUtils();

**return** *\_instance*;

**private** **static** Connection getConnection()\{

**return** *instance*().*\_connection*;

**public** **static** ResultSet sqlQuery(String sql) **throws** SQLException\{

Statement stmt = *getConnection*().createStatement();

ResultSet rset = stmt.executeQuery(sql);

//stmt.close();

**return** rset;

**public** **static** **void** main(String\[\] args) **throws** SQLException \{

System.***out***.println("===============================");

String sql = "select \* from \\"harve\_role\\"";

ResultSet rset = HbaseSqlUtils.*sqlQuery*(sql);

**while** (rset.next()) \{

System.***out***.println(rset.getString("name"));

System.***out***.println("-----------------------------");

String sql2 = "select \* from \\"harve\_user\\" limit 3";

ResultSet rset2 = HbaseSqlUtils.*sqlQuery*(sql2);

**while** (rset2.next()) \{

System.***out***.println(rset2.getString("name"));

System.***out***.println("==============================");

由于stmt.close后reset就取不到值，因此上面的工具类抽得不彻底，需要自定义一个HResultSet派生自ResultSet,把statement放到成员变量中，提供一个colse方法去关闭statement，调用者用完HResultSet后主动colse之。

因后面重点放在了研究与spring集成上，故没有进一步优化此工具类。

3) 与spring集成

[http://blog.csdn.net/happy\_wu/article/details/74560762][http_blog.csdn.net_happy_wu_article_details_74560762]

①　Pom依赖

<project xmlns=*"http://maven.apache.org/POM/4.0.0"* xmlns:xsi=*"http://www.w3.org/2001/XMLSchema-instance"*

xsi:schemaLocation=*"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4\_0\_0.xsd"*>

<groupId>maven</groupId>

<artifactId>maven\-web-redis</artifactId>

<version>0.0.1-SNAPSHOT</version>

<name>maven\-web-HDFS Maven Webapp</name>

<url>http://maven.apache.org</url>

<commons-lang3.version>3.5</commons-lang3.version>

<spring.version>3.2.4.RELEASE</spring.version>

<slf4j.version>1.7.10</slf4j.version>

<log4j.version>1.2.12</log4j.version>

</properties>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-web</artifactId>

<version>$\{spring.version\}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-webmvc</artifactId>

<version>$\{spring.version\}</version>

</dependency>

<groupId>org.springframework</groupId>

<artifactId>spring-jdbc</artifactId>

<version>$\{spring.version\}</version>

</dependency>

<version>$\{log4j.version\}</version>

</dependency>

<version>$\{slf4j.version\}</version>

</dependency>

<version>$\{slf4j.version\}</version>

</dependency>

<groupId>org.apache.hadoop</groupId>

<artifactId>hadoop\-client</artifactId>

</dependency>

<groupId>org.apache.phoenix</groupId>

<artifactId>phoenix\-core</artifactId>

<version>4.6.0-HBase-0.98</version>

</dependency>

<groupId>commons-dbcp</groupId>

<artifactId>commons-dbcp</artifactId>

</dependency>

</dependencies>

<build>

<finalName>maven\-web-HDFS</finalName>

</build>

</project>

②　Spring配置

<bean id=*"phoenixJdbcTemplate"* class=*"org.springframework.jdbc.core.JdbcTemplate"*>

<constructor-arg ref=*"phoenixDataSource"*/>

<qualifier value=*"phoenixJdbcTemplate"*></qualifier>

</bean>

<bean id=*"baseInterfacePonenixImpl"* class=*"com.harvetech.service.PhoenixService"*>

<property name=*"jdbcTemplate"* ref=*"phoenixJdbcTemplate"*/>

</bean>

<bean id=*"phoenixDataSource"* class=*"org.apache.commons.dbcp.BasicDataSource"*>

<property name=*"driverClassName"* value=*"org.apache.phoenix.jdbc.PhoenixDriver"*/>

<property name=*"url"* value=*"jdbc:phoenix:192.168.110.97,192.168.110.98,192.168.110.99:2181"*/>

<property name=*"username"* value=*""*/>

<property name=*"password"* value=*""*/>

<property name=*"initialSize"* value=*"20"*/>

<property name=*"maxActive"* value=*"0"*/>

<property name=*"defaultAutoCommit"* value=*"true"*/>

</bean>

③　封装JdbcTemplate

**package** com.harvetech.service;

**import** java.util.List;

**import** org.springframework.beans.factory.annotation.Autowired;

**import** org.springframework.jdbc.core.JdbcTemplate;

**public** **class** PhoenixService \{

@Autowired

**private** JdbcTemplate jdbcTemplate;

**public** PhoenixService(JdbcTemplate template) \{

**this**.jdbcTemplate = template;

**public** PhoenixService() \{

**super**();

**public** List<Object> query(String querySql, Class cls) \{

System.***out***.println(querySql);

**return** jdbcTemplate.query(querySql, **new** HarvetechRowMapper(cls));

**public** **void** update(String querySql) \{

System.***out***.println(querySql);

jdbcTemplate.update(querySql);

**public** JdbcTemplate getJdbcTemplate() \{

**return** jdbcTemplate;

**public** **void** setJdbcTemplate(JdbcTemplate jdbcTemplate) \{

**this**.jdbcTemplate = jdbcTemplate;

**package** com.harvetech.service;

**import** java.sql.ResultSet;

**import** java.sql.ResultSetMetaData;

**import** java.sql.SQLException;

**import** java.util.Date;

**import** java.util.HashMap;

**import** java.lang.reflect.Field;

**import** java.math.BigDecimal;

**import** org.springframework.jdbc.core.RowMapper;

**import** com.sun.jmx.snmp.Timestamp;

**public** **class** HarvetechRowMapper<T> **implements** RowMapper<T> \{

**private** Class<?> targetClazz;

**private** HashMap<String, Field> fieldMap;

**public** HarvetechRowMapper(Class<?> targetClazz) \{

**this**.targetClazz = targetClazz;

fieldMap = **new** HashMap<String, Field>();

Field\[\] fields = targetClazz.getDeclaredFields();

**for** (Field field : fields) \{

fieldMap.put(field.getName(), field);

**public** T mapRow(ResultSet rs, **int** arg1) **throws** SQLException \{

T obj = **null**;

**try** \{

obj = (T) targetClazz.newInstance();

**final** ResultSetMetaData metaData = rs.getMetaData();

**int** columnLength = metaData.getColumnCount();

String columnName = **null**;

**for** (**int** i = 1; i <= columnLength; i\++) \{

columnName = metaData.getColumnName(i);

Class fieldClazz = fieldMap.get(columnName).getType();

Field field = fieldMap.get(columnName);

field.setAccessible(**true**);

**if** (fieldClazz == **int**.**class** || fieldClazz == Integer.**class**) \{ // int

field.set(obj, rs.getInt(columnName));

\} **else** **if** (fieldClazz == **boolean**.**class** || fieldClazz == Boolean.**class**) \{ // boolean

field.set(obj, rs.getBoolean(columnName));

\} **else** **if** (fieldClazz == String.**class**) \{ // string

field.set(obj, rs.getString(columnName));

\} **else** **if** (fieldClazz == **float**.**class**) \{ // float

field.set(obj, rs.getFloat(columnName));

\} **else** **if** (fieldClazz == **double**.**class** || fieldClazz == Double.**class**) \{ // double

field.set(obj, rs.getDouble(columnName));

\} **else** **if** (fieldClazz == BigDecimal.**class**) \{ // bigdecimal

field.set(obj, rs.getBigDecimal(columnName));

\} **else** **if** (fieldClazz == **short**.**class** || fieldClazz == Short.**class**) \{ // short

field.set(obj, rs.getShort(columnName));

\} **else** **if** (fieldClazz == Date.**class**) \{ // date

field.set(obj, rs.getDate(columnName));

\} **else** **if** (fieldClazz == Timestamp.**class**) \{ // timestamp

field.set(obj, rs.getTimestamp(columnName));

\} **else** **if** (fieldClazz == Long.**class** || fieldClazz == **long**.**class**) \{ // long

field.set(obj, rs.getLong(columnName));

field.setAccessible(**false**);

\} **catch** (Exception e) \{

e.printStackTrace();

**return** obj;

**package** com.harvetech.model;

**public** **class** User \{

**private** String rowkey;

**private** String name;

**private** String telephone;

**private** String roleId;

**private** String roleName;

**public** String getRowkey() \{

**return** rowkey;

**public** **void** setRowkey(String rowkey) \{

**this**.rowkey = rowkey;

**public** String getName() \{

**return** name;

**public** **void** setName(String name) \{

**this**.name = name;

**public** String getTelephone() \{

**return** telephone;

**public** **void** setTelephone(String telephone) \{

**this**.telephone = telephone;

**public** String getRoleId() \{

**return** roleId;

**public** **void** setRoleId(String roleId) \{

**this**.roleId = roleId;

**public** String getRoleName() \{

**return** roleName;

**public** **void** setRoleName(String roleName) \{

**this**.roleName = roleName;

@Override

**public** String toString() \{

**return** "User \[rowkey=" + rowkey + ", name=" + name + ", telephone="

\+ telephone + ", roleId=" + roleId + ", roleName=" + roleName

\+ "\]";

④　使用示例

@Controller

**public** **class** IndexController \{

@Resource

**private** PhoenixService phoenixService;

@RequestMapping("login")

**public** String login()\{

System.***out***.println("-----------------------------");

String sql2 = "select \* from \\"harve\_user\\" limit 3";

List<Object> userList = phoenixService.query(sql2, User.**class**);

**for** (Object obj : userList)\{

User user = (User) obj;

System.***out***.println(user.toString());

System.***out***.println("==============================");

**return** "login";

[http_blog.csdn.net_happy_wu_article_details_74560762]: http://blog.csdn.net/happy_wu/article/details/74560762

phoenix_代码中使用phoenix

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Phoenix（三）Phoenix的二级索引

相关 Phoenix（二）Phoenix使用序列实现自增ID

相关 HBase，phoenix

相关 HBase+Phoenix 安装使用

相关 Phoenix使用总结

相关 phoenix的URL使用

相关 phoenix_代码中使用phoenix

相关 Apache Phoenix安装使用

相关 Phoenix使用指南

相关如何在CDH中使用Phoenix