import { Kysely, PostgresDialect } from 'kysely'
import { Pool } from 'pg'
import { createExecutor } from '@kysera/executor'
import { createORM } from '@kysera/repository'
import { softDeletePlugin } from '@kysera/soft-delete'

// 1. Define schema
interface Database {
  users: { id: Generated<number>; email: string; name: string }
}

// 2. Connect
const db = new Kysely<Database>({
  dialect: new PostgresDialect({ pool: new Pool({ connectionString: process.env.DATABASE_URL }) })
})

// 3. Create executor with plugins
const executor = await createExecutor(db, [softDeletePlugin()])

// 4. Create ORM
const orm = await createORM(executor, [])
const userRepo = orm.createRepository(createUserRepository)

// 5. Query - plugins apply automatically
const users = await userRepo.findAll() // Automatically filters deleted records

import { createExecutor } from '@kysera/executor'
import { softDeletePlugin } from '@kysera/soft-delete'

const executor = await createExecutor(db, [softDeletePlugin()])

// Works everywhere
const users = await executor.selectFrom('users').selectAll().execute()

const userRepo = orm.createRepository({
  tableName: 'users',
  schemas: { entity: UserSchema, create: CreateUserSchema },
})

const users = await userRepo.findAll()
await userRepo.create({ email: '[email protected]', name: 'Alice' })

import { createQuery, createContext } from '@kysera/dal'

const getUserById = createQuery((ctx, id: number) =>
  ctx.db.selectFrom('users').where('id', '=', id).executeTakeFirst()
)

const ctx = createContext(executor)
const user = await getUserById(ctx, 1)

import { parseDatabaseError, UniqueConstraintError } from '@kysera/core'

try {
  await userRepo.create(userData)
} catch (error) {
  const dbError = parseDatabaseError(error, 'postgres')
  if (dbError instanceof UniqueConstraintError) {
    // Handle duplicate
  }
}

import { paginate, paginateCursor } from '@kysera/core'

// Offset pagination
const result = await paginate(query, { page: 1, limit: 20 })

// Cursor pagination
const result = await paginateCursor(query, {
  orderBy: [{ column: 'created_at', direction: 'desc' }],
  limit: 20
})