Skip to content

Commit 48c530d

Browse files
committed
f Use locked_conn variable
1 parent 43c700b commit 48c530d

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

src/io/sqlite_store.rs

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -66,13 +66,11 @@ impl KVStore for SqliteStore {
6666
type Reader = Cursor<Vec<u8>>;
6767

6868
fn read(&self, namespace: &str, key: &str) -> std::io::Result<Self::Reader> {
69+
let locked_conn = self.connection.lock().unwrap();
6970
let sql =
7071
format!("SELECT value FROM {} WHERE namespace=:namespace AND key=:key;", KV_TABLE_NAME);
7172

72-
let res = self
73-
.connection
74-
.lock()
75-
.unwrap()
73+
let res = locked_conn
7674
.query_row(
7775
&sql,
7876
named_params! {

0 commit comments

Comments
 (0)