db — EdgeSpark database

import { db } from "edgespark";
import { and, desc, eq } from "drizzle-orm";
import { posts } from "@defs";

const rows = await db.select().from(posts);

const [post] = await db
  .select()
  .from(posts)
  .where(eq(posts.id, 1));

const recent = await db
  .select()
  .from(posts)
  .orderBy(desc(posts.createdAt))
  .limit(20);

const mine = await db
  .select()
  .from(posts)
  .where(and(eq(posts.authorId, "user_123"), eq(posts.published, 1)));

import { db } from "edgespark";
import { auth } from "edgespark/http";
import { posts } from "@defs";

const [post] = await db
  .insert(posts)
  .values({
    title: "Hello",
    content: "World",
    authorId: auth.user.id,
  })
  .returning();

import { db } from "edgespark";
import { eq } from "drizzle-orm";
import { posts } from "@defs";

await db
  .update(posts)
  .set({ title: "New title" })
  .where(eq(posts.id, 1));

await db
  .delete(posts)
  .where(eq(posts.id, 1));

import { db } from "edgespark";

const items = await db.query.posts.findMany({
  with: {
    author: true,
    comments: true,
  },
});

import { db } from "edgespark";
import { auth } from "edgespark/http";
import { eq } from "drizzle-orm";
import { activityLog, posts } from "@defs";

await db.batch([
  db.update(posts).set({ published: 1 }).where(eq(posts.id, 1)),
  db.insert(activityLog).values({
    action: "publish",
    postId: 1,
    userId: auth.user.id,
  }),
]);