Skip to content

Commit 242da10

Browse files
committed
Fixup
1 parent 9f8e134 commit 242da10

3 files changed

Lines changed: 12 additions & 8 deletions

File tree

sea-orm-migration/src/migrator.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ where
304304
constraint_name, table_name
305305
);
306306
let mut stmt = ForeignKey::drop();
307-
stmt.table(table_name.as_str())
307+
stmt.table(Alias::new(table_name.as_str()))
308308
.name(constraint_name.as_str());
309309
db.execute(db_backend.build(&stmt)).await?;
310310
info!("Foreign key '{}' has been dropped", constraint_name);
@@ -319,7 +319,7 @@ where
319319
let table_name: String = row.try_get("", "table_name")?;
320320
info!("Dropping table '{}'", table_name);
321321
let mut stmt = Table::drop();
322-
stmt.table(table_name.as_str())
322+
stmt.table(Alias::new(table_name.as_str()))
323323
.if_exists()
324324
.cascade();
325325
db.execute(db_backend.build(&stmt)).await?;
@@ -335,7 +335,7 @@ where
335335
let type_name: String = row.try_get("", "typname")?;
336336
info!("Dropping type '{}'", type_name);
337337
let mut stmt = Type::drop();
338-
stmt.name(&type_name);
338+
stmt.name(Alias::new(&type_name));
339339
db.execute(db_backend.build(&stmt)).await?;
340340
info!("Type '{}' has been dropped", type_name);
341341
}

sea-orm-migration/src/schema.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -609,5 +609,5 @@ pub fn timestamps(t: TableCreateStatement) -> TableCreateStatement {
609609

610610
/// Create an Alias.
611611
pub fn name<T: Into<String>>(name: T) -> Alias {
612-
name
612+
Alias::new(name)
613613
}

src/executor/query.rs

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
pub use crate::error::TryGetError;
22
use crate::{
3-
error::{json_err, type_err, DbErr},
3+
error::{type_err, DbErr},
44
SelectGetableValue, SelectorRaw, Statement,
55
};
66
use std::fmt;
@@ -1342,15 +1342,19 @@ where
13421342
debug_print!("{:#?}", e.to_string());
13431343
err_null_idx_col(idx)
13441344
})
1345-
.and_then(|json| serde_json::from_value(json).map_err(|e| json_err(e).into())),
1345+
.and_then(|json| {
1346+
serde_json::from_value(json).map_err(|e| crate::error::json_err(e).into())
1347+
}),
13461348
#[cfg(feature = "proxy")]
13471349
QueryResultRow::Proxy(row) => row
13481350
.try_get::<serde_json::Value, I>(idx)
13491351
.map_err(|e| {
13501352
debug_print!("{:#?}", e.to_string());
13511353
err_null_idx_col(idx)
13521354
})
1353-
.and_then(|json| serde_json::from_value(json).map_err(|e| json_err(e).into())),
1355+
.and_then(|json| {
1356+
serde_json::from_value(json).map_err(|e| crate::error::json_err(e).into())
1357+
}),
13541358
#[allow(unreachable_patterns)]
13551359
_ => unreachable!(),
13561360
}
@@ -1362,7 +1366,7 @@ where
13621366
serde_json::Value::Array(values) => {
13631367
let mut res = Vec::new();
13641368
for item in values {
1365-
res.push(serde_json::from_value(item).map_err(json_err)?);
1369+
res.push(serde_json::from_value(item).map_err(crate::error::json_err)?);
13661370
}
13671371
Ok(res)
13681372
}

0 commit comments

Comments
 (0)