데이터베이스 통합
데이터 저장하기
데이터베이스 통합은(는) CoddyKit의 무료 Learn Rust Coding 강의입니다. 이것은 4개 중 3번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Learn Rust Coding 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Learn Rust Coding 강의에는 총 4개의 강의가 포함되어 있습니다.
데이터 영속화
지금까지 API는 메모리에 데이터를 저장했으므로 다시 시작하면 데이터가 사라집니다. 실제 서비스에는 데이터베이스가 필요합니다. 이 레슨에서는 비동기 방식이며 컴파일 시점에 확인되는 Rust용 SQL 도구인 sqlx를 사용해 Axum API를 PostgreSQL에 연결합니다.
연결 풀, 쿼리, 행을 구조체에 매핑하는 방법, 풀을 공유 상태로 사용하는 방법을 배웁니다.
sqlx 추가하기
필요한 기능을 지정해 sqlx를 추가하십시오. 런타임, TLS 및 데이터베이스 드라이버가 필요합니다. 아래는 Tokio를 사용하는 Postgres 설정입니다.
// Cargo.toml
// [dependencies]
// sqlx = { version = "0.7", features = [
// "runtime-tokio", "tls-rustls", "postgres", "macros"
// ] }연결 풀
요청마다 새 연결을 여는 것은 느립니다. 연결 풀은 재사용할 수 있는 연결 집합을 유지합니다. PgPoolOptions는 데이터베이스 URL로 풀을 만듭니다. 풀은 내부적으로 참조 횟수를 세므로 복제 비용이 저렴하며, 공유 상태로 사용하기에 적합합니다.
use sqlx::postgres::PgPoolOptions;
async fn make_pool(url: &str) -> sqlx::PgPool {
PgPoolOptions::new()
.max_connections(5)
.connect(url)
.await
.expect("failed to connect")
}애플리케이션 상태로 사용하는 풀
.with_state(pool)으로 풀을 Axum에 전달하십시오. 그러면 핸들러에서 State(pool): State<PgPool>을 받습니다. 풀은 저렴하게 복제할 수 있으므로 모든 요청이 동일한 기본 연결을 공유합니다.
use axum::{routing::get, Router};
use sqlx::PgPool;
fn build(pool: PgPool) -> Router {
Router::new()
.route("/todos", get(list_todos))
.with_state(pool)
}쿼리 실행하기
sqlx::query 함수는 원시 SQL을 실행합니다. SQL 삽입을 방지하려면 .bind(value)로 매개변수를 바인딩하십시오. Postgres는 $1, $2 자리 표시자를 사용합니다. 행을 반환하지 않는 쓰기 작업에는 .execute(&pool)을 사용합니다.
use sqlx::PgPool;
async fn insert_todo(pool: &PgPool, title: &str) -> Result<(), sqlx::Error> {
sqlx::query("INSERT INTO todos (title, done) VALUES ($1, $2)")
.bind(title)
.bind(false)
.execute(pool)
.await?;
Ok(())
}행을 구조체에 매핑하기
쿼리 결과를 모델에 직접 매핑하려면 모델에 sqlx::FromRow를 파생하십시오. fetch_all과 함께 query_as::<_, Todo>를 사용하면 Vec<Todo>를 얻고, 단일 행에는 fetch_one을 사용합니다.
use sqlx::{PgPool, FromRow};
#[derive(FromRow, serde::Serialize)]
struct Todo { id: i32, title: String, done: bool }
async fn all_todos(pool: &PgPool) -> Result<Vec<Todo>, sqlx::Error> {
let rows = sqlx::query_as::<_, Todo>("SELECT id, title, done FROM todos")
.fetch_all(pool)
.await?;
Ok(rows)
}데이터베이스를 읽는 핸들러
요소를 결합해 보겠습니다. 핸들러가 상태에서 풀을 받고, 쿼리를 실행한 다음 JSON을 반환합니다. 데이터베이스 오류를 500 상태로 매핑하여 패닉 대신 클라이언트가 깔끔한 응답을 받도록 하십시오.
use axum::{extract::State, Json, http::StatusCode};
use sqlx::PgPool;
async fn list_todos(
State(pool): State<PgPool>,
) -> Result<Json<Vec<Todo>>, StatusCode> {
match all_todos(&pool).await {
Ok(todos) => Ok(Json(todos)),
Err(_) => Err(StatusCode::INTERNAL_SERVER_ERROR),
}
}삽입한 행 반환하기
Postgres는 RETURNING을 사용해 방금 삽입한 행을 반환할 수 있습니다. query_as와 fetch_one을 함께 사용하면 생성된 id를 포함한 새 레코드를 한 번의 왕복으로 얻을 수 있습니다.
use sqlx::PgPool;
async fn create(pool: &PgPool, title: &str) -> Result<Todo, sqlx::Error> {
let todo = sqlx::query_as::<_, Todo>(
"INSERT INTO todos (title, done) VALUES ($1, false) \
RETURNING id, title, done")
.bind(title)
.fetch_one(pool)
.await?;
Ok(todo)
}마이그레이션
쿼리를 실행하기 전에 스키마가 존재해야 합니다. sqlx는 마이그레이션을 지원합니다. migrations/ 폴더의 SQL 파일을 순서대로 적용하는 방식입니다. 시작할 때 sqlx::migrate!()를 실행하면 새 데이터베이스가 자동으로 설정됩니다.
use sqlx::PgPool;
async fn run_migrations(pool: &PgPool) {
sqlx::migrate!("./migrations")
.run(pool)
.await
.expect("migrations failed");
}
// migrations/0001_init.sql contains the CREATE TABLE statements.트랜잭션
여러 쓰기 작업이 함께 성공해야 한다면 트랜잭션으로 묶으십시오. pool.begin()으로 시작하고, 트랜잭션 핸들에서 쿼리를 실행한 다음 commit하십시오. 커밋하지 않고 삭제하면 sqlx가 자동으로 롤백하여 데이터 일관성을 유지합니다.
use sqlx::PgPool;
async fn transfer(pool: &PgPool) -> Result<(), sqlx::Error> {
let mut tx = pool.begin().await?;
sqlx::query("UPDATE accounts SET balance = balance - 10 WHERE id = 1")
.execute(&mut *tx).await?;
sqlx::query("UPDATE accounts SET balance = balance + 10 WHERE id = 2")
.execute(&mut *tx).await?;
tx.commit().await?;
Ok(())
}구성과 비밀 정보
데이터베이스 자격 증명을 하드코딩하지 마십시오. 환경에서 DATABASE_URL을 읽고, 개발 중에는 dotenvy 크레이트로 .env 파일에서 불러오는 경우가 많습니다. 실제 환경에서는 플랫폼이 이를 환경 변수로 주입합니다.
use std::env;
async fn connect_from_env() -> sqlx::PgPool {
let url = env::var("DATABASE_URL")
.expect("DATABASE_URL must be set");
make_pool(&url).await
}빠른 확인
데이터베이스 통합에 대한 이해도를 확인해 보십시오.
복습
데이터베이스를 통합했습니다:
PgPool연결 풀을 사용하고.with_state를 통해 공유합니다.- 쓰기에는
query/execute를 사용하고, 타입이 지정된 읽기에는FromRow와 함께query_as를 사용합니다. - SQL 인젝션을 방지하려면 항상 매개변수를 바인딩합니다.
RETURNING은 삽입된 행을 가져오고, 트랜잭션은 쓰기 작업을 원자적으로 묶습니다.- 시작할 때 마이그레이션을 실행하고 환경에서
DATABASE_URL을 읽습니다.
자주 묻는 질문
“데이터베이스 통합” 강의는 무료인가요?
네 — “데이터베이스 통합” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Learn Rust Coding 강의 전체를 잠금 해제할 수 있습니다. Learn Rust Coding 강의에는 총 4개의 강의가 포함되어 있습니다.
“데이터베이스 통합”에서 뭘 배우나요?
데이터 저장하기 브라우저에서 직접 실행하는 실습 코드로 Learn Rust Coding을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.
Learn Rust Coding을(를) 시작하는 데 경험이 필요한가요?
사전 경험은 필요하지 않습니다. CoddyKit의 Learn Rust Coding은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 3번째 강의입니다.
“데이터베이스 통합” 강의는 얼마나 걸리나요?
대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.
이 Learn Rust Coding 강의에서 코드를 작성하고 실행할 수 있나요?
네. 모든 Learn Rust Coding 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.