groovyとApache Phoenixでテーブル作成とデータを挿入する

groovyとApache Phoenixでテーブル作成とデータを挿入するには、以下のようなコードを実行します。

サンプルコード

import groovy.sql.Sql
import java.sql.*

sql = Sql.newInstance(
  "jdbc:phoenix:localhost",
  "",
  "",
  "org.apache.phoenix.jdbc.PhoenixDriver")

stmt_create = """
CREATE TABLE CUSTOMER
(
  CUSTOMER_CD CHAR(6) NOT NULL,
  FIRST_NAME VARCHAR,
  LAST_NAME VARCHAR,
  ENROLL_DATE DATE,
  BIRTH_DATE DATE,
  CONSTRAINT PK_CUSTOMER PRIMARY KEY (CUSTOMER_CD)
)
"""
sql.execute(stmt_create)

stmt_ins1 = """
UPSERT INTO CUSTOMER VALUES (
'000001', '一郎', '試験', TO_DATE('20140201', 'yyyyMMdd'),
TO_DATE('19900201', 'yyyyMMdd')
)
"""
sql.execute(stmt_ins1)

stmt_ins2 = """
UPSERT INTO CUSTOMER VALUES (
'000002', '二郎', '試験', TO_DATE('20140205', 'yyyyMMdd'),
TO_DATE('19920110', 'yyyyMMdd')
)
"""
sql.execute(stmt_ins2)
sql.commit()

query = """
select * from CUSTOMER
"""
sql.eachRow(query){ row ->
  println row
}

クライアント設定
phoenix-4.1.0-bin.tar.gzを解凍しphoenix-4.1.0-bin/hadoop2/phoenix-4.1.0-client-hadoop2.jarを~/.groovy/libなどにコピーします。

動作環境
groovy 2.3.6, JDK 7 Update 65, Hadoop 2.5.0, zookeeper 3.4.6, hbase 0.98.5, phoenix 4.1.0