Tạo API thành access D1 bằng cách sử dụng Proxy Worker Build an API to access D1 using a proxy Worker បង្កើត API ទៅ access D1 ដោយប្រើប្រូកស៊ីកម្មករ

npm create cloudflare@latest -- d1-http

yarn create cloudflare d1-http

pnpm create cloudflare@latest d1-http

cd d1-http

npm i hono

yarn add hono

pnpm add hono

bun add hono

import { Hono } from "hono";  
import { bearerAuth } from "hono/bearer-auth";  
import { logger } from "hono/logger";  
import { prettyJSON } from "hono/pretty-json";  
type Bindings = {  
  API_KEY: string;  
};  
const app = new Hono<{ Bindings: Bindings }>();  
app.use("*", prettyJSON(), logger(), async (c, next) => {  
  const auth = bearerAuth({ token: c.env.API_KEY });  
  return auth(c, next);  
});

// Paste this code at the end of the src/index.ts file  
app.post("/api/all", async (c) => {  
  return c.text("/api/all endpoint");  
});  
app.post("/api/exec", async (c) => {  
  return c.text("/api/exec endpoint");  
});  
app.post("/api/batch", async (c) => {  
  return c.text("/api/batch endpoint");  
});  
export default app;

npm run dev

yarn run dev

pnpm run dev

curl -H "Authorization: Bearer YOUR_API_KEY" "http://localhost:8787/api/all" --data '{}'

/api/all endpoint

npx wrangler d1 create d1-http-example

✅ Successfully created DB 'd1-http-example' in region EEUR  
Created your new D1 database.  
[[d1_databases]]  
binding = "DB" # i.e. available in your Worker on env.DB  
database_name = "d1-http-example"  
database_id = "1234567890"

DROP TABLE IF EXISTS posts;  
CREATE TABLE IF NOT EXISTS posts (  
  id integer PRIMARY KEY AUTOINCREMENT,  
  author text NOT NULL,  
  title text NOT NULL,  
  body text NOT NULL,  
  post_slug text NOT NULL  
);  
INSERT INTO posts (author, title, body, post_slug) VALUES ('Harshil', 'D1 HTTP API', 'Learn to create an API to query your D1 database.','d1-http-api');

npx wrangler d1 execute d1-http-example --file=./schemas/schema.sql

// Update the API routes  
/**  
* Executes the `stmt.run()` method.  
* https://developers.cloudflare.com/d1/worker-api/prepared-statements/#run  
*/  
app.post('/api/all', async (c) => {  
    return c.text("/api/all endpoint");  
  try {  
    let { query, params } = await c.req.json();  
    let stmt = c.env.DB.prepare(query);  
    if (params) {  
      stmt = stmt.bind(params);  
    }  
    const result = await stmt.run();  
    return c.json(result);  
  } catch (err) {  
    return c.json({ error: `Failed to run query: ${err}` }, 500);  
  }  
});  
/**  
* Executes the `db.exec()` method.  
* https://developers.cloudflare.com/d1/worker-api/d1-database/#exec  
*/  
app.post('/api/exec', async (c) => {  
    return c.text("/api/exec endpoint");  
  try {  
    let { query } = await c.req.json();  
    let result = await c.env.DB.exec(query);  
    return c.json(result);  
  } catch (err) {  
    return c.json({ error: `Failed to run query: ${err}` }, 500);  
  }  
});  
/**  
* Executes the `db.batch()` method.  
* https://developers.cloudflare.com/d1/worker-api/d1-database/#batch  
*/  
app.post('/api/batch', async (c) => {  
    return c.text("/api/batch endpoint");  
  try {  
    let { batch } = await c.req.json();  
    let stmts = [];  
    for (let query of batch) {  
      let stmt = c.env.DB.prepare(query.query);  
      if (query.params) {  
        stmts.push(stmt.bind(query.params));  
      } else {  
        stmts.push(stmt);  
      }  
    }  
    const results = await c.env.DB.batch(stmts);  
    return c.json(results);  
  } catch (err) {  
    return c.json({ error: `Failed to run query: ${err}` }, 500);  
  }  
});  
...

npm run dev

yarn run dev

pnpm run dev

curl -H "Authorization: Bearer YOUR_API_KEY" "http://localhost:8787/api/all" --data '{"query": "SELECT title FROM posts WHERE id=?", "params":1}'

curl -H "Authorization: Bearer YOUR_API_KEY" "http://localhost:8787/api/batch" --data '{"batch": [ {"query": "SELECT title FROM posts WHERE id=?", "params":1},{"query": "SELECT id FROM posts"}]}'

curl -H "Authorization: Bearer YOUR_API_KEY" "localhost:8787/api/exec" --data '{"query": "INSERT INTO posts (author, title, body, post_slug) VALUES ('\''Harshil'\'', '\''D1 HTTP API'\'', '\''Learn to create an API to query your D1 database.'\'','\''d1-http-api'\'')" }'

npx wrangler d1 execute d1-http-example --file=./schemas/schema.sql --remote

npx wrangler deploy

⛅️ wrangler 3.78.4 (update available 3.78.5)  
-------------------------------------------------------  
Total Upload: 53.00 KiB / gzip: 13.16 KiB  
Your worker has access to the following bindings:  
- D1 Databases:  
  - DB: d1-http-example (DATABASE_ID)  
Uploaded d1-http (4.29 sec)  
Deployed d1-http triggers (5.57 sec)  
  [DEPLOYED_APP_LINK]  
Current Version ID: [BINDING_ID]

openssl rand -base64 32

[YOUR_API_KEY]

npx wrangler secret put API_KEY

✔ Enter a secret value:

✔ Enter a secret value: [YOUR_API_KEY]

🌀 Creating the secret for the Worker "d1-http"  
✨ Success! Uploaded secret API_KEY

curl -H "Authorization: Bearer YOUR_API_KEY" "https://DEPLOYED_APP_LINK/api/exec" --data '{"query": "SELECT 1"}'

{"@context":"https://schema.org","@type":"BreadcrumbList","itemListElement":[{"@type":"ListItem","position":1,"item":{"@id":"/directory/","name":"Directory"}},{"@type":"ListItem","position":2,"item":{"@id":"/d1/","name":"D1"}},{"@type":"ListItem","position":3,"item":{"@id":"/d1/tutorials/","name":"Tutorials"}},{"@type":"ListItem","position":4,"item":{"@id":"/d1/tutorials/build-an-api-to-access-d1/","name":"Build an API to access D1 using a proxy Worker"}}]}