Phoenix is an apache project that attempts to provide an ANSI SQL standard interface to HBase data. This is just a quick implementation of it. Notice it has transactional semantics.<\/p>\n
Code below…<\/p>\n
\r\nimport java.sql.*;\r\nimport java.util.*;\r\n\r\npublic class phoenixTest {\r\n public static void main(String args[]) throws Exception {\r\n Connection conn;\r\n Properties prop = new Properties();\r\n Class.forName(\"org.apache.phoenix.jdbc.PhoenixDriver\");\r\n conn = DriverManager.getConnection(\"jdbc:phoenix:localhost:\/hbase-unsecure\");\r\n System.out.println(\"got connection\");\r\n ResultSet rst = conn.createStatement().executeQuery(\"select * from stock_symbol\");\r\n while (rst.next()) {\r\n System.out.println(rst.getString(1) + \" \" + rst.getString(2));\r\n }\r\n System.out.println(conn.createStatement().executeUpdate(\"delete from stock_symbol\"));\r\n conn.commit();\r\n rst = conn.createStatement().executeQuery(\"select * from stock_symbol\");\r\n while (rst.next()) {\r\n System.out.println(rst.getString(1) + \" \" + rst.getString(2));\r\n }\r\n System.out.println(conn.createStatement().executeUpdate(\"upsert into stock_symbol values('IBM','International Business Machines')\"));\r\n conn.commit();\r\n }\r\n}\r\n<\/pre>\n…with the call example below…<\/p>\n
\r\n[root@sandbox ~]# env | grep CLASSPATH\r\nCLASSPATH=.:\/root\/phoenix-4.1.0-bin\/hadoop2\/phoenix-4.1.0-client-hadoop2.jar\r\n[root@sandbox ~]# java phoenixTest\r\nlog4j:WARN No appenders could be found for logger (org.apache.hadoop.conf.Configuration.deprecation).\r\nlog4j:WARN Please initialize the log4j system properly.\r\nlog4j:WARN See http:\/\/logging.apache.org\/log4j\/1.2\/faq.html#noconfig for more info.\r\ngot connection\r\nIBM International Business Machines\r\n1\r\n1\r\n[root@sandbox ~]#\r\n<\/pre>\n","protected":false},"excerpt":{"rendered":"Phoenix is an apache project that attempts to provide an ANSI SQL standard interface to HBase data. This is just a quick implementation of it. Notice it has transactional semantics. Code below… import java.sql.*; import java.util.*; public class phoenixTest {…<\/p>\n