aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2026-01-31 13:54:27 +01:00
Code Issues Packages Projects Releases Wiki Activity

rusqlite stop trying to get rows when we error with InvalidColumnIndex

Browse Source
This commit is contained in:
pedrocarlo
2025-10-10 13:08:41 -03:00
parent d99e3f590f
commit dca1137f81
1 changed files with 13 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
simulator/runner/execution.rs
View File

@@ -283,16 +283,13 @@ fn limbo_integrity_check(conn: &Arc<Connection>) -> Result<()> {
Ok(())
}
#[instrument(skip(env, interaction, stack), fields(conn_index = interaction.connection_index, interaction = %interaction))]
fn execute_interaction_rusqlite(
env: &mut SimulatorEnv,
interaction: &Interaction,
stack: &mut Vec<ResultSet>,
) -> turso_core::Result<ExecutionContinuation> {
tracing::trace!(
"execute_interaction_rusqlite(connection_index={}, interaction={})",
interaction.connection_index,
interaction
);
tracing::info!("");
let SimConnection::SQLiteConnection(conn) = &mut env.connections[interaction.connection_index]
else {
unreachable!()
@@ -347,11 +344,19 @@ fn execute_query_rusqlite(
match query {
Query::Select(select) => {
let mut stmt = connection.prepare(select.to_string().as_str())?;
let columns = stmt.column_count();
let rows = stmt.query_map([], |row| {
let mut values = vec![];
for i in 0..columns {
let value = row.get_unwrap(i);
for i in 0.. {
let value = match row.get(i) {
Ok(value) => value,
Err(err) => match err {
rusqlite::Error::InvalidColumnIndex(_) => break,
_ => {
tracing::error!(?err);
panic!("{err}")
}
},
};
let value = match value {
rusqlite::types::Value::Null => Value::Null,
rusqlite::types::Value::Integer(i) => Value::Integer(i),