feat: Tokio with D1 example

examples/tokio-d1/.gitignore

@@ -0,0 +1 @@
+target

examples/tokio-d1/Cargo.toml

@@ -0,0 +1,20 @@
+[package]
+name = "tokio-postgres-on-workers"
+version = "0.1.0"
+edition = "2021"
+resolver = "2"
+
+[package.metadata.release]
+release = false
+
+# https://github.com/rustwasm/wasm-pack/issues/1247
+[package.metadata.wasm-pack.profile.release]
+wasm-opt = false
+
+[lib]
+crate-type = ["cdylib"]
+
+[dependencies]
+worker = { workspace=true, features=["tokio-postgres", "d1"] }
+serde_json = "1.0.114"
+serde = "1.0.197"

examples/tokio-d1/README.md

@@ -0,0 +1,17 @@
+# tokio and d1 on Cloudflare Workers
+
+Demonstration of using `tokio` and `d1` on Cloudflare Workers.
+
+## Setup
+1. `npx wrangler d1 create dev-d1-rust`
+
+Now you can add your database to the configuration toml by replacing
+`<YOUR_DATABASE_ID>`
+
+
+2. Insert some records
+`npx wrangler d1 execute dev-d1-rust --file=./database/schema.sql`
+
+
+
+3. `npm run deploy`

examples/tokio-d1/database/schema.sql

@@ -0,0 +1,3 @@
+DROP TABLE IF EXISTS Customers;
+CREATE TABLE IF NOT EXISTS Customers (CustomerId INTEGER PRIMARY KEY, CompanyName TEXT, ContactName TEXT);
+INSERT INTO Customers (CustomerID, CompanyName, ContactName) VALUES (1, 'Alfreds Futterkiste', 'Maria Anders'), (4, 'Around the Horn', 'Thomas Hardy'), (11, 'Bs Beverages', 'Victoria Ashworth'), (13, 'Bs Beverages', 'Random Name');

examples/tokio-d1/package.json

@@ -0,0 +1,12 @@
+{
+	"name": "tokio-d1",
+	"version": "0.0.0",
+	"private": true,
+	"scripts": {
+		"deploy": "wrangler deploy",
+		"dev": "wrangler dev --local"
+	},
+	"devDependencies": {
+		"wrangler": "^2.13.0"
+	}
+}

examples/tokio-d1/src/lib.rs

@@ -0,0 +1,24 @@
+use worker::*;
+
+use serde::{Deserialize,Serialize};
+
+
+#[allow(non_snake_case)]
+#[derive(Deserialize,Serialize)]
+struct Customers {
+	CustomerId: String,
+	CompanyName: String,
+	ContactName: String
+}
+
+#[event(fetch)]
+async fn main(_req: Request, env: Env, _ctx: Context) -> Result<Response> {
+    let d1 = env.d1("DB")?;
+    let statement = d1.prepare("SELECT * FROM Customers WHERE id = ?1");
+    let query = statement.bind(&["1".into()])?;
+	let result = query.first::<Customers>(None).await?;
+	match result {
+        Some(customer) => Response::from_json(&customer),
+        None => Response::error("Not found", 404),
+    }
+}

examples/tokio-d1/wrangler.toml

@@ -0,0 +1,11 @@
+name = "tokio-postgres-on-workers"
+main = "build/worker/shim.mjs"
+compatibility_date = "2023-03-22"
+
+[build]
+command = "cargo install --path ../../worker-build && worker-build --release"
+
+[[d1_databases]]
+binding = "DB" # i.e. available in your Worker on env.DB
+database_name = "dev-d1-rust"
+database_id = "<YOUR_DATABASE_ID>"