diff --git a/hbase-starter/pom.xml b/hbase-starter/pom.xml
index e898ab6..73e2418 100644
--- a/hbase-starter/pom.xml
+++ b/hbase-starter/pom.xml
@@ -35,5 +35,11 @@
4.12
test
+
+
+ org.apache.phoenix
+ phoenix-core
+ 4.14.0-HBase-1.2
+
\ No newline at end of file
diff --git a/hbase-starter/src/test/java/TestPhoenixJDBC.java b/hbase-starter/src/test/java/TestPhoenixJDBC.java
new file mode 100644
index 0000000..fde0fae
--- /dev/null
+++ b/hbase-starter/src/test/java/TestPhoenixJDBC.java
@@ -0,0 +1,61 @@
+
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+
+/**
+ * Desc: create table, create index, insert data, select table.
+ *
+ * 如果出现错误:
+ * Mutable secondary indexes must have the hbase.regionserver.wal.codec property set to org.apache.hadoop.hbase.regionserver.wal.IndexedWALEditCodec in the hbase-sites.xml of every region server. tableName=TEST_IDX
+ *
+ * 解决办法: hbase-site.xml中加入
+ *
+ * hbase.regionserver.wal.codec
+ * org.apache.hadoop.hbase.regionserver.wal.IndexedWALEditCodec
+ *
+ */
+public class TestPhoenixJDBC {
+
+
+ private static String driver = "org.apache.phoenix.jdbc.PhoenixDriver";
+
+
+ public static void main(String[] args) throws SQLException {
+
+
+ Connection conn = null;
+ Statement stmt = null;
+ ResultSet rs = null;
+ try {
+ Class.forName(driver);
+ } catch (ClassNotFoundException e) {
+ e.printStackTrace();
+ }
+ conn = DriverManager.getConnection("jdbc:phoenix:localhost:2181");
+ stmt = conn.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!')");
+ stmt.executeUpdate("upsert into test values (3,'====World!====')");
+ conn.commit();
+ rs = stmt.executeQuery("select mykey from test where mycolumn='Hello'");
+ while (rs.next()) {
+ System.out.println(rs.getInt(1));
+ }
+ stmt.close();
+ rs.close();
+ conn.close();
+
+
+ }
+
+
+}
\ No newline at end of file