| Java Flight SQL package |
The Java Flight SQL client integrates with Java applications to query and retrieve data from Flight database servers using RPC and SQL. |
| influxdb3_enterprise |
| name |
parent |
identifier |
| Java Flight SQL |
Arrow Flight clients |
java-flightsql-client |
|
|
| Flight client |
| Java |
| gRPC |
| SQL |
| Flight SQL |
|
201 |
| /influxdb3/enterprise/reference/client-libraries/v3/java/ |
|
| /influxdb3/enterprise/reference/client-libraries/flight-sql/java-flightsql/ |
|
```java
public class Query {
public static void main(String[] args) {
String query = "SELECT * FROM home";
Location location = Location.forGrpcTls(HOST, 443);
CredentialCallOption auth = new CredentialCallOption(new BearerCredentialWriter(TOKEN));
BufferAllocator allocator = new RootAllocator(Long.MAX_VALUE);
FlightClientMiddleware.Factory f = info -> new FlightClientMiddleware() {
@Override
public void onBeforeSendingHeaders(CallHeaders outgoingHeaders) {
outgoingHeaders.insert(DATABASE_FIELD, DATABASE_NAME);
}
};
FlightClient client = FlightClient.builder(allocator, location)
.intercept(f)
.build();
FlightSqlClient sqlClient = new FlightSqlClient(client);
FlightInfo flightInfo = sqlClient.execute(query, auth);
}
}
```
|
/shared/influxdb-client-libraries-reference/flight/java-flightsql.md |