Diesel-rust

CRUD realizado en Diesel.

Instalar diesel.

Para instalar diesel hay que añadir la siguiente dependencia en el archivo Cargo.toml:

diesel = { version = "2.0.0", features = ["mysql"] }

Instalar diesel_cli

Al instalar diesel_cli da un error. Se soluciona instalando solo la feature para mysql.

cargo install diesel_cli --no-default-features --features mysql

Configurar .env

Generamos un archivo .env con el siguiente contenido:

DATABASE_URL=mysql://usuario:contraseña@localhost/base_de_datos

Setup

Ejecutamos el siguiente comando:

diesel setup

Este comando nos crea la bd si no existe. Aparte crea el directorio migrations y el archivo diesel.toml

Migraciones

Crear una migración:

Comando:

diesel migration generate crear_usuario

Contenido archivo up.sql

CREATE TABLE usuarios (
  id INT NOT NULL AUTO_INCREMENT,
  nombre VARCHAR(100) NOT NULL,
  apellidos VARCHAR(100) NOT NULL,
  activo BOOLEAN NOT NULL DEFAULT FALSE,
  PRIMARY KEY (id)
)

Contenido archivo down.sql

DROP TABLE usuarios

Ejecutar una migración:

diesel migration run

Eliminar una migración:

diesel migration revert

Elimina una migracion y la vuelve a ejecutar de nuevo

diesel migration redo

Código

Conectarse a la bd

pub fn establecer_conexion_bc() -> MysqlConnection {
    dotenv().ok();

    let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
    MysqlConnection::establish(&database_url)
        .unwrap_or_else(|_| panic!("Error connecting to {}", database_url))
}

Get Usuarios

fn get_usuarios(){
    let connection = &mut establecer_conexion_bc();
    use self::schema::usuarios::dsl::*;
    let results = usuarios       
        .limit(5)
        .load::<Usuarios>(connection)
        .expect("Error obteniendo los usuarios");

    for usuario in results{
        let estado_usuario;
        if usuario.activo == true{
            estado_usuario="Activo".to_string();
        }else{
            estado_usuario="Inactivo".to_string();
        }
        println!("Nombre usuario: {}, apellidos: {} , estado {} ",usuario.nombre,usuario.apellidos,estado_usuario);
    }
}

Get Usuario

fn get_usuario(nombre_usuario:String){
    let connection = &mut establecer_conexion_bc();
    use self::schema::usuarios::dsl::*;
    let results = usuarios
        .filter(nombre.eq(&nombre_usuario))
        .limit(1)
        .load::<Usuarios>(connection)
        .expect("Error obteniendo el usuario");

        if results.len()>0{
            let estado_usuario;
            if results[0].activo == true{
                estado_usuario="Activo".to_string();
            }else{
                estado_usuario="Inactivo".to_string();
            }
           println!("Nombre usuario: {}, apellidos: {} , estado {} ",results[0].nombre,results[0].apellidos,estado_usuario);
        }else{
            println!("No existe el usuario {}",nombre_usuario);
        }
}

Crear Usuario

fn crear_usuario(nombre:&String,apellidos:&String,activo:&bool){
    let connection = &mut establecer_conexion_bc();
    let nuevo_usuario = NuevoUsuario {nombre, apellidos,activo };

    let usuario_creado=diesel::insert_into(usuarios::table)
        .values(nuevo_usuario)
        .execute(connection)
        .expect("Error creando el usuario");
    if usuario_creado==1{
        println!("Usuario creado.");
    }else{
        println!("Se ha producido un error al crear el usuario");
    }
}

Eliminar Usuario

fn eliminar_usuario(id_usuario:i32){
    let connection = &mut  establecer_conexion_bc();
    use self::schema::usuarios::dsl::*;
    let usuario_eliminado = diesel::delete(usuarios.filter(id.eq(id_usuario)))
    .execute(connection)
    .expect("Error eliminando el usuario");
    if usuario_eliminado==1{
        println!("Usuario con id {} eliminado correctamente!",id_usuario);
    }else{
        println!("Se ha producido un error al eliminar el usuario con id {}",id_usuario)
    }  
}

Actualizar Usuario

fn actualizar_usuario(id_usuario:i32){
    use self::schema::usuarios::dsl::*;
    let connection = &mut establecer_conexion_bc();
    let usuario_actualizado=diesel::update(usuarios.filter(id.eq(id_usuario)))
    .set((nombre.eq("James"), apellidos.eq("Not Bond")))
    .execute(connection).unwrap();
    if usuario_actualizado==1{
        println!("Usuario con id {} actualizado correctamente!",id_usuario)
    }else{
        println!("Se ha producido un error al actualizar el usuario con id {}",id_usuario)
    }
}