aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-06 17:54:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

core: transaction support

Browse Source
This commit is contained in:
Pere Diaz Bou
2024-12-24 18:04:30 +01:00
parent a94d4ca8bc
commit aed14117c9
13 changed files with 334 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
cli/app.rs
View File

@@ -525,6 +525,10 @@ impl Limbo {
Ok(RowResult::Done) => {
break;
}
Ok(RowResult::Busy) => {
self.writeln("database is busy");
break;
}
Err(err) => {
let _ = self.writeln(err.to_string());
break;
@@ -560,6 +564,10 @@ impl Limbo {
}
Ok(RowResult::Interrupt) => break,
Ok(RowResult::Done) => break,
Ok(RowResult::Busy) => {
self.writeln("database is busy");
break;
}
Err(err) => {
let _ = self.write_fmt(format_args!("{}", err));
break;
@@ -610,6 +618,10 @@ impl Limbo {
}
RowResult::Interrupt => break,
RowResult::Done => break,
RowResult::Busy => {
self.writeln("database is busy");
break;
}
}
}
if !found {
@@ -663,6 +675,10 @@ impl Limbo {
}
RowResult::Interrupt => break,
RowResult::Done => break,
RowResult::Busy => {
self.writeln("database is busy");
break;
}
}
}