The Complete Production SOP: How to Deploy and Run SeaORM Async & Dynamic Object-Relational Mapping for Rust in Autonomous AI Agents

[dependencies]
sea-orm = { version = "^1.1.0", features = [ "sqlx-postgres", "runtime-tokio-rustls", "macros" ] }
tokio = { version = "1.38", features = ["full"] }
sea-orm-migration = { version = "^1.1.0" }
tracing = "0.1"

use sea_orm::{ConnectOptions, Database, DatabaseConnection, DbErr};
use std::time::Duration;

pub async fn establish_connection(database_url: &str) -> Result<DatabaseConnection, DbErr> {
    let mut opt = ConnectOptions::new(database_url.to_owned());
    opt.max_connections(20)
        .min_connections(5)
        .connect_timeout(Duration::from_secs(8))
        .idle_timeout(Duration::from_secs(8))
        .sqlx_logging(true);
    Database::connect(opt).await
}

use sea_orm::entity::prelude::*;
use sea_orm::ActiveValue::Set;

#[derive(Clone, Debug, PartialEq, DeriveEntityModel, Eq)]
#[sea_orm(table_name = "posts")]
pub struct Model {
    #[sea_orm(primary_key)]
    pub id: i32,
    pub title: String,
    pub text: String,
}

#[derive(Copy, Clone, Debug, EnumIter, DeriveRelation)]
pub enum Relation {}

impl ActiveModelBehavior for ActiveModel {}

// SOP Mutation Helper
pub async fn update_post_title(
    db: &DatabaseConnection,
    model: Model,
    new_title: String,
) -> Result<Model, DbErr> {
    let mut active: ActiveModel = model.into();
    active.title = Set(new_title);
    active.update(db).await
}