chore: skip marker for since/till

Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-02-05 21:11:25 +08:00
parent e6a725b099
commit c4b3682947
4 changed files with 22 additions and 2 deletions

2
Cargo.lock generated
View File

@@ -12690,7 +12690,7 @@ dependencies = [
[[package]]
name = "sqlness"
version = "0.6.1"
source = "git+https://github.com/GreptimeTeam/sqlness?rev=6bc85ce077a87756e68ef5a5cd5707071a9da380#6bc85ce077a87756e68ef5a5cd5707071a9da380"
source = "git+https://github.com/GreptimeTeam/sqlness?rev=662d7dd24d8c11f62d960d2b90a92aa43ec699b5#662d7dd24d8c11f62d960d2b90a92aa43ec699b5"
dependencies = [
"async-trait",
"derive_builder 0.11.2",

View File

@@ -27,7 +27,7 @@ semver = "1.0"
serde.workspace = true
serde_json.workspace = true
sha2 = "0.10"
sqlness = { git = "https://github.com/GreptimeTeam/sqlness", rev = "6bc85ce077a87756e68ef5a5cd5707071a9da380" }
sqlness = { git = "https://github.com/GreptimeTeam/sqlness", rev = "662d7dd24d8c11f62d960d2b90a92aa43ec699b5" }
tar = "0.4"
tempfile.workspace = true
tinytemplate = "1.2"

View File

@@ -45,6 +45,16 @@ impl Interceptor for SinceInterceptor {
sql.clear();
}
}
fn after_execute(&self, result: &mut String) {
result.clear();
*result = format!(
"{} target version {} < {}",
sqlness::SKIP_MARKER_PREFIX,
self.target_version,
self.since_version
);
}
}
pub struct SinceInterceptorFactory {

View File

@@ -44,6 +44,16 @@ impl Interceptor for TillInterceptor {
sql.clear();
}
}
fn after_execute(&self, result: &mut String) {
result.clear();
*result = format!(
"{} target version {} > {}",
sqlness::SKIP_MARKER_PREFIX,
self.target_version,
self.till_version
);
}
}
pub struct TillInterceptorFactory {