caisin/sea-orm
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

WIP

Browse Source
This commit is contained in:
Sam Samai 2021-08-22 15:30:04 +10:00
parent 0998b64ed4
commit e009d2ffcf
1 changed files with 35 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
examples/rocket_example/src/sqlx/mod.rs
View File

@ -15,7 +15,7 @@ mod setup;
#[derive(Database, Debug)] #[derive(Database, Debug)]
#[database("blog")] #[database("blog")]
struct Db(sea_orm::DatabaseConnection); struct Db(sea_orm::Database);
type Result<T, E = rocket::response::Debug<sqlx::Error>> = std::result::Result<T, E>; type Result<T, E = rocket::response::Debug<sqlx::Error>> = std::result::Result<T, E>;
@ -48,7 +48,7 @@ use sea_orm::DatabaseConnection;
// } // }
#[get("/")] #[get("/")]
async fn list(mut db: Connection<Db>) -> Result<Json<Vec<i64>>> { async fn list(mut con: Connection<Db>) -> Result<Json<Vec<i64>>> {
// let ids = sqlx::query!("SELECT id FROM posts") // let ids = sqlx::query!("SELECT id FROM posts")
// .fetch(&mut *db) // .fetch(&mut *db)
// .map_ok(|record| record.id) // .map_ok(|record| record.id)
@ -91,17 +91,32 @@ async fn list(mut db: Connection<Db>) -> Result<Json<Vec<i64>>> {
// let ids: Vec<i64> = recs.into(); // let ids: Vec<i64> = recs.into();
// println!("recs: {:#?}", ids); // println!("recs: {:#?}", ids);
println!("db: {:#?}", &*db); // println!("db: {:#?}", &*db);
let res = db // let res = db
.execute(Statement::from_string( // .execute(Statement::from_string(
// DatabaseBackend::Sqlite,
// "SELECT * from posts".to_owned(),
// ))
// .await;
// println!("res: {:#?}", res);
let all_posts = con
.query_all(Statement::from_string(
DatabaseBackend::Sqlite, DatabaseBackend::Sqlite,
"SELECT * from posts".to_owned(), "select * from posts;".to_owned(),
)) ))
.await; .await
println!("res: {:#?}", res); .unwrap();
for post in all_posts.into_iter() {
// let p = Post::from_raw_query_result(post);
println!(
"p: {:#?}",
sea_orm::JsonValue::from_query_result(&post, "").unwrap()
);
}
// let con = SqlxSqliteConnector::from_sqlx_sqlite_pool(db); // let con = SqlxSqliteConnector::from_sqlx_sqlite_pool(db);
// let posts = Post::find().all(&db).await.unwrap(); // let posts = Post::find().all(&con).await.unwrap();
// assert_eq!(posts.len(), 0); // assert_eq!(posts.len(), 0);
let ids: Vec<i64> = vec![]; let ids: Vec<i64> = vec![];
@ -183,7 +198,9 @@ pub fn stage() -> AdHoc {
rocket rocket
.attach(Db::init()) .attach(Db::init())
.attach(AdHoc::try_on_ignite("Create init post", |rocket| async { .attach(AdHoc::try_on_ignite("Create init post", |rocket| async {
let db = Db::fetch(&rocket).expect("database mounted"); let con = sea_orm::Database::connect("mysql://root:@localhost/rocket_example")
.await
.unwrap();
// let res = sqlx::query( // let res = sqlx::query(
// r#" // r#"
// CREATE TABLE posts ( // CREATE TABLE posts (
@ -195,23 +212,22 @@ pub fn stage() -> AdHoc {
// ) // )
// .execute(&**db) // .execute(&**db)
// .await; // .await;
let create_post_table = con
let create_post_table = db
.execute(Statement::from_string( .execute(Statement::from_string(
DatabaseBackend::Sqlite, DatabaseBackend::Sqlite,
r#" r#"
CREATE TABLE posts ( CREATE TABLE posts (
id INTEGER PRIMARY KEY AUTOINCREMENT, id int NOT NULL AUTO_INCREMENT,
title VARCHAR NOT NULL, title VARCHAR(255) NOT NULL,
text VARCHAR NOT NULL, text VARCHAR(255) NOT NULL,
published BOOLEAN NOT NULL DEFAULT 0 PRIMARY KEY (id)
)"# )"#
.to_owned(), .to_owned(),
)) ))
.await; .await;
println!("create_post_table: {:#?}", create_post_table); println!("create_post_table: {:#?}", create_post_table);
let create_post = db let create_post = con
.execute(Statement::from_string( .execute(Statement::from_string(
DatabaseBackend::Sqlite, DatabaseBackend::Sqlite,
"INSERT INTO posts (title, text) VALUES ('a post', 'content of a post')" "INSERT INTO posts (title, text) VALUES ('a post', 'content of a post')"
@ -220,6 +236,8 @@ pub fn stage() -> AdHoc {
.await; .await;
println!("create_post: {:#?}", create_post); println!("create_post: {:#?}", create_post);
// println!("all_posts: {:#?}", all_posts);
// let res2 = sqlx::query( // let res2 = sqlx::query(
// r#" // r#"
// INSERT INTO posts (title, text) VALUES ('a post', 'content of a post') // INSERT INTO posts (title, text) VALUES ('a post', 'content of a post')