Struct ExternalDriver

pub struct ExternalDriver { /* private fields */ }

Communicates with a subprocess via its stdin/stdout.

Protocol

Sends JSON stream:

{"sql":"SELECT 1,2"}

Receives JSON stream:

If the query succeeds:

{"result":[["1","2"]]}

If the query fails:

{"err":"..."}

Implementations

impl ExternalDriver

pub async fn connect(cmd: Command) -> Result<Self, ExternalDriverError>

Spawn and pipe into the subprocess with the given cmd.

Trait Implementations

impl AsyncDB for ExternalDriver

type Error = ExternalDriverError

The error type of SQL execution.

type ColumnType = DefaultColumnType

The type of result columns

fn run<'life0, 'life1, 'async_trait>( &'life0 mut self, sql: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<DBOutput<Self::ColumnType>, ExternalDriverError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Async run a SQL query and return the output.

fn engine_name(&self) -> &str

Engine name of current database.

fn sleep<'async_trait>( dur: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

Runner calls this function to perform sleep.

fn run_command<'async_trait>( command: Command, ) -> Pin<Box<dyn Future<Output = Result<Output>> + Send + 'async_trait>>

Runner calls this function to run a system command.

impl Drop for ExternalDriver

fn drop(&mut self)

Executes the destructor for this type.