@alchemy.run/细雨
滴入外科手术 页:1 炼金术。在部署时从您的策略中生成迁移,并查询 D1 、 Postgres、 MySQL 或 libSQL 的输入效果客户端.
npm install alchemy @alchemy.run/drizzle @alchemy.run/cloudflare drizzle-orm drizzle-kit effect
一个计划:
// src/schema.ts
import { integer, sqliteTable, text } from "drizzle-orm/sqlite-core";
export const Users = sqliteTable("users", {
id: integer("id").primaryKey({ autoIncrement: true }),
email: text("email").notNull().unique(),
name: text("name").notNull(),
});
一个D1数据库,其迁移来源于部署时的这一计划,还有一个工人查询:
// src/api.ts
import * as Cloudflare from "@alchemy.run/cloudflare";
import * as Drizzle from "@alchemy.run/drizzle";
import * as Effect from "effect/Effect";
import * as HttpServerResponse from "effect/http/HttpServerResponse";
import { Users } from "./schema.ts";
export const Database = Effect.gen(function* () {
const schema = yield* Drizzle.Schema("Schema", {
schema: "./src/schema.ts",
out: "./migrations",
dialect: "sqlite",
});
return yield* Cloudflare.D1.Database("Db", { migrations: schema });
});
export default class Api extends Cloudflare.Worker<Api>()(
"Api",
{ main: import.meta.url },
Effect.gen(function* () {
const d1 = yield* Cloudflare.D1.QueryDatabase(yield* Database);
const db = yield* Drizzle.D1(d1);
return {
fetch: Effect.gen(function* () {
const users = yield* db.select().from(Users);
return yield* HttpServerResponse.json({ users });
}).pipe(Effect.orDie),
};
}).pipe(Effect.provide(Cloudflare.D1.QueryDatabaseBinding)),
) {}
// alchemy.run.ts
import * as Alchemy from "alchemy";
import * as Cloudflare from "@alchemy.run/cloudflare";
import * as Drizzle from "@alchemy.run/drizzle";
import * as Effect from "effect/Effect";
import * as Layer from "effect/Layer";
import Api from "./src/api.ts";
export default Alchemy.Stack(
"MyApp",
{
providers: Layer.mergeAll(Cloudflare.providers(), Drizzle.providers()),
state: Cloudflare.state(),
},
Effect.gen(function* () {
const api = yield* Api;
return { url: api.url };
}),
);
Drizzle.Postgres, (中文(简体) ), Drizzle.MySQL,以及 Drizzle.LibSQL 与其他数据库一样.