oxirs 0.2.4

Command-line interface for OxiRS - import, export, migration, and benchmarking tools
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
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

//! OxiRS CLI Tools Suite
//!
//! Comprehensive command-line tools for RDF processing, SPARQL querying,
//! validation, and dataset management. Inspired by Apache Jena's CLI tools
//! but built in Rust for performance and safety.

/// Common result type for all tools
pub type ToolResult<T = ()> = Result<T, Box<dyn std::error::Error>>;

// === Data Processing Tools ===
pub mod rdfcat;
pub mod rdfcopy;
pub mod rdfdiff;
pub mod rdfparse;
pub mod riot;

// === Advanced Query Tools ===
pub mod arq;
pub mod qparse;
pub mod rsparql;
pub mod rupdate;
pub mod uparse;

// === Storage Tools ===
pub mod backup_encryption;
pub mod pitr;
pub mod tdbbackup;
pub mod tdbcompact;
pub mod tdbdump;
pub mod tdbloader;
pub mod tdbquery;
pub mod tdbstats;
pub mod tdbupdate;

// === Validation Tools ===
pub mod infer;
pub mod schemagen;
pub mod shacl;
pub mod shex;

// === Utility Tools ===
pub mod iri;
pub mod juuid;
pub mod langtag;
pub mod rset;
pub mod utf8;
pub mod wwwdec;
pub mod wwwenc;

/// Common utilities for tools
pub mod utils;

/// Format detection and conversion
pub mod format_detection;

/// Performance monitoring and profiling
pub mod performance;

/// Query profiling system
pub mod profiling;

/// Compression support for RDF files
pub mod compression;

/// SPARQL benchmarking suite
pub mod benchmark;

/// Transaction support (BEGIN/COMMIT/ROLLBACK)
pub mod transaction;

/// Database migration tools (Jena, Virtuoso, RDF4J)
pub mod migration;

/// Tool execution statistics
#[derive(Debug, Clone)]
pub struct ToolStats {
    pub start_time: std::time::Instant,
    pub duration: std::time::Duration,
    pub items_processed: usize,
    pub errors: usize,
    pub warnings: usize,
}

impl ToolStats {
    pub fn new() -> Self {
        Self {
            start_time: std::time::Instant::now(),
            duration: std::time::Duration::new(0, 0),
            items_processed: 0,
            errors: 0,
            warnings: 0,
        }
    }

    pub fn finish(&mut self) {
        self.duration = self.start_time.elapsed();
    }

    pub fn rate(&self) -> f64 {
        if self.duration.as_secs_f64() > 0.0 {
            self.items_processed as f64 / self.duration.as_secs_f64()
        } else {
            0.0
        }
    }

    pub fn print_summary(&self, tool_name: &str) {
        println!("\n{tool_name} completed:");
        println!("  Duration: {:.3}s", self.duration.as_secs_f64());
        println!("  Items processed: {}", self.items_processed);
        if self.errors > 0 {
            println!("  Errors: {}", self.errors);
        }
        if self.warnings > 0 {
            println!("  Warnings: {}", self.warnings);
        }
        if self.items_processed > 0 {
            println!("  Rate: {:.1} items/second", self.rate());
        }
    }
}

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