GothenburgBitFactory/taskwarrior
1
0
Fork 0
mirror of https://github.com/GothenburgBitFactory/taskwarrior.git synced 2025-06-26 10:54:26 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use uuid feature of rusqlite

Browse source
This commit is contained in:
dbr 2021-04-22 13:31:15 +10:00
parent 0f3729d4c8
commit 4bd6c40daf
2 changed files with 8 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

2
taskchampion/Cargo.toml
View file

@ -22,7 +22,7 @@ lmdb-rkv = {version = "^0.14.0"}
ureq = "^2.1.0"
log = "^0.4.14"
tindercrypt = { version = "^0.2.2", default-features = false }
rusqlite = { version = "0.25", features = ["bundled"] }
rusqlite = { version = "0.25", features = ["bundled", "uuid"] }
[dev-dependencies]
proptest = "^1.0.0"

15
taskchampion/src/storage/sqlite.rs
View file

@ -1,7 +1,7 @@
use crate::storage::{Operation, Storage, StorageTxn, TaskMap, VersionId, DEFAULT_BASE_VERSION};
use crate::utils::Key;
use anyhow::Context;
use rusqlite::{Connection, OptionalExtension};
use rusqlite::{Connection, OptionalExtension, params};
use serde::serde_if_integer128;
use std::path::Path;
use uuid::Uuid;
@ -57,7 +57,7 @@ impl<'t> StorageTxn for Txn<'t> {
let result: Option<String> = t
.query_row(
"SELECT data FROM tasks WHERE uuid = ? LIMIT 1",
[&uuid.to_string()],
[&uuid],
|r| r.get(0),
)
.optional()?;
@ -72,7 +72,7 @@ impl<'t> StorageTxn for Txn<'t> {
let t = self.get_txn()?;
let count: usize = t.query_row(
"SELECT count(uuid) FROM tasks WHERE uuid = ?",
[&uuid.to_string()],
[&uuid],
|x| x.get(0),
)?;
if count > 0 {
@ -83,7 +83,7 @@ impl<'t> StorageTxn for Txn<'t> {
let data_str = serde_json::to_string(&data)?;
t.execute(
"INSERT INTO TASKS (uuid, data) VALUES (?, ?)",
[&uuid.to_string(), &data_str],
params![&uuid, &data_str],
)
.context("Create task query")?;
Ok(true)
@ -94,7 +94,7 @@ impl<'t> StorageTxn for Txn<'t> {
let data_str = serde_json::to_string(&task)?;
t.execute(
"INSERT OR REPLACE INTO tasks (uuid, data) VALUES (?, ?)",
[&uuid.to_string(), &data_str],
params![&uuid, &data_str],
)
.context("Update task query")?;
Ok(())
@ -103,7 +103,7 @@ impl<'t> StorageTxn for Txn<'t> {
fn delete_task(&mut self, uuid: Uuid) -> anyhow::Result<bool> {
let t = self.get_txn()?;
let changed = t
.execute("DELETE FROM tasks WHERE uuid = ?", [&uuid.to_string()])
.execute("DELETE FROM tasks WHERE uuid = ?", [&uuid])
.context("Delete task query")?;
Ok(changed > 0)
}
@ -113,9 +113,8 @@ impl<'t> StorageTxn for Txn<'t> {
let mut q = t.prepare("SELECT uuid, data FROM tasks")?;
let rows = q
.query_map([], |r| {
let uuid_str: String = r.get(0)?;
let uuid: Uuid = r.get(0)?;
let data_str: String = r.get(1)?;
let uuid = Uuid::parse_str(&uuid_str).unwrap(); // FIXME: Remove unwrap
let data = serde_json::from_str(&data_str).unwrap(); // FIXME: Remove unwrap
Ok((uuid, data))
})?;