Test.java

import com.zaxxer.hikari.HikariDataSource;
import org.apache.hadoop.hbase.thrift.generated.BatchMutation;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;

public class Test
{
    private Connection connection;

    public static void main(String [] args)
    {
        HikariDataSource ds = new HikariDataSource();

        ds.setJdbcUrl("jdbc:phoenix:zookeeper");
        ds.setDriverClassName("org.apache.phoenix.jdbc.PhoenixDriver");
        ds.setAutoCommit(false);

        try {
            this.connection = ds.getConnection();

            System.out.println("Connection is valid: " + this.connection.isValid(10));
        }
        catch(SQLException e)
        {
            e.printStackTrace();
        }

        try {
            PreparedStatement statement = this.connection.prepareStatement("UPSERT INTO \"events\"(\"uuid\",\"event\") VALUES(?, ?)");

            statement.setString(1, "toto");
            statement.setString(2, "click");

            statement.executeUpdate();

            this.connection.commit();

            this.connection.close();

        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}