import {drizzle} from "drizzle-orm/neon-serverless";
import {Pool} from '@neondatabase/serverless';
import {Orders} from "@/app/db/schema";
import {eq} from "drizzle-orm";
export interface Order {
instagram_post_id: string
}
const client = new Pool({
connectionString: process.env.DATABASE_CONNECTION_STRING,
ssl: true,
idleTimeoutMillis: 20000,
})
const db = drizzle(client)
export const getOrder = async (id: string) => {
return db.select().from(Orders).where(eq(Orders.instagram_post_id, id));
}
export const addOrder = async (order: Order) => {
try {
const orderReq = await db.insert(Orders).values({
instagram_post_id: order.instagram_post_id,
}).returning()
console.log({orderReq})
} catch (e) {
console.log({e})
}
return order
}
import {drizzle} from "drizzle-orm/neon-serverless";
import {Pool} from '@neondatabase/serverless';
import {Orders} from "@/app/db/schema";
import {eq} from "drizzle-orm";
export interface Order {
instagram_post_id: string
}
const client = new Pool({
connectionString: process.env.DATABASE_CONNECTION_STRING,
ssl: true,
idleTimeoutMillis: 20000,
})
const db = drizzle(client)
export const getOrder = async (id: string) => {
return db.select().from(Orders).where(eq(Orders.instagram_post_id, id));
}
export const addOrder = async (order: Order) => {
try {
const orderReq = await db.insert(Orders).values({
instagram_post_id: order.instagram_post_id,
}).returning()
console.log({orderReq})
} catch (e) {
console.log({e})
}
return order
}