dm-database-parser-sqllog 2.0.4

一个高性能的达梦数据库 sqllog 日志解析库，支持 FilterBuilder 全字段链式过滤、AsyncLogParser tokio 异步接口和 LogParserBuilder 链式配置
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
52
53
54
55
56
57
58
59
60

use crate::error::ParseError;
use crate::filter::builder::Filter;
use crate::record::Sqllog;

pub(crate) fn filter_by_exec_time<I>(
    iter: I,
    min_ms: f32,
) -> impl Iterator<Item = Result<Sqllog, ParseError>>
where
    I: Iterator<Item = Result<Sqllog, ParseError>>,
{
    iter.filter(move |item| match item {
        Ok(sqllog) => sqllog.exectime >= min_ms,
        Err(_) => false,
    })
}

pub(crate) fn filter_by_sql_contains<'a, I>(
    iter: I,
    pattern: &str,
) -> impl Iterator<Item = Result<Sqllog, ParseError>> + 'a
where
    I: Iterator<Item = Result<Sqllog, ParseError>> + 'a,
{
    let pattern = pattern.to_string();
    iter.filter(move |item| match item {
        Ok(sqllog) => sqllog.sql.contains(&pattern),
        Err(_) => false,
    })
}

/// 使用 Filter 过滤迭代器：Ok 记录通过 Filter::matches 判定，Err 记录被丢弃。
///
/// 错误记录处理行为与 filter_by_exec_time / filter_by_sql_contains 一致。
pub(crate) fn apply_filter<I>(
    iter: I,
    filter: Filter,
) -> impl Iterator<Item = Result<Sqllog, ParseError>>
where
    I: Iterator<Item = Result<Sqllog, ParseError>>,
{
    iter.filter(move |item| match item {
        Ok(sqllog) => filter.matches(sqllog),
        Err(_) => false,
    })
}

/// 与 apply_filter 相同，但保留错误记录（Err 透传，Ok 经过 Filter 判定）。
pub(crate) fn apply_filter_keep_errors<I>(
    iter: I,
    filter: Filter,
) -> impl Iterator<Item = Result<Sqllog, ParseError>>
where
    I: Iterator<Item = Result<Sqllog, ParseError>>,
{
    iter.filter(move |item| match item {
        Ok(sqllog) => filter.matches(sqllog),
        Err(_) => true,
    })
}