f No need for transaction in write

Author: tnull

src/io/sqlite_store.rs

@@ -87,35 +87,27 @@ impl KVStore for SqliteStore {
 	}
 
 	fn write(&self, namespace: &str, key: &str, buf: &[u8]) -> std::io::Result<()> {
-		let mut locked_conn = self.connection.lock().unwrap();
-
-		let sql_tx = locked_conn.transaction().map_err(|_| {
-			let msg = format!("Failed to start transaction");
-			std::io::Error::new(std::io::ErrorKind::Other, msg)
-		})?;
+		let locked_conn = self.connection.lock().unwrap();
 
 		let sql = format!(
-			"INSERT OR REPLACE INTO {} (namespace, key, value) VALUES (:namespace, :key, :data);",
+			"INSERT OR REPLACE INTO {} (namespace, key, value) VALUES (:namespace, :key, :value);",
 			KV_TABLE_NAME
 		);
-		sql_tx
+
+		locked_conn
 			.execute(
 				&sql,
 				named_params! {
 					":namespace": namespace,
 					":key": key,
-					":data": buf,
+					":value": buf,
 				},
 			)
 			.map_err(|_| {
 				let msg = format!("Failed to write to key: {}/{}", namespace, key);
 				std::io::Error::new(std::io::ErrorKind::Other, msg)
 			})?;
-
-		sql_tx.commit().map_err(|_| {
-			let msg = format!("Failed to commit transaction");
-			std::io::Error::new(std::io::ErrorKind::Other, msg)
-		})
+		Ok(())
 	}
 
 	fn remove(&self, namespace: &str, key: &str) -> std::io::Result<bool> {