init user

Cargo.lock

@@ -664,6 +664,9 @@ version = "0.1.0"
 dependencies = [
  "actix-web",
  "mysql",
+ "serde",
+ "serde_derive",
+ "uuid",
 ]
 
 [[package]]
@@ -2333,6 +2336,9 @@ name = "uuid"
 version = "1.11.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "f8c5f0a0af699448548ad1a2fbf920fb4bee257eae39953ba95cb84891a0446a"
+dependencies = [
+ "getrandom",
+]
 
 [[package]]
 name = "vcpkg"

Cargo.toml

@@ -6,3 +6,6 @@ edition = "2021"
 [dependencies]
 mysql = "25.0.1"
 actix-web = "4"
+serde = "1.0"
+serde_derive = "1.0"
+uuid = { version = "1.11.0", features = ["v4"] }

README.md

@@ -0,0 +1,23 @@
+## Rust分层架构
+
+1. 表示层（Presentation Layer）：负责处理 HTTP 请求和响应，通常包含路由和控制器。
+2. 业务逻辑层（Business Logic Layer）：包含服务和业务逻辑，实现核心应用功能。
+3. 数据访问层（Data Access Layer）：与数据库或其他存储系统进行交互。
+4. 模型层（Model Layer）：定义应用程序的数据结构。
+
+```angular2html
+src/
+|-- main.rs
+|-- routes/      # 表示层
+|   |-- mod.rs
+|   |-- user_routes.rs
+|-- services/    # 业务逻辑层
+|   |-- mod.rs
+|   |-- user_service.rs
+|-- repositories/ # 数据访问层
+|   |-- mod.rs
+|   |-- user_repository.rs
+|-- models/      # 模型层
+    |-- mod.rs
+    |-- user.rs
+```

src/main.rs

@@ -1,21 +1,16 @@
-use mysql::*;
+use actix_web::{App, HttpServer};
-use mysql::prelude::*;
+mod models;
-fn main() -> Result<()> {
+mod repositories;
-    // 连接mysql
+mod services;
-    let url = "mysql://root:0andrx@122.152.201.90:9912/test_server";
+mod routes;
-    let pool = Pool::new(url)?;
+mod utils;
-    let mut conn = pool.get_conn()?;
 
-    // 执行查询
+#[actix_web::main]
-    conn.query_drop(
+async fn main() -> std::io::Result<()> {
-        r"CREATE TABLE IF NOT EXISTS users (
+    HttpServer::new(|| {
-            id INT PRIMARY KEY AUTO_INCREMENT,
+        App::new().service(routes::register_user)
-            name TEXT NOT NULL,
+    })
-            age INT NOT NULL
+        .bind("127.0.0.1:8080")?
-        )"
+        .run()
-    )?;
+        .await
-
-    println!("Created users table");
-
-    Ok(())
 }

src/models/mod.rs

@@ -0,0 +1 @@
+pub mod user;

src/models/user.rs

@@ -0,0 +1,9 @@
+use mysql::serde;
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub struct User {
+    pub id: i32,
+    pub name: String,
+    pub age: i32,
+    pub email: String,
+}

src/repositories/mod.rs

@@ -0,0 +1 @@
+pub mod user_repository;

src/repositories/user_repository.rs

@@ -0,0 +1,30 @@
+use mysql::params;
+use mysql::prelude::Queryable;
+use crate::models::user::User;
+
+/**
+ * 新建用户
+ */
+pub fn create_user(conn: &mut mysql::PooledConn, user: &User) -> Result<(), mysql::Error> {
+    conn.exec_drop(
+        r"INSERT INTO users (id, name, age, email) VALUES (:id, :name, :age, :email)",
+        params! {
+            "id" => &user.id,
+            "name" => &user.name,
+            "age" => &user.age,
+            "email" => &user.email,
+        },
+    )
+}
+
+// /**
+//  * 查询所有用户
+//  */
+// pub fn query_all_users(conn: &mut mysql::PooledConn) -> Result<Vec<User>, mysql::Error> {
+//     conn.query_map(
+//         "SELECT id, name, email FROM users",
+//         |(id, name, age, email)| {
+//             User { id, name, age, email }
+//         },
+//     )
+// }

src/routes/mod.rs

@@ -0,0 +1,2 @@
+mod user_routes;
+pub use user_routes::register_user;

src/routes/user_routes.rs

@@ -0,0 +1,26 @@
+use serde::Deserialize;
+use actix_web::{post, web, HttpResponse, Responder};
+use crate::models::user::User;
+use crate::services::user_service;
+use crate::utils::pool;
+
+#[derive(Deserialize)]
+struct RegisterUser {
+    name: String,
+    age: i32,
+    email: String,
+}
+
+#[post("/users/register")]
+async fn register_user(user: web::Json<RegisterUser>) -> impl Responder {
+    let pool = pool::get_db_pool();
+    let mut conn = pool.get_conn().unwrap();
+    let new_user = User {
+        id: 0,
+        name: user.name.clone(),
+        age: user.age,
+        email: user.email.clone(),
+    };
+    let users = user_service::create_user(&mut conn, &new_user).unwrap();
+    HttpResponse::Ok().json("User registered successfully")
+}

src/services/mod.rs

@@ -0,0 +1 @@
+pub mod user_service;

src/services/user_service.rs

@@ -0,0 +1,11 @@
+use mysql::PooledConn;
+use crate::models::user::User;
+use crate::repositories::user_repository;
+use mysql;
+
+/**
+ * 新建用户
+ */
+pub fn create_user(conn: &mut PooledConn, user: &User) -> Result<(), mysql::Error> {
+    user_repository::create_user(conn, user)
+}

src/utils/mod.rs

@@ -0,0 +1 @@
+pub mod pool;

src/utils/pool.rs

@@ -0,0 +1,9 @@
+use mysql::*;
+
+/**
+ * 获取数据库连接池
+ */
+pub fn get_db_pool() -> Pool {
+    let url = "mysql://root:0andrx@122.152.201.90:9912/test_server";
+    Pool::new(url).expect("TODO: panic message")
+}