sql >> Databasteknik >  >> RDS >> Mysql

Rust:Läs dataram i polars från mysql

Samma svar som i denna fråga , verkar ganska duplicerad IMO.

Du kan använda byggarna för det eller samla in från iteratorer. Det går ofta snabbt att samla in från iteratorer, men i det här fallet kräver det att du slingar Vec<Country> två gånger, så du bör jämföra.

Nedan finns en exempelfunktion för båda de visade lösningarna.

use polars::prelude::*;

struct Country {
    country: String,
    count: i64,
}

fn example_1(values: &[Country]) -> (Series, Series) {
    let ca_country: Utf8Chunked = values.iter().map(|v| &*v.country).collect();
    let ca_count: NoNull<Int64Chunked> = values.iter().map(|v| v.count).collect();
    let mut s_country: Series = ca_country.into();
    let mut s_count: Series = ca_count.into_inner().into();
    s_country.rename("country");
    s_count.rename("country");
    (s_count, s_country)
}

fn example_2(values: &[Country]) -> (Series, Series) {
    let mut country_builder = Utf8ChunkedBuilder::new("country", values.len(), values.len() * 5);
    let mut count_builder = PrimitiveChunkedBuilder::<Int64Type>::new("count", values.len());

    values.iter().for_each(|v| {
        country_builder.append_value(&v.country);
        count_builder.append_value(v.count)
    });

    (
        count_builder.finish().into(),
        country_builder.finish().into(),
    )
}

När du har fått Series , kan du använda DataFrame::new(columns) där columns: Vec<Series> för att skapa en DataFrame .

Btw, om du vill ha maximal prestanda rekommenderar jag verkligen connector-x . Den har integrering av polar och pilar och har fått galen prestanda.



  1. Psycopg / Postgres :Anslutningar hänger ut slumpmässigt

  2. vilket är bättre en stor fråga eller flera små frågor?

  3. Använda förberedda uttalanden med mysql i python

  4. Vad är skillnaden mellan MySQL BOOL och BOOLEAN kolumndatatyper?