mirror of
https://github.com/nushell/nushell
synced 2025-01-13 21:55:07 +00:00
sqlite query without collect (#6217)
This commit is contained in:
parent
233afebdf0
commit
e7958bebac
1 changed files with 15 additions and 10 deletions
|
@ -366,16 +366,21 @@ impl CustomValue for SQLiteDatabase {
|
|||
}
|
||||
|
||||
fn to_base_value(&self, span: Span) -> Result<Value, ShellError> {
|
||||
let db = open_sqlite_db(self.connection.as_path(span)?, span)?;
|
||||
read_entire_sqlite_db(db, span).map_err(|e| {
|
||||
ShellError::GenericError(
|
||||
"Failed to read from SQLite database".into(),
|
||||
e.to_string(),
|
||||
Some(span),
|
||||
None,
|
||||
Vec::new(),
|
||||
)
|
||||
})
|
||||
match self.statement {
|
||||
None => {
|
||||
let db = open_sqlite_db(self.connection.as_path(span)?, span)?;
|
||||
read_entire_sqlite_db(db, span).map_err(|e| {
|
||||
ShellError::GenericError(
|
||||
"Failed to read from SQLite database".into(),
|
||||
e.to_string(),
|
||||
Some(span),
|
||||
None,
|
||||
Vec::new(),
|
||||
)
|
||||
})
|
||||
}
|
||||
Some(_) => self.collect(span),
|
||||
}
|
||||
}
|
||||
|
||||
fn as_any(&self) -> &dyn std::any::Any {
|
||||
|
|
Loading…
Reference in a new issue