Crate odbc_avro

This Rust crate extends odbc-iter crate functionality with ability to query Avro records and write entire ResultSet as Avro “Object Container File” data.

Example usage

Write Avro object container file data from query.

use odbc_iter::Odbc;
use odbc_avro::{AvroConfiguration, AvroResultSet, Codec};

let mut connection = Odbc::connect(&std::env::var("DB_CONNECTION_STRING").expect("no DB_CONNECTION_STRING env set")).expect("connect to database");

// Configure handler with default `AvroConfiguration`.
let mut db = connection.handle_with_configuration(AvroConfiguration::default());

// For example query all table data from database.
let data = db.query(r#"SELECT * FROM sys.tables"#).expect("query failed");

// You can use `File` instead to write Avro object container file or any other `Write` type.
let mut buf = Vec::new();

// Write all rows as uncompressed Avro object container file where rows are represented as record object named "result_set".
data.write_avro(&mut buf, Codec::Null, "result_set").expect("write worked");

// Now `buf` contains all rows from `sys.tables` table serialized Avro object container file.

!

Structs

AvroColumn

Table column represented as AvroValue.

AvroConfiguration

ODBC to Avor record processing configuration and internal state.

AvroConfigurationBuilder

Helper object that allows to build AvroConfiguration with custom settings.

AvroName

Represents valid Avro name as defined by standard.

AvroRowRecord

Table row represented as AvroValue::Record.

NameNormalizationError

State

Internal state used to cache row metadata.

Writer

Main interface for writing Avro formatted values.

Enums

AvroSchema

Represents any valid Avro schema More information about Avro schemas can be found in the Avro Specification

AvroValue

Represents any valid Avro value More information about Avro values can be found in the Avro Specification

Codec

The compression codec used to compress blocks.

OdbcAvroError

Errors that this library can produce.

ReformatJson

Specification of JSON column data is reformatted.

TimestampFormat

Specification of TIMESTAMP column representation.

Traits

AvroResultSet

Extension functions for ResultSet.

AvroRowRecordIter

Extension functions for iterators of AvroRowRecord items.