Aplicaciones con Rullst I · Lección 08 / 14

Crear: el texto sigue siendo dato

Un apóstrofo en el título no debe romper la consulta.

Vamos a descubrir juntos

1
En POST, el handler recibe JSON, valida y llama a Store::create. SQL usa VALUES (?, ?); bind envía título y prioridad como valores. No concatenes entradas en SQL: O'Brien es un nombre común y otros textos pueden parecer comandos.
2
Tras INSERT, last_insert_rowid identifica el nuevo registro. La respuesta 201 devuelve el id y los valores normalizados, incluido done=false. Un título repetido crea otro registro; el proyecto no define unicidad del título ni deduplicación de envíos.
3
Inspecciona la prueba con apóstrofo, marcado HTML y texto parecido a SQL. Tras la llamada, la tabla sigue existiendo y el título permanece como texto. Esto verifica esa ruta parametrizada; no prueba inmunidad de toda la aplicación ni resuelve autorización.
4
Un INSERT individual de SQLite es atómico: inserta el registro o falla la instrucción. Si una acción futura cambia varias tablas como unidad, la transacción debe abarcar todos los pasos. Dos escrituras independientes no son una sola transacción.

Tu mesa de aplicaciones

El kit incluye la aplicación completa para investigar y modificar. El fragmento explica esta etapa; el editor contiene el archivo indicado. Rullst Academy no compila ni ejecuta este servidor en el navegador.

Archivo para estudiar y modificar

src/store.rs

sqlx::query("INSERT INTO missions (title, priority) VALUES (?, ?)")
    .bind(&input.title)
    .bind(input.priority)
    .execute(&self.pool).await?

Extrae el kit en una carpeta nueva y abre el terminal junto a Cargo.toml. Usa Rust 1.96+; la primera compilación puede descargar dependencias y tardar. Abre http://127.0.0.1:3010. Detén con Ctrl+C y ejecuta de nuevo tras editar.

cargo test --locked
cargo run --locked

Mis archivos y GitHub

Descarga tu borrador y sustituye el archivo indicado en tu copia extraída. El editor guarda un archivo en este navegador; tu cuenta guarda evaluaciones y XP. El ZIP excluye tus cambios. GitHub envía solo el archivo confirmado; usa Git manual para la aplicación entera, sin bases, respaldos ni secretos.

Enlaces oficiales y siguiente paso

SQLite: parámetros y expresiones

✦

TU MISIÓN

Seguir una creación validada hasta INSERT parametrizado y respuesta 201.

Llévatelo contigo

Crea un título con apóstrofo y revisa respuesta, listado y reinicio. Agrega una prueba con otra entrada válida inusual. Explica cómo bind separa instrucción y valor sin prometer resolver permisos.

A tu ritmo

Mis archivos y GitHub

Cada lección puede convertirse en un registro propio: código, notas o un plan de práctica. Guardar un archivo en GitHub es opcional y no cambia tus XP.

Manual del alumno

El editor y las descargas se abren cuando esta lección esté disponible para tu cuenta. Revisa el acceso indicado abajo o vuelve al mapa de la ruta.

Comprobando tu acceso a esta lección…

Tu camino, paso a paso

Descargar material de la actividad

Descarga el ejemplo de la lección y un cuaderno para tus notas. El ZIP incluye una guía para organizar actividades en uno o varios repositorios. Publicar es opcional; las cuentas habilitadas también pueden usar el botón de envío a GitHub.

Tu archivo de esta lección

Edita el ejemplo o registra lo aprendido. Este espacio no ejecuta código ni corrige respuestas. El borrador se guarda solo en este navegador, separado por cuenta; tú decides cuándo descargar o enviar a GitHub.

El ejemplo puede ser solo un fragmento o una guía. Cambiar la extensión no lo convierte en un programa completo. El ZIP de la actividad contiene material inicial; el botón de archivo editado descarga tu texto.

Mi código o mis notas

use crate::validation::NewMission;
use rullst::orm::sqlx::{
    self, Row, SqlitePool,
    sqlite::{SqliteConnectOptions, SqlitePoolOptions},
};
use serde::Serialize;
use std::{path::Path, time::Duration};

#[derive(Clone)]
pub struct Store {
    pub pool: SqlitePool,
}

#[derive(Debug, Serialize)]
pub struct Mission {
    pub id: i64,
    pub title: String,
    pub priority: i64,
    pub done: bool,
}

impl Store {
    pub async fn open(path: &Path) -> Result<Self, sqlx::Error> {
        let options = SqliteConnectOptions::new()
            .filename(path)
            .create_if_missing(true)
            .foreign_keys(true)
            .busy_timeout(Duration::from_secs(5));
        let pool = SqlitePoolOptions::new()
            .max_connections(1)
            .connect_with(options)
            .await?;
        let version: i64 = sqlx::query_scalar("PRAGMA user_version")
            .fetch_one(&pool)
            .await?;
        if version > 1 {
            return Err(sqlx::Error::Protocol("Unsupported schema version".into()));
        }
        sqlx::raw_sql(include_str!("../schema.sql"))
            .execute(&pool)
            .await?;
        Ok(Self { pool })
    }

pub async fn list(&self) -> Result<Vec<Mission>, sqlx::Error> {
        let rows = sqlx::query("SELECT id, title, priority, done FROM missions ORDER BY priority DESC, id ASC LIMIT 100")
            .fetch_all(&self.pool).await?;
        rows.into_iter()
            .map(|row| {
                Ok(Mission {
                    id: row.try_get("id")?,
                    title: row.try_get("title")?,
                    priority: row.try_get("priority")?,
                    done: row.try_get("done")?,
                })
            })
            .collect()
    }

// Only validated input reaches this operation through the HTTP handler.
    pub async fn create(&self, input: NewMission) -> Result<Mission, sqlx::Error> {
        let result = sqlx::query("INSERT INTO missions (title, priority) VALUES (?, ?)")
            .bind(&input.title)
            .bind(input.priority)
            .execute(&self.pool)
            .await?;
        Ok(Mission {
            id: result.last_insert_rowid(),
            title: input.title,
            priority: input.priority,
            done: false,
        })
    }

pub async fn complete(&self, id: i64, done: bool) -> Result<bool, sqlx::Error> {
        let result = sqlx::query("UPDATE missions SET done = ? WHERE id = ?")
            .bind(done)
            .bind(id)
            .execute(&self.pool)
            .await?;
        Ok(result.rows_affected() == 1)
    }
}

Formato del archivo

Tu texto se guardará en este navegador al editarlo. En un equipo compartido, borra los borradores al terminar.

El envío directo acepta hasta 8 KiB de texto en un archivo. Usa las descargas y la guía manual para proyectos con varios archivos.

Crear: el texto sigue siendo dato

Vamos a descubrir juntos

Tu mesa de aplicaciones

Archivo para estudiar y modificar

Enlaces oficiales y siguiente paso

Ahora te toca

Decide antes de ejecutar

Llévatelo contigo

Mis archivos y GitHub

Tu archivo de esta lección

Guardar en mi GitHub

Rullstpetbot