加入Phoenix例子

hbase-starter/pom.xml

@@ -35,5 +35,11 @@
             <version>4.12</version>
             <scope>test</scope>
         </dependency>
+
+        <dependency>
+            <groupId>org.apache.phoenix</groupId>
+            <artifactId>phoenix-core</artifactId>
+            <version>4.14.0-HBase-1.2</version>
+        </dependency>
     </dependencies>
 </project>

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中加入
+ *              <property>
+ *                  <name>hbase.regionserver.wal.codec</name>
+ *                  <value>org.apache.hadoop.hbase.regionserver.wal.IndexedWALEditCodec</value>
+ *              </property> 
+ */
+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();
+
+
+    }
+
+
+}