From 735034550dbaacabc2df2eb1e76de0dc4e96f419 Mon Sep 17 00:00:00 2001
From: huzekang <1040080742@qq.com>
Date: Tue, 2 Jul 2019 11:38:22 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8A=A0=E5=85=A5Phoenix=E5=8E=9F=E7=94=9Fapi?=
 =?UTF-8?q?=E4=BE=8B=E5=AD=90=EF=BC=8C=E8=B0=83=E6=95=B4pom?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/phoenix/PhoenixTest.java    | 29 +++++++++++++++++++
 .../test/java/phoenix_mybatis/BaseTest.java   |  3 +-
 2 files changed, 31 insertions(+), 1 deletion(-)
 create mode 100644 hbase-starter/src/main/java/phoenix/PhoenixTest.java

diff --git a/hbase-starter/src/main/java/phoenix/PhoenixTest.java b/hbase-starter/src/main/java/phoenix/PhoenixTest.java
new file mode 100644
index 0000000..eb58ebc
--- /dev/null
+++ b/hbase-starter/src/main/java/phoenix/PhoenixTest.java
@@ -0,0 +1,29 @@
+package phoenix;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+
+/**
+ *  直接使用原生jdbc访问Phoenix
+ */
+public class PhoenixTest {
+
+  public static void main(String[] args) throws Exception {
+    Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");
+    // 写上zookeeper地址
+    Connection connection = DriverManager.getConnection("jdbc:phoenix:localhost:2181");
+
+    PreparedStatement statement = connection.prepareStatement("select * from TEST");
+
+    ResultSet resultSet = statement.executeQuery();
+
+    while (resultSet.next()) {
+      System.out.println(resultSet.getString("MYCOLUMN"));
+    }
+
+    statement.close();
+    connection.close();
+  }
+}
diff --git a/hbase-starter/src/test/java/phoenix_mybatis/BaseTest.java b/hbase-starter/src/test/java/phoenix_mybatis/BaseTest.java
index 8aaa871..aff2e99 100755
--- a/hbase-starter/src/test/java/phoenix_mybatis/BaseTest.java
+++ b/hbase-starter/src/test/java/phoenix_mybatis/BaseTest.java
@@ -14,7 +14,8 @@
 import java.util.List;
 
 /**
- *  on 18-3-11.
+ *  需要手动在Phoenix中创建USER_INFO表
+ *  create table USER_INFO (id integer not null primary key, name varchar);
  */
 @RunWith(SpringJUnit4ClassRunner.class)
 @Import(PhoenixDataSourceConfig.class)