Как подсчитать количество отдельных элементов в столбце массива с помощью Diesel?

Я пытаюсь реализовать функцию count_distinct_labels для подсчета отдельных элементов в столбце массивов с помощью Diesel и PostgreSQL.

Например, у меня есть такая таблица:

------------------
|     labels     |
------------------
| ['foo', 'bar'] |
------------------
| ['bar', 'baz'] |
------------------

В этом случае count_distinct_labels() должно быть 3, потому что есть 3 уникальных метки ('foo', 'bar', 'baz').

Я обнаружил, что следующий SQL возвращает желаемый результат, но я не знаю, как преобразовать его в выражение Дизеля.

SELECT COUNT(*) FROM (SELECT DISTINCT unnest(labels) FROM t) AS label;

Вот мой исходный код:

#[macro_use]
extern crate diesel;
extern crate dotenv;

use diesel::pg::PgConnection;
use diesel::prelude::*;
use dotenv::dotenv;
use std::env;

mod schema {
    table! {
        t (id) {
            id -> Int4,
            labels -> Array<Text>,
        }
    }

    #[derive(Insertable)]
    #[table_name = "t"]
    pub struct NewRow<'a> {
        pub labels: &'a [String],
    }
}

fn count_distinct_labels(conn: &PgConnection) -> i64 {
    // SELECT COUNT(*) FROM (SELECT DISTINCT unnest(labels) FROM t) AS label
    unimplemented!()
}

fn main() {
    dotenv().ok();

    let database_url = env::var("DATABASE_URL").expect("DATABASE_URL must be set");
    let conn = PgConnection::establish(&database_url)
        .expect(&format!("Error connecting to {}", database_url));

    diesel::insert_into(schema::t::dsl::t)
        .values(&vec![
            schema::NewRow {
                labels: &["foo".to_string(), "bar".to_string()],
            },
            schema::NewRow {
                labels: &["bar".to_string(), "baz".to_string()],
            },
        ]).execute(&conn)
        .unwrap();

    // how to implement?
    assert_eq!(count_distinct_labels(&conn), 3);
}

и Cargo.toml:

[package]
name = "how-to-count-distinct"
version = "0.1.0"
authors = ["name"]

[dependencies]
diesel = { version = "1.0", features = ["postgres"] }
dotenv = "0.13"

Я также создал репозиторий, содержащий полный пример < / а>. Если вы хотите воспроизвести, клонируйте это репо и cargo run. Обратите внимание, что перед запуском кода необходимо запустить службу Postgres.


person pandaman    schedule 15.08.2018    source источник


Ответы (1)


Добавить представление

Самое простое, что можно сделать в Diesel 1.3 1, - это добавить представление в базу данных:

CREATE VIEW unique_labels AS (SELECT DISTINCT unnest(labels) FROM t);

Затем вы можете рассказать Дизелю о виде:

table! {
    unique_labels (unnest) {
        unnest -> Text,
    }
}

И запросите его напрямую:

fn count_distinct_labels(conn: &PgConnection) -> i64 {
    use schema::unique_labels::dsl::*;
    use diesel::dsl;

    unique_labels.select(dsl::count_star()).first(conn).unwrap()
}

Используйте sql_query

Вы всегда можете вернуться к «большому молотку» прямого выполнения SQL:

fn count_distinct_labels(conn: &PgConnection) -> i64 {
    use diesel::sql_types::BigInt;

    #[derive(QueryableByName)]
    struct Count {
        #[sql_type = "BigInt"]
        count: i64,
    }

    diesel::sql_query(r#"SELECT COUNT(*) FROM (SELECT DISTINCT unnest(labels) FROM t) AS label"#)
        .load::<Count>(conn)
        .expect("Query failed")
        .pop()
        .expect("No rows")
        .count
}

1 Diesel 1.3 не имеет возможности передавать ваше собственное предложение FROM вручную, возможно, среди других ограничений.

person Shepmaster    schedule 17.08.2018