# JOOQ 数据库模式 ## 存储库结构 @存储库类环境存储库（私有 val dsl：DSLContext ）{ fun findById(id: UUID)：环境？ = dsl.selectFrom(环境) .where(环境.ID.eq(id)) .fetchOne() ?.toEntity() fun findByName(name: String): 环境？ = dsl.selectFrom(环境) .where(ENVIRONMENT.NAME.eq(名称)) .fetchOne() ?.toEntity() fun findAll(): List<环境> = dsl.selectFrom(环境) .orderBy(ENVIRONMENT.CREATED_AT.desc()) .fetch() .map { it.toEntity() } 有趣的保存（实体：环境）：环境= dsl.insertInto（环境） .set(环境.ID,实体.id) .set(环境.名称,实体.名称) .set(环境.状态,实体.状态.名称) .set(ENVIRONMENT.CREATED_AT,entity.createdAt) .return() .fetchOne()!! .toEntity() 有趣的更新（实体：环境）：环境= dsl.update（环境） .set(环境.状态,实体.状态.名称) .set(ENVIRONMENT.UPDATED_AT, Instant.now()) .where(ENVIRONMENT.ID.eq(entity.id)) .return() .fetchOne()!! .toEntity() 有趣的删除（ID：UUID）：布尔= dsl.deleteFrom（环境） .where(环境.ID.eq(id)) .execute() > 0 } ## 记录到实体映射 // 生成的 Record 上的扩展函数私人乐趣EnvironmentRecord.toEntity（）=环境（ id = id, 姓名=姓名，状态=环境状态.valueOf(状态), 创建时间 = 创建时间, 更新时间 = 更新时间） // 对于带有连接的复杂映射私人乐趣 Record.toEnvironmentWithTags() = 环境( id = get(环境.ID), 名称 = get(环境.名称), 状态 = EnvironmentStatus.valueOf(get(ENVIRONMENT.STATUS)), 创建于 = get(ENVIRONMENT.CREATED_AT), updateAt = get(ENVIRONMENT.UPDATED_AT), Tags = get("tags", List::class.java) as List ） ## 复杂查询 ### 加入有趣的findWithOwner（id：UUID）：EnvironmentWithOwner？ = dsl.选择（环境.星号(), USER.NAME.`as`("owner_name"), USER.EMAIL.`as`("owner_email") ） .来自（环境） .join(USER).on(ENVIRONMENT.OWNER_ID.eq(USER.ID)) .where(环境.ID.eq(id)) .fetchOne() ?.let { 记录 -> 有所有者的环境（环境 = record.into(ENVIRONMENT).toEntity(), 所有者名称 = record.get("所有者名称", String::class.java), ownerEmail = record.get("owner_email", String::class.java) ） } ### 过滤和分页有趣的findByFilters( 状态：环境状态？，搜索：字符串？，页面：国际，尺寸：内部 ): 页面<环境> { val 条件 = mutableListOf<条件>() status?.let {conditions.add(ENVIRONMENT.STATUS.eq(it.name)) } 搜索？.let { 条件.add(ENVIRONMENT.NAME.likeIgnoreCase("%$it%")) } val baseQuery = dsl.selectFrom(ENVIRONMENT) .where(条件) val 总计 = dsl.selectCount() .来自（环境） .where(条件) .fetchOne(0, Long::class.java) ?: 0L val items = 基本查询 .orderBy(ENVIRONMENT.CREATED_AT.desc()) .限制（大小） .offset(页*大小) .fetch() .map { it.toEntity() } 返回页面（项目，总数，页数，大小） } ### 聚合有趣的 countByStatus(): Map = dsl.select(环境.状态, DSL.count()) .来自（环境） .groupBy(环境.状态) .fetch() .associate { 记录 -> EnvironmentStatus.valueOf(record.value1()) 到 record.value2().toLong() } ## 批量操作 fun saveAll(实体: List<环境>): List<环境> { if (entities.isEmpty()) 返回emptyList() val 记录 =Entity.map { 实体 -> dsl.newRecord(ENVIRONMENT).apply { id = 实体.id 名称 = 实体.名称状态 = 实体.状态.名称创建时间 = 实体.创建时间 } } dsl.batchInsert(记录).execute() 返回实体 } fun updateStatuses(ids: List, 状态: EnvironmentStatus): Int = dsl.update（环境） .set(环境.状态,状态.名称) .set(ENVIRONMENT.UPDATED_AT, Instant.now()) .where(ENVIRONMENT.ID.`in`(ids)) .execute() ## JSON 字段 (PostgreSQL) // 对于 JSONB 列 fun findByMetadata(key: String, value: String): List<环境> = dsl.selectFrom(环境) .哪里( DSL.field("元数据->>'{0}'", String::class.java, key) .eq(值) ） .fetch() .map { it.toEntity() } // 存储 JSON fun updateMetadata(id: UUID, 元数据: Map): 环境 = dsl.update（环境） .set(ENVIRONMENT.METADATA, JSONB.jsonb(objectMapper.writeValueAsString(元数据))) .where(环境.ID.eq(id)) .return() .fetchOne()!! .toEntity() ## 更新插入（冲突时） fun upsert（实体：环境）：环境= dsl.insertInto（环境） .set(环境.ID,实体.id) .set(环境.名称,实体.名称) .set(环境.状态,实体.状态.名称) .set(ENVIRONMENT.CREATED_AT,entity.createdAt) .onConflict(环境.名称) .doUpdate() .set(环境.状态,实体.状态.名称) .set(ENVIRONMENT.UPDATED_AT, Instant.now()) .return() .fetchOne()!! .toEntity() ## 交易处理 // 在服务层 - 显式事务控制 @服务类环境服务（私有val dsl：DSLContext，私有 val 存储库：EnvironmentRepository ）{ 有趣的createWithResources（请求：CreateRequest）：环境= dsl.transactionResult { 配置 -> val txDsl = DSL.using(config) // 创建环境 val env =repository.save(request.toEnvironment()) // 在同一个事务中创建相关资源 request.resources.forEach { 资源 -> txDsl.insertInto（资源） .set(RESOURCE.ENVIRONMENT_ID, env.id) .set(资源.类型, 资源.类型) .execute() } 环境 } } ## 自定义 SQL 函数 // 使用 PostgreSQL 函数 fun findNearExpiry(days: Int): List<环境> = dsl.selectFrom(环境) .哪里( ENVIRONMENT.EXPIRES_AT.lessOrEqual( DSL.currentTimestamp().plus(DSL.interval(天, DatePart.DAY)) ）） .fetch() .map { it.toEntity() } // 数组操作 fun findByTags(标签: List): List = dsl.selectFrom(环境) .哪里( DSL.field("tags").cast(SQLDataType.VARCHAR.array()) .contains(tags.toTypedArray()) ） .fetch() .map { it.toEntity() }

乔克模式

包含技能