Apache Phoenix Core

<dependency>
    <groupId>org.apache.phoenix</groupId>
    <artifactId>phoenix-core</artifactId>
    <version>5.2.1</version>
</dependency>

// Primary JDBC driver
import org.apache.phoenix.jdbc.PhoenixDriver;
import org.apache.phoenix.jdbc.PhoenixConnection;

// Query services
import org.apache.phoenix.query.ConnectionQueryServices;
import org.apache.phoenix.query.QueryServices;

// Schema management
import org.apache.phoenix.schema.PTable;
import org.apache.phoenix.schema.PMetaData;

// Data types
import org.apache.phoenix.schema.types.PDataType;

// Standard JDBC imports
import java.sql.*;

import org.apache.phoenix.jdbc.PhoenixDriver;
import java.sql.*;

// Register the Phoenix driver
Class.forName("org.apache.phoenix.jdbc.PhoenixDriver");

// Connect to HBase via Phoenix
String url = "jdbc:phoenix:localhost:2181";
Connection connection = DriverManager.getConnection(url);

// Create a statement
Statement stmt = connection.createStatement();

// Execute queries
ResultSet rs = stmt.executeQuery("SELECT * FROM my_table");
while (rs.next()) {
    String name = rs.getString("name");
    int value = rs.getInt("value");
    // Process results
}

Statement stmt = connection.createStatement();

// Create a Phoenix table (maps to HBase table)
stmt.executeUpdate(
    "CREATE TABLE users (" +
    "  id BIGINT NOT NULL, " +
    "  name VARCHAR, " +
    "  email VARCHAR, " +
    "  created_date DATE " +
    "  CONSTRAINT pk PRIMARY KEY (id))"
);

// Driver registration and connection management
PhoenixDriver driver = new PhoenixDriver();
PhoenixConnection connection = driver.connect(url, properties);

// Statement execution with monitoring
PhoenixPreparedStatement stmt = connection.prepareStatement(sql);
PhoenixResultSet results = stmt.executeQuery();

// Query services for metadata and execution
ConnectionQueryServices queryServices = connection.getQueryServices();

// Query compilation and planning
QueryCompiler compiler = new QueryCompiler();
QueryPlan plan = compiler.compile(statement, context);

// Table and column metadata
PTable table = connection.getTable(tableName);
PColumn column = table.getColumn(columnName);

// Metadata cache management
PMetaData metaData = connection.getMetaData();
PTableRef tableRef = metaData.getTableRef(tableName);

// Core data types
PDataType varchar = PVarchar.INSTANCE;
PDataType integer = PInteger.INSTANCE;
PDataType decimal = PDecimal.INSTANCE;

// Array types
PDataType varcharArray = PVarcharArray.INSTANCE;
PDataType integerArray = PIntegerArray.INSTANCE;

// Exception construction
SQLExceptionInfo.Builder builder = new SQLExceptionInfo.Builder(code);
SQLException exception = builder.setMessage(message).build().buildException();

// Schema-specific exceptions
throw new TableNotFoundException(tableName);
throw new ColumnNotFoundException(columnName);

// Expression evaluation
Expression expression = LiteralExpression.newConstant(value);
ImmutableBytesWritable result = new ImmutableBytesWritable();
boolean success = expression.evaluate(tuple, result);

// Function expressions
FunctionExpression function = new SomeScalarFunction(arguments);

// Execution planning and iteration
ResultIterator iterator = queryPlan.iterator();
Tuple tuple = iterator.next();

// Mutation state management
MutationState mutationState = connection.getMutationState();
mutationState.commit();

// Configuration properties
ConnectionProperty property = ConnectionProperty.QUERY_TIMEOUT;
String value = connection.getClientInfo(property.toString());

// Utility operations
byte[] bytes = ByteUtil.concat(array1, array2);
String formatted = SchemaUtil.getTableName(schemaName, tableName);

// Coprocessor interfaces
PhoenixCoprocessor coprocessor = new MetaDataEndpointImpl();

// Index building and management
IndexBuilder indexBuilder = new PhoenixIndexBuilder();
IndexWriter indexWriter = new ParallelWriterIndexCommitter();

// MapReduce input/output formats
PhoenixInputFormat inputFormat = new PhoenixInputFormat();
PhoenixOutputFormat outputFormat = new PhoenixOutputFormat();

// Bulk loading tools
BulkLoadTool bulkLoader = new BulkLoadTool();

// Metrics collection
MetricType metricType = MetricType.QUERY_TIME;
GlobalClientMetrics.GLOBAL_QUERY_TIME.increment(duration);

// Table-specific metrics
TableMetricsManager metricsManager = TableMetricsManager.getInstance();

// Transaction client interfaces
PhoenixTransactionClient txClient = TransactionFactory.getTransactionClient();

// Transaction context management
TransactionContext txContext = txClient.newTransactionContext();