starainrt
8469c11373
- 将臃肿的 parse.go 按职责拆分为多个模块：
parse_types.go、parse_io.go、parse_event_convert.go、parse_stream.go、parse_filter.go
- parse.go 保留为模块入口说明，提升可维护性与可读性
- 修复事务状态被覆盖问题（BEGIN/COMMIT/ROLLBACK 不再被重置为 PREPARE）
- 增加 include-tables 与 exclude-tables 互斥校验，同时配置时直接报配置错误
- 强化表匹配器模式校验，并补充非法模式测试
- 在明细过滤后重算事务统计（RowsCount/StartPos/EndPos/Size），避免统计失真
- 增加 TABLE_MAP 事件转换，补充列元信息透传（ColumnTypes/ColumnCollationIDs）
- 基于 unsigned 元数据规范化行值，避免无符号整型被渲染为负数
- 优化事件解析报错信息：增加有界 body 十六进制预览
- 补充单元测试：payload/tablemap 转换、unsigned 规范化、过滤逻辑、IO 预览
34 lines
873 B
Go
34 lines
873 B
Go
package binlog
|
|
|
|
import (
|
|
"strings"
|
|
"testing"
|
|
)
|
|
|
|
func TestFormatBodyPreview(t *testing.T) {
|
|
if got := formatBodyPreview(nil, 256); got != "len=0" {
|
|
t.Fatalf("unexpected empty preview: %q", got)
|
|
}
|
|
|
|
small := []byte{0x01, 0x02, 0xAB}
|
|
got := formatBodyPreview(small, 8)
|
|
if !strings.Contains(got, "len=3") || !strings.Contains(got, "0102ab") {
|
|
t.Fatalf("unexpected preview for small body: %q", got)
|
|
}
|
|
if strings.Contains(got, "...") {
|
|
t.Fatalf("small body should not be truncated: %q", got)
|
|
}
|
|
|
|
large := make([]byte, 300)
|
|
for i := range large {
|
|
large[i] = byte(i)
|
|
}
|
|
got = formatBodyPreview(large, 16)
|
|
if !strings.Contains(got, "len=300") || !strings.Contains(got, "preview(hex,16B)=") {
|
|
t.Fatalf("unexpected preview for large body: %q", got)
|
|
}
|
|
if !strings.HasSuffix(got, "...") {
|
|
t.Fatalf("large body should be truncated with ellipsis: %q", got)
|
|
}
|
|
}
|