fullstack.org.ua

ORM та Query Builder · fullstack.org.ua

Середній17 хв· Fullstack Team

ORM та Query Builder

Порівняєте ORM і query builder, визначите їхні переваги та обмеження для різних сценаріїв роботи з даними.

Що таке ORM і query builder

Коли Node.js-застосунок працює з реляційною базою даних, він може виконувати SQL-запити різними способами:

безпосередньо через драйвер бази даних;
за допомогою query builder;
за допомогою ORM.

ORM (Object-Relational Mapping) зіставляє таблиці бази даних із програмними моделями та об’єктами.

Query builder надає програмний API для побудови SQL-запитів без ручного складання рядків SQL.

Обидва підходи зменшують кількість помилок порівняно з конкатенацією SQL-рядків, але працюють на різних рівнях абстракції.

Query builder

Query builder дає змогу описувати SQL-запит за допомогою ланцюжка викликів методів.

Наприклад, для Knex.js запит:

javascript

const users = await knex("users")
  .select(["id", "email", "created_at"])
  .where("is_active", true)
  .orderBy("created_at", "desc")
  .limit(20);

javascript

const knex = require("knex")({
  client: "pg",
  connection: process.env.DATABASE_URL,
});

async function getActiveUsersWithOrderCount() {
  const rows = await knex("users")
    .leftJoin("orders", "orders.user_id", "users.id")
    .select("users.id", "users.email")
    .count("orders.id as order_count")
    .where("users.is_active", true)
    .groupBy("users.id", "users.email")
    .orderBy("order_count", "desc");

  return rows.map((row) => ({
    id: row.id,
    email: row.email,
    orderCount: Number(row.order_count),
  }));
}

getActiveUsersWithOrderCount()
  .then((users) => {
    console.log(users);
  })
  .catch((error) => {
    console.error("Помилка запиту:", error);
  })
  .finally(() => knex.destroy());

prisma

model User {
  id        Int     @id @default(autoincrement())
  email     String  @unique
  isActive  Boolean @map("is_active")
  orders    Order[]

  @@map("users")
}

model Order {
  id        Int    @id @default(autoincrement())
  userId    Int    @map("user_id")
  total     Float
  user      User   @relation(fields: [userId], references: [id])

  @@map("orders")
}

javascript

const { PrismaClient } = require("@prisma/client");

const prisma = new PrismaClient();

async function getActiveUsers() {
  const users = await prisma.user.findMany({
    where: {
      isActive: true,
    },
    select: {
      id: true,
      email: true,
      _count: {
        select: {
          orders: true,
        },
      },
    },
    orderBy: {
      email: "asc",
    },
  });

  return users.map((user) => ({
    id: user.id,
    email: user.email,
    orderCount: user._count.orders,
  }));
}

getActiveUsers()
  .then((users) => {
    console.log(users);
  })
  .catch((error) => {
    console.error("Помилка запиту:", error);
  })
  .finally(() => prisma.$disconnect());

javascript

async function createOrder(prisma, userId, productId, total) {
  return prisma.$transaction(async (transaction) => {
    const order = await transaction.order.create({
      data: {
        userId,
        total,
      },
    });

    await transaction.product.update({
      where: {
        id: productId,
      },
      data: {
        stock: {
          decrement: 1,
        },
      },
    });

    return order;
  });
}