chakcy_code_repository/queue_sqlite
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

modify: 修改 QueueOperation

Browse Source
This commit is contained in:
chakcy 2025-09-23 10:34:58 +08:00
parent 7189d6e2a4
commit 80b1c89014
5 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
.gitignore vendored
View File

@ -18,4 +18,9 @@ cache/
.vscode/ .vscode/
# test files # test files
.pytest_cache/ .pytest_cache/
# dynamic library
*.so
*.dll
*.pyd

2
.python-version
View File

@ -1 +1 @@
3.13 3.13t

0
to_json_utils.py → scripts/to_json_utils.py
View File

4
src/core/src/queue_operation.rs
View File

@ -348,9 +348,7 @@ impl QueueOperation {
.get() .get()
.map_err(|e| PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(e.to_string()))?; .map_err(|e| PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(e.to_string()))?;
let mut stmt = conn let mut stmt = conn
.prepare( .prepare("SELECT * FROM messages WHERE id = ?1 AND (status = ?2 OR status = ?3)")
"SELECT result, status FROM messages WHERE id = ?1 AND (status = ?2 OR status = ?3)",
)
.map_err(|e| PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(e.to_string()))?; .map_err(|e| PyErr::new::<pyo3::exceptions::PyRuntimeError, _>(e.to_string()))?;
let mut mapped_rows = stmt let mut mapped_rows = stmt
.query_map(params![&id, 2, 3], |row| { .query_map(params![&id, 2, 3], |row| {

BIN
src/queue_sqlite/core/core.pyd
View File

Binary file not shown.