Database Repository

import { createMongoConnection } from'@esengine/database-drivers'
import { Repository, createRepository } from'@esengine/database'
// Define entity
interface Player {
id:string
name:string
score:number
createdAt:Date
updatedAt:Date
}
// Create connection
const mongo = createMongoConnection({
uri: 'mongodb://localhost:27017',
database: 'game'
})
await mongo.connect()
// Create repository
const playerRepo = createRepository<Player>(mongo, 'players')
// CRUD operations
const player = await playerRepo.create({
name: 'John',
score: 0
})
const found = await playerRepo.findById(player.id)
await playerRepo.update(player.id, { score: 100 })
await playerRepo.delete(player.id)

import { Repository, BaseEntity } from'@esengine/database'
importtype { IMongoConnection } from'@esengine/database-drivers'
interface Player extendsBaseEntity {
name:string
score:number
rank?:string
}
classPlayerRepositoryextendsRepository<Player> {
constructor(connection:IMongoConnection) {
super(connection, 'players')
}
asyncfindTopPlayers(limit:number=10):Promise<Player[]> {
returnthis.findMany({
sort: { score: 'desc' },
limit
})
}
asyncfindByRank(rank:string):Promise<Player[]> {
returnthis.findMany({
where: { rank }
})
}
}
// Usage
const playerRepo = newPlayerRepository(mongo)
const topPlayers = await playerRepo.findTopPlayers(5)

import { UserRepository } from'@esengine/database'
const userRepo = newUserRepository(mongo)
// Register new user
const user = await userRepo.register({
username: 'john',
password: 'securePassword123',
email: 'john@example.com'
})
// Authenticate
const authenticated = await userRepo.authenticate('john', 'securePassword123')
if (authenticated) {
console.log('Login successful:', authenticated.username)
}
// Change password
await userRepo.changePassword(user.id, 'securePassword123', 'newPassword456')
// Role management
await userRepo.addRole(user.id, 'admin')
await userRepo.removeRole(user.id, 'admin')
// Find users
const admins = await userRepo.findByRole('admin')
const john = await userRepo.findByUsername('john')

const result = await playerRepo.findPaginated(
{ page: 1, pageSize: 20 },
{
where: { rank: 'gold' },
sort: { score: 'desc' }
}
)
console.log(result.data) // Player[]
console.log(result.total) // Total count
console.log(result.totalPages) // Total pages
console.log(result.hasNext) // Has next page
console.log(result.hasPrev) // Has previous page

// Enable soft delete
const playerRepo = createRepository<Player>(mongo, 'players', true)
// Delete (marks as deleted)
await playerRepo.delete(playerId)
// Find excludes soft-deleted by default
const players = await playerRepo.findMany()
// Include soft-deleted records
const allPlayers = await playerRepo.findMany({
includeSoftDeleted: true
})
// Restore soft-deleted record
await playerRepo.restore(playerId)

// Complex queries
const players = await playerRepo.findMany({
where: {
score: { $gte: 100 },
rank: { $in: ['gold', 'platinum'] },
name: { $like: 'John%' }
},
sort: {
score: 'desc',
name: 'asc'
},
limit: 10,
offset: 0
})
// OR conditions
const players = await playerRepo.findMany({
where: {
$or: [
{ score: { $gte: 1000 } },
{ rank: 'legendary' }
]
}
})