Class

ArrowFlightSQLServer

Description 

abstract class ArrowFlightSQL.Server : ArrowFlight.Server
  implements ArrowFlight.Servable {
  /* No available fields */
}

No description available.

Ancestors

Implements

Instance methods

gaflightsql_server_close_prepared_statement
No description available.

since: 14.0.0

gaflightsql_server_create_prepared_statement
No description available.

since: 14.0.0

gaflightsql_server_do_get_statement
No description available.

since: 9.0.0

gaflightsql_server_do_put_command_statement_update
No description available.

since: 13.0.0

gaflightsql_server_do_put_prepared_statement_update
No description available.

since: 14.0.0

gaflightsql_server_get_flight_info_statement
No description available.

since: 9.0.0

Methods inherited from GAFlightServer (8)
gaflight_server_do_get
No description available.
gaflight_server_do_put

Processes a stream of IPC payloads sent from a client.

gaflight_server_get_flight_info
No description available.
gaflight_server_get_port
No description available.
gaflight_server_list_flights
No description available.
gaflight_server_listen
No description available.
gaflight_server_shutdown

Shuts down the serve. This function can be called from signal handler or another thread.

gaflight_server_wait
No description available.
Methods inherited from GObject (43)

Please see GObject for a full list of methods.

Signals

Signals inherited from GObject (1)
GObject::notify

The notify signal is emitted on an object when one of its properties has its value set through g_object_set_property(), g_object_set(), et al.

Class structure 

struct ArrowFlightSQLServerClass {
  GAFlightServerClass parent_class;
  GAFlightInfo* (* get_flight_info_statement) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLStatementQuery* command,
    GAFlightDescriptor* descriptor,
    GError** error
  );
  GAFlightDataStream* (* do_get_statement) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLStatementQueryTicket* ticket,
    GError** error
  );
  gint64 (* do_put_command_statement_update) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLStatementUpdate* command,
    GError** error
  );
  gint64 (* do_put_prepared_statement_update) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLPreparedStatementUpdate* command,
    GAFlightMessageReader* reader,
    GError** error
  );
  GAFlightSQLCreatePreparedStatementResult* (* create_prepared_statement) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLCreatePreparedStatementRequest* request,
    GError** error
  );
  void (* close_prepared_statement) (
    GAFlightSQLServer* server,
    GAFlightServerCallContext* context,
    GAFlightSQLClosePreparedStatementRequest* request,
    GError** error
  );
  
}

No description available.

Class members
parent_class: GAFlightServerClass

No description available.

get_flight_info_statement: GAFlightInfo* (* get_flight_info_statement) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLStatementQuery* command, GAFlightDescriptor* descriptor, GError** error )

A virtual function to implement GetFlightInfoStatement API that gets a GAFlightInfo for executing a SQL query.

do_get_statement: GAFlightDataStream* (* do_get_statement) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLStatementQueryTicket* ticket, GError** error )

A virtual function to implement DoGetStatement API that gets a GAFlightDataStream containing the query results.

do_put_command_statement_update: gint64 (* do_put_command_statement_update) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLStatementUpdate* command, GError** error )

A virtual function to implement DoPutCommandStatementUpdate API that executes an update SQL statement.

do_put_prepared_statement_update: gint64 (* do_put_prepared_statement_update) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLPreparedStatementUpdate* command, GAFlightMessageReader* reader, GError** error )

A virtual function to implement DoPutPreparedStatementUpdate API that executes an update prepared statement.

create_prepared_statement: GAFlightSQLCreatePreparedStatementResult* (* create_prepared_statement) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLCreatePreparedStatementRequest* request, GError** error )

A virtual function to implement CreatePreparedStatement API that creates a prepared statement.

close_prepared_statement: void (* close_prepared_statement) ( GAFlightSQLServer* server, GAFlightServerCallContext* context, GAFlightSQLClosePreparedStatementRequest* request, GError** error )

A virtual function to implement ClosePreparedStatement API that closes a prepared statement.

Virtual methods

ArrowFlightSQL.ServerClass.close_prepared_statement

A virtual function to implement ClosePreparedStatement API that closes a prepared statement.

since: 14.0.0

ArrowFlightSQL.ServerClass.create_prepared_statement

A virtual function to implement CreatePreparedStatement API that creates a prepared statement.

since: 14.0.0

ArrowFlightSQL.ServerClass.do_get_statement

A virtual function to implement DoGetStatement API that gets a GAFlightDataStream containing the query results.

since: 9.0.0

ArrowFlightSQL.ServerClass.do_put_command_statement_update

A virtual function to implement DoPutCommandStatementUpdate API that executes an update SQL statement.

since: 13.0.0

ArrowFlightSQL.ServerClass.do_put_prepared_statement_update

A virtual function to implement DoPutPreparedStatementUpdate API that executes an update prepared statement.

since: 14.0.0

ArrowFlightSQL.ServerClass.get_flight_info_statement

A virtual function to implement GetFlightInfoStatement API that gets a GAFlightInfo for executing a SQL query.

since: 9.0.0