Struct SqlServerProtocol 

pub struct SqlServerProtocol {}

SQL Server protocol adapter implementation

Implementations

impl SqlServerProtocol

pub fn new() -> Self

Create a new SQL Server protocol adapter

pub fn parse_login_packet( &self, data: &[u8], ) -> NirvResult<HashMap<String, String>>

Parse a TDS login packet

pub fn parse_sql_batch(&self, data: &[u8]) -> NirvResult<String>

Parse a SQL batch packet

pub fn create_colmetadata(&self, columns: &[ColumnMetadata]) -> Vec<u8>

Create column metadata token

pub fn create_row(&self, row: &Row, columns: &[ColumnMetadata]) -> Vec<u8>

Create a data row token

pub fn create_done(&self, status: u16, cur_cmd: u16, row_count: u64) -> Vec<u8>

Create a DONE token

pub fn create_error_response( &self, error_number: u32, message: &str, severity: u8, ) -> Vec<u8>

Create an error response

pub fn value_to_tds_type(&self, value: &Value) -> u8

Convert Value to TDS type code

Trait Implementations

impl Debug for SqlServerProtocol

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SqlServerProtocol

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolAdapter for SqlServerProtocol

fn accept_connection<'life0, 'async_trait>( &'life0 self, stream: TcpStream, ) -> Pin<Box<dyn Future<Output = NirvResult<Connection>> + Send + 'async_trait>>

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

Accept a new connection and perform initial handshake

fn authenticate<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, credentials: Credentials, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

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

Authenticate a connection with provided credentials

fn handle_query<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 Connection, _query: ProtocolQuery, ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolResponse>> + Send + 'async_trait>>

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

Handle a query from the client and return a response

fn get_protocol_type(&self) -> ProtocolType

Get the protocol type this adapter handles

fn parse_message<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _conn: &'life1 Connection, data: &'life2 [u8], ) -> Pin<Box<dyn Future<Output = NirvResult<ProtocolQuery>> + Send + 'async_trait>>

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

Parse protocol-specific message into internal representation

fn format_response<'life0, 'life1, 'async_trait>( &'life0 self, _conn: &'life1 Connection, result: QueryResult, ) -> Pin<Box<dyn Future<Output = NirvResult<Vec<u8>>> + Send + 'async_trait>>

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

Format internal query result into protocol-specific response

fn terminate_connection<'life0, 'life1, 'async_trait>( &'life0 self, conn: &'life1 mut Connection, ) -> Pin<Box<dyn Future<Output = NirvResult<()>> + Send + 'async_trait>>

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

Handle connection termination