mirrors/limbo
1
0
Fork 0
mirror of https://github.com/tursodatabase/limbo.git synced 2025-08-04 01:58:16 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Handle Err case from connection.io

Browse source
This commit is contained in:
김선우 2025-01-24 14:07:52 +09:00
parent 36dff168b3
commit 0481e69217
1 changed files with 20 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

35
bindings/java/rs_src/limbo_statement.rs
View file

@ -59,27 +59,32 @@ pub extern "system" fn Java_org_github_tursodatabase_core_LimboStatement_step<'l
};
loop {
match stmt.stmt.step() {
Ok(StepResult::Row(row)) => match row_to_obj_array(&mut env, &row) {
Ok(row) => return to_limbo_step_result(&mut env, STEP_RESULT_ID_ROW, Some(row)),
Err(e) => {
match stmt
.stmt
.step()
.map_err(|_e| to_limbo_step_result(&mut env, STEP_RESULT_ID_ERROR, None))
.unwrap()
{
StepResult::Row(row) => {
return match row_to_obj_array(&mut env, &row) {
Ok(row) => to_limbo_step_result(&mut env, STEP_RESULT_ID_ROW, Some(row)),
Err(e) => {
set_err_msg_and_throw_exception(&mut env, obj, LIMBO_ETC, e.to_string());
to_limbo_step_result(&mut env, STEP_RESULT_ID_ERROR, None)
}
}
}
StepResult::IO => {
if let Err(e) = stmt.connection.io.run_once() {
set_err_msg_and_throw_exception(&mut env, obj, LIMBO_ETC, e.to_string());
return to_limbo_step_result(&mut env, STEP_RESULT_ID_ERROR, None);
}
},
Ok(StepResult::IO) => {
stmt.connection.io.run_once().unwrap();
}
Ok(StepResult::Done) => {
return to_limbo_step_result(&mut env, STEP_RESULT_ID_DONE, None)
}
Ok(StepResult::Interrupt) => {
StepResult::Done => return to_limbo_step_result(&mut env, STEP_RESULT_ID_DONE, None),
StepResult::Interrupt => {
return to_limbo_step_result(&mut env, STEP_RESULT_ID_INTERRUPT, None)
}
Ok(StepResult::Busy) => {
return to_limbo_step_result(&mut env, STEP_RESULT_ID_BUSY, None)
}
_ => return to_limbo_step_result(&mut env, STEP_RESULT_ID_ERROR, None),
StepResult::Busy => return to_limbo_step_result(&mut env, STEP_RESULT_ID_BUSY, None),
}
}
}