Phoenix 入门

Phoenix 数据分析入门


本篇介绍简单的Phoenix使用方法，进行初步的数据分析。
在开始之前，请先确认您已经准备好了Phoenix的运行环境，若还没有，请 参考这里

快速开始

1. 创建一个 us_population.sql 文件,用来创建表结构，内容如下CREATE TABLE IF NOT EXISTS us_population (
2.    state CHAR(2) NOT NULL,
3.    city VARCHAR NOT NULL,
4.    population BIGINT
5.    CONSTRAINT my_pk PRIMARY KEY (state, city));

• 使用Maven构建工程时，依赖如下<dependencies>
•     <dependency>
•         <groupId>com.aliyun.phoenix</groupId>
•         <artifactId>ali-phoenix-core</artifactId>
•         <version>4.11.0-AliHBase-1.1-0.1</version>
•     </dependency>
• </dependencies>
• 
  

• 测试程序import java.sql.Connection;
• import java.sql.DriverManager;
• import java.sql.ResultSet;
• import java.sql.SQLException;
• import java.sql.PreparedStatement;
• import java.sql.Statement;
• /**
• * create table, create index, insert data, select table.
• */
• public class TestPhoenixJDBC {
•     public static void main(String[] args) {
•         try {
•             Connection con =
•                     DriverManager.getConnection("jdbc:phoenix:n-proxy-pub-zk1, n-proxy-pub-zk2,n-proxy-pub-zk3");
•             Statement stmt = con.createStatement();
•             stmt.execute("drop table if exists test");
•             stmt.execute("create table test (mykey integer not null primary key, mycolumn varchar)");
•             stmt.execute("create index test_idx on test(mycolumn)");
•             stmt.executeUpdate("upsert into test values (1,'World!')");
•             stmt.executeUpdate("upsert into test values (2,'Hello')");
•             stmt.executeUpdate("upsert into test values (3,'World!')");
•             con.commit();
•             PreparedStatement statement = con.prepareStatement("select mykey from test where mycolumn='Hello'");
•             ResultSet rset = statement.executeQuery();
•             while (rset.next()) {
•                 System.out.println(rset.getInt(1));
•             }
•             stmt.close();
•             rset.close();
•             con.close();
•         } catch (SQLException e) {
•             e.printStackTrace();
•         }
•     }
• }
• 
  

• 
  编译执行
  javac TestPhoenixJDBC.java
  java -cp “../phoenix-4.11.0-AliHBase-1.1-0.1-client.jar:.” TestPhoenixJDBC
  输出：2