Maven依赖

  1. <!--注意 底层引用的\org\glassfish\javax.el\3.0.1-b06-SNAPSHOT在仓库中已经移除了我们这里引用其稳定版本-->
  2. <dependency>
  3.             <groupId>org.apache.phoenix</groupId>
  4.             <artifactId>phoenix-spark</artifactId>
  5.             <version>4.14.2-HBase-1.3</version>
  6.             <exclusions>
  7.                 <exclusion>
  8.                     <groupId>org.glassfish</groupId>
  9.                     <artifactId>javax.el</artifactId>
  10.                 </exclusion>
  11.             </exclusions>
  12.         </dependency>
  13.           <dependency>
  14.             <groupId>org.glassfish</groupId>
  15.             <artifactId>javax.el</artifactId>
  16.             <version>3.0.1-b06</version>
  17.                  </dependency>
  19.             <dependency>
  20.             <groupId>com.alibaba</groupId>
  21.             <artifactId>fastjson</artifactId>
  22.             <version>1.2.62</version>
  23.         </dependency>

查询

  2. import java.sql.{Connection, DriverManager, PreparedStatement, ResultSet, ResultSetMetaData}
  3. import com.alibaba.fastjson.JSONObject
  4. import scala.collection.mutable.ListBuffer
  6. object PhoenixUtil {
  8.   def main(args: Array[String]): Unit = {
  9.     //查询语句 select * from "ns1"."us_population"
  10.     val list: List[JSONObject] = queryList("select * from \"ns1\".\"us_population\"")
  11.     println(list)
  12.   }
  14.   private val phoenixUrl = "jdbc:phoenix:zjj101,zjj102,zjj103:2181"
  16.   def queryList(sql: String): List[JSONObject] = {
  17.     val rsList: ListBuffer[JSONObject] = new ListBuffer[JSONObject]
  18.     //注册驱动
  19.     Class.forName("org.apache.phoenix.jdbc.PhoenixDriver")
  20.     //建立连接
  21.     val conn: Connection = DriverManager.getConnection(phoenixUrl)
  22.     //创建数据库操作对象
  23.     val ps: PreparedStatement = conn.prepareStatement(sql)
  24.     //执行SQL语句
  25.     val rs: ResultSet = ps.executeQuery()
  26.     val rsMetaData: ResultSetMetaData = rs.getMetaData
  27.     //处理结果集
  28.     while (rs.next()) {
  29.       val usPopulation = new JSONObject()
  30.       for (i <- 1 to rsMetaData.getColumnCount) {
  31.         usPopulation.put(rsMetaData.getColumnName(i), rs.getObject(i))
  32.       }
  33.       rsList.append(usPopulation)
  34.     }
  35.     //释放资源
  36.     rs.close()
  37.     ps.close()
  38.     conn.close()
  39.     rsList.toList
  40.   }
  43. }

执行输出结果:

List({“POPULATION”:3844829,”CITY”:”Los Angeles”,”STATE”:”CA”}, {“POPULATION”:2842518,”CITY”:”Chicago”,”STATE”:”IL”}, {“POPULATION”:8143197,”CITY”:”NewYork”,”STATE”:”NY”})