summaryrefslogtreecommitdiff
path: root/lib/items-ship/repository.ts
diff options
context:
space:
mode:
Diffstat (limited to 'lib/items-ship/repository.ts')
-rw-r--r--lib/items-ship/repository.ts125
1 files changed, 0 insertions, 125 deletions
diff --git a/lib/items-ship/repository.ts b/lib/items-ship/repository.ts
deleted file mode 100644
index 550e6b1d..00000000
--- a/lib/items-ship/repository.ts
+++ /dev/null
@@ -1,125 +0,0 @@
-// src/lib/items/repository.ts
-import db from "@/db/db";
-import { Item, items } from "@/db/schema/items";
-import {
- eq,
- inArray,
- not,
- asc,
- desc,
- and,
- ilike,
- gte,
- lte,
- count,
- gt,
-} from "drizzle-orm";
-import { PgTransaction } from "drizzle-orm/pg-core";
-export type NewItem = typeof items.$inferInsert
-
-/**
- * 단건/복수 조회 시 공통으로 사용 가능한 SELECT 함수 예시
- * - 트랜잭션(tx)을 받아서 사용하도록 구현
- */
-export async function selectItems(
- tx: PgTransaction<any, any, any>,
- params: {
- where?: any; // drizzle-orm의 조건식 (and, eq...) 등
- orderBy?: (ReturnType<typeof asc> | ReturnType<typeof desc>)[];
- offset?: number;
- limit?: number;
- }
-) {
- const { where, orderBy, offset = 0, limit = 10 } = params;
-
- return tx
- .select()
- .from(items)
- .where(where)
- .orderBy(...(orderBy ?? []))
- .offset(offset)
- .limit(limit);
-}
-/** 총 개수 count */
-export async function countItems(
- tx: PgTransaction<any, any, any>,
- where?: any
-) {
- const res = await tx.select({ count: count() }).from(items).where(where);
- return res[0]?.count ?? 0;
-}
-
-/** 단건 Insert 예시 */
-export async function insertItem(
- tx: PgTransaction<any, any, any>,
- data: NewItem // DB와 동일한 insert 가능한 타입
-) {
- // returning() 사용 시 배열로 돌아오므로 [0]만 리턴
- return tx
- .insert(items)
- .values(data)
- .returning({ id: items.id, createdAt: items.createdAt });
-}
-
-/** 복수 Insert 예시 */
-export async function insertItems(
- tx: PgTransaction<any, any, any>,
- data: Item[]
-) {
- return tx.insert(items).values(data).onConflictDoNothing();
-}
-
-
-
-/** 단건 삭제 */
-export async function deleteItemById(
- tx: PgTransaction<any, any, any>,
- itemId: number
-) {
- return tx.delete(items).where(eq(items.id, itemId));
-}
-
-/** 복수 삭제 */
-export async function deleteItemsByIds(
- tx: PgTransaction<any, any, any>,
- ids: number[]
-) {
- return tx.delete(items).where(inArray(items.id, ids));
-}
-
-/** 전체 삭제 */
-export async function deleteAllItems(
- tx: PgTransaction<any, any, any>,
-) {
- return tx.delete(items);
-}
-
-/** 단건 업데이트 */
-export async function updateItem(
- tx: PgTransaction<any, any, any>,
- itemId: number,
- data: Partial<Item>
-) {
- return tx
- .update(items)
- .set(data)
- .where(eq(items.id, itemId))
- .returning({ id: items.id, createdAt: items.createdAt });
-}
-
-/** 복수 업데이트 */
-export async function updateItems(
- tx: PgTransaction<any, any, any>,
- ids: number[],
- data: Partial<Item>
-) {
- return tx
- .update(items)
- .set(data)
- .where(inArray(items.id, ids))
- .returning({ id: items.id, createdAt: items.createdAt });
-}
-
-export async function findAllItems(): Promise<Item[]> {
- return db.select().from(items).orderBy(asc(items.itemCode));
-}