mysql_binlog 0.4.0

Parser for the MySQL binlog format
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

use std::collections::BTreeMap;

use crate::column_types::ColumnType;

#[derive(Debug)]
/// Opaque reference to a table map, intended to be consumed by [`Event`]
pub struct SingleTableMap {
    pub(crate) schema_name: String,
    pub(crate) table_name: String,
    pub(crate) columns: Vec<ColumnType>,
}

/// A MySQL binary log includes Table Map events; the first time a table is referenced in a given
/// binlog, a TME will be emitted describing the fields of that table and assigning them to a
/// binlog-unique identifier. The TableMap object is used to keep track of that mapping.
pub struct TableMap {
    inner: BTreeMap<u64, SingleTableMap>,
}

impl Default for TableMap {
    fn default() -> Self {
        Self::new()
    }
}

impl TableMap {
    pub fn new() -> Self {
        TableMap {
            inner: BTreeMap::new(),
        }
    }

    pub fn handle(
        &mut self,
        table_id: u64,
        schema_name: String,
        table_name: String,
        columns: Vec<ColumnType>,
    ) {
        let map = SingleTableMap {
            schema_name,
            table_name,
            columns,
        };
        self.inner.insert(table_id, map);
    }

    pub fn get(&self, table_id: u64) -> Option<&SingleTableMap> {
        self.inner.get(&table_id)
    }
}