[−][src]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 |
AvroConfiguration | ODBC to Avor record processing configuration and internal state. |
AvroConfigurationBuilder | Helper object that allows to build |
AvroName | Represents valid Avro name as defined by standard. |
AvroRowRecord | Table row represented as |
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 |
AvroRowRecordIter | Extension functions for iterators of |