Chdb Datastore

# Change this:import pandas as pd# To this:import chdb.datastore as pd# Everything else stays the same.

from datastore import DataStore
# Local file (auto-detects .parquet, .csv, .json, .arrow, .orc, .avro, .tsv, .xml)ds = DataStore.from_file("sales.parquet")
# Databaseds = DataStore.from_mysql(host="db:3306", database="shop", table="orders", user="root", password="pass")
# Cloud storageds = DataStore.from_s3("s3://bucket/data.parquet", nosign=True)
# URI shorthand — auto-detects source typeds = DataStore.uri("mysql://root:pass@db:3306/shop/orders")

result = ds[ds["age"] > 25]                                          # filterresult = ds[["name", "city"]]                                        # select columnsresult = ds.sort_values("revenue", ascending=False)                  # sortresult = ds.groupby("dept")["salary"].mean()                         # groupbyresult = ds.assign(margin=lambda x: x["profit"] / x["revenue"])     # computed columnds["name"].str.upper()                                               # string accessords["date"].dt.year                                                   # datetime accessorresult = ds1.join(ds2, on="id")                                      # joinresult = ds.head(10)                                                 # previewprint(ds.to_sql())                                                   # see generated SQL

from datastore import DataStore
customers = DataStore.from_mysql(host="db:3306", database="crm", table="customers", user="root", password="pass")orders = DataStore.from_file("orders.parquet")
result = (orders    .join(customers, left_on="customer_id", right_on="id")    .groupby("country")    .agg({"amount": "sum", "rating": "mean"})    .sort_values("sum", ascending=False))print(result)

source = DataStore.from_mysql(host="db:3306", database="shop", table="orders", user="root", password="pass")target = DataStore("file", path="summary.parquet", format="Parquet")
target.insert_into("category", "total", "count").select_from(    source.groupby("category").select("category", "sum(amount) AS total", "count() AS count")).execute()