go get github.com/spiceai/gospice/v8@latest

go get github.com/spiceai/gospice/v8@latest

import "github.com/spiceai/gospice/v8"

import "github.com/spiceai/gospice/v8"

spice := gospice.NewSpiceClient()
defer spice.Close()

if err := spice.Init(); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}

spice := gospice.NewSpiceClient()
defer spice.Close()

if err := spice.Init(); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}

if err := spice.Init(
    gospice.WithFlightAddress("grpc://my_remote_spice_instance:50051"),
); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}

if err := spice.Init(
    gospice.WithFlightAddress("grpc://my_remote_spice_instance:50051"),
); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}

reader, err := spice.Sql(
    context.Background(),
    "SELECT trip_distance, total_amount FROM taxi_trips ORDER BY trip_distance DESC LIMIT 10",
)
if err != nil {
    panic(fmt.Errorf("error querying: %w", err))
}
defer reader.Release()

for reader.Next() {
    record := reader.RecordBatch()
    defer record.Release()
    fmt.Println(record)
}

reader, err := spice.Sql(
    context.Background(),
    "SELECT trip_distance, total_amount FROM taxi_trips ORDER BY trip_distance DESC LIMIT 10",
)
if err != nil {
    panic(fmt.Errorf("error querying: %w", err))
}
defer reader.Release()

for reader.Next() {
    record := reader.RecordBatch()
    defer record.Release()
    fmt.Println(record)
}

reader, err := spice.SqlWithParams(
    context.Background(),
    "SELECT * FROM customers WHERE c_custkey > $1 LIMIT $2",
    100,  // $1: customer key threshold
    10,   // $2: limit
)
if err != nil {
    panic(fmt.Errorf("error querying: %w", err))
}
defer reader.Release()

reader, err := spice.SqlWithParams(
    context.Background(),
    "SELECT * FROM customers WHERE c_custkey > $1 LIMIT $2",
    100,  // $1: customer key threshold
    10,   // $2: limit
)
if err != nil {
    panic(fmt.Errorf("error querying: %w", err))
}
defer reader.Release()

reader, err := spice.SqlWithParams(
    ctx,
    "SELECT * FROM orders WHERE customer_id = $1 AND order_date > $2 AND total > $3",
    42,           // int
    "2024-01-01", // string
    100.50,       // float64
)

reader, err := spice.SqlWithParams(
    ctx,
    "SELECT * FROM orders WHERE customer_id = $1 AND order_date > $2 AND total > $3",
    42,           // int
    "2024-01-01", // string
    100.50,       // float64
)

import "github.com/apache/arrow-go/v18/arrow"

reader, err := spice.SqlWithParams(
    ctx,
    "SELECT * FROM financial WHERE amount >= $1",
    gospice.Decimal128Param(amountBytes, 19, 4),
)

import "github.com/apache/arrow-go/v18/arrow"

reader, err := spice.SqlWithParams(
    ctx,
    "SELECT * FROM financial WHERE amount >= $1",
    gospice.Decimal128Param(amountBytes, 19, 4),
)

ctx := context.Background()

// Unauthenticated health check
if spice.IsSpiceHealthy(ctx) {
    fmt.Println("Spice is healthy")
}

// Authenticated readiness check (requires API key for Spice Cloud)
if spice.IsSpiceReady(ctx) {
    fmt.Println("Spice is ready")
}

ctx := context.Background()

// Unauthenticated health check
if spice.IsSpiceHealthy(ctx) {
    fmt.Println("Spice is healthy")
}

// Authenticated readiness check (requires API key for Spice Cloud)
if spice.IsSpiceReady(ctx) {
    fmt.Println("Spice is ready")
}

spice := gospice.NewSpiceClient()
defer spice.Close()

if err := spice.Init(
    gospice.WithApiKey(os.Getenv("SPICE_API_KEY")),
    gospice.WithSpiceCloudAddress(),
); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}

spice := gospice.NewSpiceClient()
defer spice.Close()

if err := spice.Init(
    gospice.WithApiKey(os.Getenv("SPICE_API_KEY")),
    gospice.WithSpiceCloudAddress(),
); err != nil {
    panic(fmt.Errorf("error initializing SpiceClient: %w", err))
}