support multi keyword search

yhornisse / bremer

Browse code support multi keyword search master
1 parent de37dc4 commit d6108b554cdc426b6d0cbff56d3e1eeb4fddb2ab yhornisse authored on 20 Aug 2023

Patch

Showing 7 changed files

Ignore Space Show notes View src/main/kotlin/controller/api/AudioApiController.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.controller.api import jakarta.validation.Valid import net.piedpiper.bremer.model.api.AudioListResponse import net.piedpiper.bremer.model.api.AudioRequest import net.piedpiper.bremer.service.AudioService import org.springframework.beans.factory.annotation.Qualifier import org.springframework.http.ResponseEntity import org.springframework.web.bind.annotation. @RestController("bremer.controller.AudioApiController") @RequestMapping("bremer/api/audio") class AudioApiController( @Qualifier("bremer.service.AudioService") private val audioService: AudioService ) { companion object { private const val PAGE_LIMIT = 50 } // TODO 複数キーワード対応 @GetMapping fun getAudioList( @RequestParam("audio", required = false) audioName: String?, @RequestParam("artist", required = false) artistName: String?, @RequestParam("album", required = false) albumName: String?, @RequestParam("tag", required = false) tagName: String? ): ResponseEntity<AudioListResponse> = ResponseEntity.ok( audioService.getByKeywords( audioName?.split("\\s".toRegex())?.toList(), artistName?.split("\\s".toRegex())?.toList(), albumName?.split("\\s".toRegex())?.toList(), tagName?.split("\\s".toRegex())?.toList(), PAGE_LIMIT ) ) @GetMapping("history") fun getLeastRecentlyPlayedList(): ResponseEntity<AudioListResponse> = ResponseEntity.ok(audioService.getLeastRecentlyAccessedAudio(PAGE_LIMIT)) @PostMapping("history/{slug}") fun updateHistory( @PathVariable("slug") slug: String ): ResponseEntity<Void> { audioService.updateHistory(slug) return ResponseEntity.ok(null) } @PutMapping("{slug}") fun updateAudio( @PathVariable("slug") slug: String, @Valid @RequestBody request: AudioRequest ): ResponseEntity<Void> { audioService.update(slug, request) return ResponseEntity.ok(null) } } /* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.controller.api import jakarta.validation.Valid import net.piedpiper.bremer.model.api.AudioListResponse import net.piedpiper.bremer.model.api.AudioRequest import net.piedpiper.bremer.service.AudioService import org.springframework.beans.factory.annotation.Qualifier import org.springframework.http.ResponseEntity import org.springframework.web.bind.annotation. @RestController("bremer.controller.AudioApiController") @RequestMapping("bremer/api/audio") class AudioApiController( @Qualifier("bremer.service.AudioService") private val audioService: AudioService ) { companion object { private const val PAGE_LIMIT = 50 } // TODO 複数キーワード対応 @GetMapping fun getAudioList( @RequestParam("audio", required = false) audioName: String?, @RequestParam("artist", required = false) artistName: String?, @RequestParam("album", required = false) albumName: String?, @RequestParam("tag", required = false) tagName: String? ): ResponseEntity<AudioListResponse> = ResponseEntity.ok( audioService.getByKeywords( audioName, artistName, albumName, tagName, PAGE_LIMIT ) ) @GetMapping("history") fun getLeastRecentlyPlayedList(): ResponseEntity<AudioListResponse> = ResponseEntity.ok(audioService.getLeastRecentlyAccessedAudio(PAGE_LIMIT)) @PostMapping("history/{slug}") fun updateHistory( @PathVariable("slug") slug: String ): ResponseEntity<Void> { audioService.updateHistory(slug) return ResponseEntity.ok(null) } @PutMapping("{slug}") fun updateAudio( @PathVariable("slug") slug: String, @Valid @RequestBody request: AudioRequest ): ResponseEntity<Void> { audioService.update(slug, request) return ResponseEntity.ok(null) } }

Ignore Space Show notes View

src/main/kotlin/controller/api/AudioApiController.kt

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.controller.api

import jakarta.validation.Valid
import net.piedpiper.bremer.model.api.AudioListResponse
import net.piedpiper.bremer.model.api.AudioRequest
import net.piedpiper.bremer.service.AudioService
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.http.ResponseEntity
import org.springframework.web.bind.annotation.*

@RestController("bremer.controller.AudioApiController")
@RequestMapping("bremer/api/audio")
class AudioApiController(
    @Qualifier("bremer.service.AudioService")
    private val audioService: AudioService
) {
    companion object {
        private const val PAGE_LIMIT = 50
    }

// TODO 複数キーワード対応
    @GetMapping
    fun getAudioList(
        @RequestParam("audio", required = false) audioName: String?,
        @RequestParam("artist", required = false) artistName: String?,
        @RequestParam("album", required = false) albumName: String?,
        @RequestParam("tag", required = false) tagName: String?
    ): ResponseEntity<AudioListResponse> =
        ResponseEntity.ok(
            audioService.getByKeywords(
                audioName?.split("\\s".toRegex())?.toList(),
                artistName?.split("\\s".toRegex())?.toList(),
                albumName?.split("\\s".toRegex())?.toList(),
                tagName?.split("\\s".toRegex())?.toList(),
                PAGE_LIMIT
            )
        )

@GetMapping("history")
    fun getLeastRecentlyPlayedList(): ResponseEntity<AudioListResponse> =
        ResponseEntity.ok(audioService.getLeastRecentlyAccessedAudio(PAGE_LIMIT))

@PostMapping("history/{slug}")
    fun updateHistory(
        @PathVariable("slug") slug: String
    ): ResponseEntity<Void> {
        audioService.updateHistory(slug)
        return ResponseEntity.ok(null)
    }

@PutMapping("{slug}")
    fun updateAudio(
        @PathVariable("slug") slug: String,
        @Valid @RequestBody request: AudioRequest
    ): ResponseEntity<Void> {
        audioService.update(slug, request)
        return ResponseEntity.ok(null)
    }
}

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.controller.api

// TODO 複数キーワード対応
    @GetMapping
    fun getAudioList(
        @RequestParam("audio", required = false) audioName: String?,
        @RequestParam("artist", required = false) artistName: String?,
        @RequestParam("album", required = false) albumName: String?,
        @RequestParam("tag", required = false) tagName: String?
    ): ResponseEntity<AudioListResponse> =
        ResponseEntity.ok(
            audioService.getByKeywords(
                audioName, artistName, albumName, tagName, PAGE_LIMIT
            )
        )

@GetMapping("history")
    fun getLeastRecentlyPlayedList(): ResponseEntity<AudioListResponse> =
        ResponseEntity.ok(audioService.getLeastRecentlyAccessedAudio(PAGE_LIMIT))

Ignore Space Show notes View src/main/kotlin/dao/AlbumDao.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.AlbumEntity import net.piedpiper.bremer.entity.AudioEntity import net.piedpiper.bremer.entity.AudioPlayHistoryEntity import net.piedpiper.bremer.utils.DaoUtils import net.piedpiper.bremer.utils.SelectSQLBuilder import net.piedpiper.bremer.utils.WHERE_LIKES import org.apache.ibatis.annotations. import org.apache.ibatis.jdbc.SelectBuilder import org.springframework.stereotype.Repository @Repository("bremer.dao.AlbumDao") @Mapper interface AlbumDao { @ResultMap("net.piedpiper.bremer.AlbumEntity") @Select("SELECT * FROM album WHERE id = #{id} FOR UPDATE") fun findOneByIdWithLock(@Param("id") id: Long): AlbumEntity? @ResultMap("net.piedpiper.bremer.AlbumEntity") @Select( """<script> SELECT * FROM album WHERE artist_id IN <foreach item="artistId" collection="artistIds" open="(" separator="," close=")"> #{artistId} </foreach> LIMIT #{limit} </script>""" ) fun findAllByArtistIdInLimit( @Param("artistIds") artistIds: List<Long>, @Param("limit") limit: Int ): List<AlbumEntity> @ResultMap("net.piedpiper.bremer.AlbumEntity") @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit") fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, @Param("limit") limit: Int ): List<AlbumEntity> @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: AlbumEntity) class Sql { companion object { @JvmStatic fun updateOne(@Param("entity") entity: AlbumEntity): String = DaoUtils.updateOne(entity) @JvmStatic fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, ): String = SelectSQLBuilder(AlbumEntity::class) .toSql() .WHERE_LIKES("name", "namesLike", namesLike.size) .LIMIT("#{limit}") .toString() } } } /* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.AlbumEntity import net.piedpiper.bremer.entity.AudioEntity import net.piedpiper.bremer.entity.AudioPlayHistoryEntity import net.piedpiper.bremer.utils.DaoUtils import org.apache.ibatis.annotations. import org.springframework.stereotype.Repository @Repository("bremer.dao.AlbumDao") @Mapper interface AlbumDao { @ResultMap("net.piedpiper.bremer.AlbumEntity") @Select("SELECT * FROM album WHERE id = #{id} FOR UPDATE") fun findOneByIdWithLock(@Param("id") id: Long): AlbumEntity? @ResultMap("net.piedpiper.bremer.AlbumEntity") @Select( """<script> SELECT * FROM album WHERE artist_id IN <foreach item="artistId" collection="artistIds" open="(" separator="," close=")"> #{artistId} </foreach> LIMIT #{limit} </script>""" ) fun findAllByArtistIdInLimit( @Param("artistIds") artistIds: List<Long>, @Param("limit") limit: Int ): List<AlbumEntity> @ResultMap("net.piedpiper.bremer.AlbumEntity") @Select("SELECT * FROM album WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}") fun findAllByNameLikeLimit( @Param("nameLike") nameLike: String, @Param("limit") limit: Int ): List<AlbumEntity> @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: AlbumEntity) class Sql { companion object { @JvmStatic fun updateOne(@Param("entity") entity: AlbumEntity): String = DaoUtils.updateOne(entity) } } }

Ignore Space Show notes View

src/main/kotlin/dao/AlbumDao.kt

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.AlbumEntity
import net.piedpiper.bremer.entity.AudioEntity
import net.piedpiper.bremer.entity.AudioPlayHistoryEntity
import net.piedpiper.bremer.utils.DaoUtils
import net.piedpiper.bremer.utils.SelectSQLBuilder
import net.piedpiper.bremer.utils.WHERE_LIKES
import org.apache.ibatis.annotations.*
import org.apache.ibatis.jdbc.SelectBuilder
import org.springframework.stereotype.Repository

@Repository("bremer.dao.AlbumDao")
@Mapper
interface AlbumDao {

@ResultMap("net.piedpiper.bremer.AlbumEntity")
    @Select("SELECT * FROM album WHERE id = #{id} FOR UPDATE")
    fun findOneByIdWithLock(@Param("id") id: Long): AlbumEntity?

@ResultMap("net.piedpiper.bremer.AlbumEntity")
    @Select(
        """<script>
    SELECT * FROM album WHERE artist_id IN
    <foreach item="artistId" collection="artistIds" open="(" separator="," close=")">
    #{artistId}
    </foreach>
    LIMIT #{limit}
    </script>"""
    )
    fun findAllByArtistIdInLimit(
        @Param("artistIds") artistIds: List<Long>,
        @Param("limit") limit: Int
    ): List<AlbumEntity>

@ResultMap("net.piedpiper.bremer.AlbumEntity")
    @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit")
    fun findAllByNamesLikeLimit(
        @Param("namesLike") namesLike: List<String>,
        @Param("limit") limit: Int
    ): List<AlbumEntity>

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: AlbumEntity)

class Sql {
        companion object {
            @JvmStatic
            fun updateOne(@Param("entity") entity: AlbumEntity): String =
                DaoUtils.updateOne(entity)

@JvmStatic
            fun findAllByNamesLikeLimit(
                @Param("namesLike") namesLike: List<String>,
            ): String = SelectSQLBuilder(AlbumEntity::class)
                .toSql()
                .WHERE_LIKES("name", "namesLike", namesLike.size)
                .LIMIT("#{limit}")
                .toString()
        }
    }
}

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.AlbumEntity
import net.piedpiper.bremer.entity.AudioEntity
import net.piedpiper.bremer.entity.AudioPlayHistoryEntity
import net.piedpiper.bremer.utils.DaoUtils
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.AlbumDao")
@Mapper
interface AlbumDao {

@ResultMap("net.piedpiper.bremer.AlbumEntity")
    @Select("SELECT * FROM album WHERE id = #{id} FOR UPDATE")
    fun findOneByIdWithLock(@Param("id") id: Long): AlbumEntity?

@ResultMap("net.piedpiper.bremer.AlbumEntity")
    @Select("SELECT * FROM album WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}")
    fun findAllByNameLikeLimit(
        @Param("nameLike") nameLike: String,
        @Param("limit") limit: Int
    ): List<AlbumEntity>

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: AlbumEntity)

class Sql {
        companion object {
            @JvmStatic
            fun updateOne(@Param("entity") entity: AlbumEntity): String =
                DaoUtils.updateOne(entity)
        }
    }
}

Ignore Space Show notes View src/main/kotlin/dao/ArtistDao.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.AlbumEntity import net.piedpiper.bremer.entity.ArtistEntity import net.piedpiper.bremer.utils.DaoUtils import net.piedpiper.bremer.utils.SelectSQLBuilder import net.piedpiper.bremer.utils.WHERE_LIKES import org.apache.ibatis.annotations. import org.springframework.stereotype.Repository @Repository("bremer.dao.ArtistDao") @Mapper interface ArtistDao { @ResultMap("net.piedpiper.bremer.ArtistEntity") @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit") fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, @Param("limit") limit: Int ): List<ArtistEntity> @ResultMap("net.piedpiper.bremer.ArtistEntity") @Select("SELECT * FROM artist WHERE id = #{id} FOR UPDATE") fun findOneByIdWithLock(@Param("id") id: Long) : ArtistEntity? @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: ArtistEntity) class Sql { companion object { @JvmStatic fun updateOne(@Param("entity") entity: ArtistEntity): String = DaoUtils.updateOne(entity) @JvmStatic fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, ): String = SelectSQLBuilder(ArtistEntity::class) .toSql() .WHERE_LIKES("name", "namesLike", namesLike.size) .LIMIT("#{limit}") .toString() } } } /* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.ArtistEntity import net.piedpiper.bremer.utils.DaoUtils import org.apache.ibatis.annotations. import org.springframework.stereotype.Repository @Repository("bremer.dao.ArtistDao") @Mapper interface ArtistDao { @ResultMap("net.piedpiper.bremer.ArtistEntity") @Select("SELECT * FROM artist WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}") fun findAllByNameLikeLimit( @Param("nameLike") nameLike: String, @Param("limit") limit: Int ): List<ArtistEntity> @ResultMap("net.piedpiper.bremer.ArtistEntity") @Select("SELECT * FROM artist WHERE id = #{id} FOR UPDATE") fun findOneByIdWithLock(@Param("id") id: Long) : ArtistEntity? @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: ArtistEntity) class Sql { companion object { @JvmStatic fun updateOne(@Param("entity") entity: ArtistEntity): String = DaoUtils.updateOne(entity) } } }

Ignore Space Show notes View

src/main/kotlin/dao/ArtistDao.kt

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.AlbumEntity
import net.piedpiper.bremer.entity.ArtistEntity
import net.piedpiper.bremer.utils.DaoUtils
import net.piedpiper.bremer.utils.SelectSQLBuilder
import net.piedpiper.bremer.utils.WHERE_LIKES
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.ArtistDao")
@Mapper
interface ArtistDao {

@ResultMap("net.piedpiper.bremer.ArtistEntity")
    @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit")
    fun findAllByNamesLikeLimit(
        @Param("namesLike") namesLike: List<String>,
        @Param("limit") limit: Int
    ): List<ArtistEntity>

@ResultMap("net.piedpiper.bremer.ArtistEntity")
    @Select("SELECT * FROM artist WHERE id = #{id} FOR UPDATE")
    fun findOneByIdWithLock(@Param("id") id: Long) : ArtistEntity?

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: ArtistEntity)

class Sql {
        companion object {
            @JvmStatic
            fun updateOne(@Param("entity") entity: ArtistEntity): String =
                DaoUtils.updateOne(entity)

@JvmStatic
            fun findAllByNamesLikeLimit(
                @Param("namesLike") namesLike: List<String>,
            ): String = SelectSQLBuilder(ArtistEntity::class)
                .toSql()
                .WHERE_LIKES("name", "namesLike", namesLike.size)
                .LIMIT("#{limit}")
                .toString()
        }
    }
}

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.ArtistEntity
import net.piedpiper.bremer.utils.DaoUtils
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.ArtistDao")
@Mapper
interface ArtistDao {

@ResultMap("net.piedpiper.bremer.ArtistEntity")
    @Select("SELECT * FROM artist WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}")
    fun findAllByNameLikeLimit(
        @Param("nameLike") nameLike: String,
        @Param("limit") limit: Int
    ): List<ArtistEntity>

@ResultMap("net.piedpiper.bremer.ArtistEntity")
    @Select("SELECT * FROM artist WHERE id = #{id} FOR UPDATE")
    fun findOneByIdWithLock(@Param("id") id: Long) : ArtistEntity?

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: ArtistEntity)

class Sql {
        companion object {
            @JvmStatic
            fun updateOne(@Param("entity") entity: ArtistEntity): String =
                DaoUtils.updateOne(entity)
        }
    }
}

Ignore Space Show notes View src/main/kotlin/dao/AudioDao.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity. import net.piedpiper.bremer.utils.DaoUtils import net.piedpiper.bremer.utils.SelectSQLBuilder import net.piedpiper.bremer.utils.WHERE_IN import net.piedpiper.bremer.utils.WHERE_LIKES import org.apache.ibatis.annotations.* import org.springframework.stereotype.Repository @Repository("bremer.dao.AudioDao") @Mapper interface AudioDao { @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findOneById") fun findOneById(@Param("id") id: Long): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findOneBySlug") fun findOneBySlug(@Param("slug") slug: String): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @Select("SELECT * FROM audio WHERE slug = #{slug} FOR UPDATE") fun findOneBySlugWithLock(@Param("slug") slug: String): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByAlbumIdIn") fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByTagIdIn") fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByIdIn") fun findAllByIdIn(@Param("ids") ids: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllBySlugIn") fun findAllBySlugIn(@Param("slugs") ids: List<String>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByNameLikesLimit") fun findAllByNameLikesLimit( @Param("nameLikes") nameLikes: List<String>, @Param("limit") limit: Int ): List<AudioEntity> @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: AudioEntity) class Sql { companion object { @JvmStatic fun findOneById(): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE("audio.id = #{id}") .toString() @JvmStatic fun findOneBySlug(): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE("audio.slug = #{slug}") .toString() @JvmStatic fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.album_id", "albumIds", albumIds.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByIdIn(@Param("ids") ids: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.id", "ids", ids.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllBySlugIn(@Param("slugs") slugs: List<String>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.slug", "slugs", slugs.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .leftOuterJoin(AudioTagEntity::class, "audio.id = audio_tag.audio_id") .toSql() .WHERE_IN("audio_tag.tag_id", "tagIds", tagIds.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByNameLikesLimit( @Param("nameLikes") nameLikes: List<String>, @Param("limit") limit: Long ): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin( ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class ) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_LIKES("audio.name", "nameLikes", nameLikes.size) .OR() .WHERE_LIKES("audio_name.name", "nameLikes", nameLikes.size) .ORDER_BY("audio.album_id, audio.sequence") .LIMIT("#{limit}") .toString() @JvmStatic fun updateOne(@Param("entity") entity: AudioEntity): String = DaoUtils.updateOne(entity) } } } /* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity. import net.piedpiper.bremer.utils.DaoUtils import net.piedpiper.bremer.utils.SelectSQLBuilder import net.piedpiper.bremer.utils.WHERE_IN import org.apache.ibatis.annotations.* import org.springframework.stereotype.Repository @Repository("bremer.dao.AudioDao") @Mapper interface AudioDao { @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findOneById") fun findOneById(@Param("id") id: Long): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findOneBySlug") fun findOneBySlug(@Param("slug") slug: String): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @Select("SELECT * FROM audio WHERE slug = #{slug} FOR UPDATE") fun findOneBySlugWithLock(@Param("slug") slug: String): AudioEntity? @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByAlbumIdIn") fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByTagIdIn") fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByIdIn") fun findAllByIdIn(@Param("ids") ids: List<Long>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllBySlugIn") fun findAllBySlugIn(@Param("slugs") ids: List<String>): List<AudioEntity> @ResultMap("net.piedpiper.bremer.AudioEntity") @SelectProvider(type = Sql::class, method = "findAllByNameLikeLimit") fun findAllByNameLikeLimit( @Param("nameLike") nameLike: String, @Param("limit") limit: Int ): List<AudioEntity> @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: AudioEntity) class Sql { companion object { @JvmStatic fun findOneById(): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE("audio.id = #{id}") .toString() @JvmStatic fun findOneBySlug(): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE("audio.slug = #{slug}") .toString() @JvmStatic fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.album_id", "albumIds", albumIds.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByIdIn(@Param("ids") ids: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.id", "ids", ids.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllBySlugIn(@Param("slugs") slugs: List<String>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE_IN("audio.slug", "slugs", slugs.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .leftOuterJoin(AudioTagEntity::class, "audio.id = audio_tag.audio_id") .toSql() .WHERE_IN("audio_tag.tag_id", "tagIds", tagIds.size) .ORDER_BY("audio.album_id, audio.sequence") .toString() @JvmStatic fun findAllByNameLikeLimit( @Param("nameLike") nameLike: String, @Param("limit") limit: Long ): String = SelectSQLBuilder(AudioEntity::class) .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id") .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class) .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id") .toSql() .WHERE( "audio.name LIKE CONCAT('%', #{nameLike}, '%') OR " + "audio_name.name LIKE CONCAT('%', #{nameLike}, '%')" ) .ORDER_BY("audio.album_id, audio.sequence") .LIMIT("#{limit}") .toString() @JvmStatic fun updateOne(@Param("entity") entity: AudioEntity): String = DaoUtils.updateOne(entity) } } }

Ignore Space Show notes View

src/main/kotlin/dao/AudioDao.kt

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.*
import net.piedpiper.bremer.utils.DaoUtils
import net.piedpiper.bremer.utils.SelectSQLBuilder
import net.piedpiper.bremer.utils.WHERE_IN
import net.piedpiper.bremer.utils.WHERE_LIKES
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.AudioDao")
@Mapper
interface AudioDao {

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findOneById")
    fun findOneById(@Param("id") id: Long): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findOneBySlug")
    fun findOneBySlug(@Param("slug") slug: String): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @Select("SELECT * FROM audio WHERE slug = #{slug} FOR UPDATE")
    fun findOneBySlugWithLock(@Param("slug") slug: String): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByAlbumIdIn")
    fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByTagIdIn")
    fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByIdIn")
    fun findAllByIdIn(@Param("ids") ids: List<Long>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllBySlugIn")
    fun findAllBySlugIn(@Param("slugs") ids: List<String>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByNameLikesLimit")
    fun findAllByNameLikesLimit(
        @Param("nameLikes") nameLikes: List<String>,
        @Param("limit") limit: Int
    ): List<AudioEntity>

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: AudioEntity)

class Sql {
        companion object {
            @JvmStatic
            fun findOneById(): String = SelectSQLBuilder(AudioEntity::class)
                .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                .leftOuterJoin(
                    ArtistEntity::class,
                    "album.artist_id = artist.id",
                    AlbumEntity::class
                )
                .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                .toSql()
                .WHERE("audio.id = #{id}")
                .toString()

@JvmStatic
            fun findOneBySlug(): String = SelectSQLBuilder(AudioEntity::class)
                .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                .leftOuterJoin(
                    ArtistEntity::class,
                    "album.artist_id = artist.id",
                    AlbumEntity::class
                )
                .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                .toSql()
                .WHERE("audio.slug = #{slug}")
                .toString()

@JvmStatic
            fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(
                        ArtistEntity::class,
                        "album.artist_id = artist.id",
                        AlbumEntity::class
                    )
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.album_id", "albumIds", albumIds.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByIdIn(@Param("ids") ids: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(
                        ArtistEntity::class,
                        "album.artist_id = artist.id",
                        AlbumEntity::class
                    )
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.id", "ids", ids.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllBySlugIn(@Param("slugs") slugs: List<String>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(
                        ArtistEntity::class,
                        "album.artist_id = artist.id",
                        AlbumEntity::class
                    )
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.slug", "slugs", slugs.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(
                        ArtistEntity::class,
                        "album.artist_id = artist.id",
                        AlbumEntity::class
                    )
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .leftOuterJoin(AudioTagEntity::class, "audio.id = audio_tag.audio_id")
                    .toSql()
                    .WHERE_IN("audio_tag.tag_id", "tagIds", tagIds.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByNameLikesLimit(
                @Param("nameLikes") nameLikes: List<String>,
                @Param("limit") limit: Long
            ): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(
                        ArtistEntity::class,
                        "album.artist_id = artist.id",
                        AlbumEntity::class
                    )
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_LIKES("audio.name", "nameLikes", nameLikes.size)
                    .OR()
                    .WHERE_LIKES("audio_name.name", "nameLikes", nameLikes.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .LIMIT("#{limit}")
                    .toString()

@JvmStatic
            fun updateOne(@Param("entity") entity: AudioEntity): String =
                DaoUtils.updateOne(entity)
        }
    }
}

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.*
import net.piedpiper.bremer.utils.DaoUtils
import net.piedpiper.bremer.utils.SelectSQLBuilder
import net.piedpiper.bremer.utils.WHERE_IN
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.AudioDao")
@Mapper
interface AudioDao {

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findOneById")
    fun findOneById(@Param("id") id: Long): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findOneBySlug")
    fun findOneBySlug(@Param("slug") slug: String): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @Select("SELECT * FROM audio WHERE slug = #{slug} FOR UPDATE")
    fun findOneBySlugWithLock(@Param("slug") slug: String): AudioEntity?

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByTagIdIn")
    fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByIdIn")
    fun findAllByIdIn(@Param("ids") ids: List<Long>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllBySlugIn")
    fun findAllBySlugIn(@Param("slugs") ids: List<String>): List<AudioEntity>

@ResultMap("net.piedpiper.bremer.AudioEntity")
    @SelectProvider(type = Sql::class, method = "findAllByNameLikeLimit")
    fun findAllByNameLikeLimit(
        @Param("nameLike") nameLike: String,
        @Param("limit") limit: Int
    ): List<AudioEntity>

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: AudioEntity)

class Sql {
        companion object {
            @JvmStatic
            fun findOneById(): String = SelectSQLBuilder(AudioEntity::class)
                .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                .toSql()
                .WHERE("audio.id = #{id}")
                .toString()

@JvmStatic
            fun findOneBySlug(): String = SelectSQLBuilder(AudioEntity::class)
                .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                .toSql()
                .WHERE("audio.slug = #{slug}")
                .toString()

@JvmStatic
            fun findAllByAlbumIdIn(@Param("albumIds") albumIds: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.album_id", "albumIds", albumIds.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByIdIn(@Param("ids") ids: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.id", "ids", ids.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllBySlugIn(@Param("slugs") slugs: List<String>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE_IN("audio.slug", "slugs", slugs.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByTagIdIn(@Param("tagIds") tagIds: List<Long>): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .leftOuterJoin(AudioTagEntity::class, "audio.id = audio_tag.audio_id")
                    .toSql()
                    .WHERE_IN("audio_tag.tag_id", "tagIds", tagIds.size)
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .toString()

@JvmStatic
            fun findAllByNameLikeLimit(
                @Param("nameLike") nameLike: String,
                @Param("limit") limit: Long
            ): String =
                SelectSQLBuilder(AudioEntity::class)
                    .leftOuterJoin(AlbumEntity::class, "audio.album_id = album.id")
                    .leftOuterJoin(ArtistEntity::class, "album.artist_id = artist.id", AlbumEntity::class)
                    .leftOuterJoin(AudioNameEntity::class, "audio.id = audio_name.audio_id")
                    .toSql()
                    .WHERE(
                        "audio.name LIKE CONCAT('%', #{nameLike}, '%') OR "
                                + "audio_name.name LIKE CONCAT('%', #{nameLike}, '%')"
                    )
                    .ORDER_BY("audio.album_id, audio.sequence")
                    .LIMIT("#{limit}")
                    .toString()

@JvmStatic
            fun updateOne(@Param("entity") entity: AudioEntity): String =
                DaoUtils.updateOne(entity)
        }
    }
}

Ignore Space Show notes View src/main/kotlin/dao/TagDao.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.ArtistEntity import net.piedpiper.bremer.entity.TagEntity import net.piedpiper.bremer.utils.DaoUtils import net.piedpiper.bremer.utils.SelectSQLBuilder import net.piedpiper.bremer.utils.WHERE_LIKES import org.apache.ibatis.annotations. import org.springframework.stereotype.Repository @Repository("bremer.dao.TagDao") @Mapper interface TagDao { @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag WHERE slug = #{slug}") fun findOneBySlug(@Param("slug") slug: String): TagEntity? @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag WHERE slug = #{slug} FOR UPDATE") fun findOneBySlugWithLock(@Param("slug") slug: String): TagEntity? @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag") fun findAll(): List<TagEntity> @ResultMap("net.piedpiper.bremer.TagEntity") @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit") fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, @Param("limit") limit: Int ): List<TagEntity> @InsertProvider(type = Sql::class, method = "insertOne") @Options(useGeneratedKeys = true, keyProperty = "id") fun insertOne(@Param("entity") entity: TagEntity): Boolean @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: TagEntity) @Delete("DELETE FROM tag WHERE id = #{id}") fun deleteById(@Param("id") id: Long): Boolean class Sql { companion object { @JvmStatic @Options(useGeneratedKeys = true, keyColumn = "id") fun insertOne(@Param("entity") entity: TagEntity): String = DaoUtils.insertOne(entity) @JvmStatic fun updateOne(@Param("entity") entity: TagEntity): String = DaoUtils.updateOne(entity) @JvmStatic fun findAllByNamesLikeLimit( @Param("namesLike") namesLike: List<String>, ): String = SelectSQLBuilder(TagEntity::class) .toSql() .WHERE_LIKES("name", "namesLike", namesLike.size) .LIMIT("#{limit}") .toString() } } } /* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.dao import net.piedpiper.bremer.entity.TagEntity import net.piedpiper.bremer.utils.DaoUtils import org.apache.ibatis.annotations. import org.springframework.stereotype.Repository @Repository("bremer.dao.TagDao") @Mapper interface TagDao { @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag WHERE slug = #{slug}") fun findOneBySlug(@Param("slug") slug: String): TagEntity? @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag WHERE slug = #{slug} FOR UPDATE") fun findOneBySlugWithLock(@Param("slug") slug: String): TagEntity? @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag") fun findAll(): List<TagEntity> @ResultMap("net.piedpiper.bremer.TagEntity") @Select("SELECT * FROM tag WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}") fun findAllByNameLikeLimit( @Param("nameLike") nameLike: String, @Param("limit") limit: Int ): List<TagEntity> @InsertProvider(type = Sql::class, method = "insertOne") @Options(useGeneratedKeys = true, keyProperty = "id") fun insertOne(@Param("entity") entity: TagEntity): Boolean @UpdateProvider(type = Sql::class, method = "updateOne") fun updateOne(@Param("entity") entity: TagEntity) @Delete("DELETE FROM tag WHERE id = #{id}") fun deleteById(@Param("id") id: Long): Boolean class Sql { companion object { @JvmStatic @Options(useGeneratedKeys = true, keyColumn = "id") fun insertOne(@Param("entity") entity: TagEntity): String = DaoUtils.insertOne(entity) @JvmStatic fun updateOne(@Param("entity") entity: TagEntity): String = DaoUtils.updateOne(entity) } } }

Ignore Space Show notes View

src/main/kotlin/dao/TagDao.kt

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.ArtistEntity
import net.piedpiper.bremer.entity.TagEntity
import net.piedpiper.bremer.utils.DaoUtils
import net.piedpiper.bremer.utils.SelectSQLBuilder
import net.piedpiper.bremer.utils.WHERE_LIKES
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.TagDao")
@Mapper
interface TagDao {

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag WHERE slug = #{slug}")
    fun findOneBySlug(@Param("slug") slug: String): TagEntity?

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag WHERE slug = #{slug} FOR UPDATE")
    fun findOneBySlugWithLock(@Param("slug") slug: String): TagEntity?

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag")
    fun findAll(): List<TagEntity>

@ResultMap("net.piedpiper.bremer.TagEntity")
    @SelectProvider(type = Sql::class, method = "findAllByNamesLikeLimit")
    fun findAllByNamesLikeLimit(
        @Param("namesLike") namesLike: List<String>,
        @Param("limit") limit: Int
    ): List<TagEntity>

@InsertProvider(type = Sql::class, method = "insertOne")
    @Options(useGeneratedKeys = true, keyProperty = "id")
    fun insertOne(@Param("entity") entity: TagEntity): Boolean

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: TagEntity)

@Delete("DELETE FROM tag WHERE id = #{id}")
    fun deleteById(@Param("id") id: Long): Boolean

class Sql {
        companion object {
            @JvmStatic
            @Options(useGeneratedKeys = true, keyColumn = "id")
            fun insertOne(@Param("entity") entity: TagEntity): String =
                DaoUtils.insertOne(entity)

@JvmStatic
            fun updateOne(@Param("entity") entity: TagEntity): String =
                DaoUtils.updateOne(entity)

@JvmStatic
            fun findAllByNamesLikeLimit(
                @Param("namesLike") namesLike: List<String>,
            ): String = SelectSQLBuilder(TagEntity::class)
                .toSql()
                .WHERE_LIKES("name", "namesLike", namesLike.size)
                .LIMIT("#{limit}")
                .toString()
        }
    }
}

/*
 * Copyright (c) 2023. yo-saito. All Rights Reserved.
 */

package net.piedpiper.bremer.dao

import net.piedpiper.bremer.entity.TagEntity
import net.piedpiper.bremer.utils.DaoUtils
import org.apache.ibatis.annotations.*
import org.springframework.stereotype.Repository

@Repository("bremer.dao.TagDao")
@Mapper
interface TagDao {

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag WHERE slug = #{slug}")
    fun findOneBySlug(@Param("slug") slug: String): TagEntity?

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag WHERE slug = #{slug} FOR UPDATE")
    fun findOneBySlugWithLock(@Param("slug") slug: String): TagEntity?

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag")
    fun findAll(): List<TagEntity>

@ResultMap("net.piedpiper.bremer.TagEntity")
    @Select("SELECT * FROM tag WHERE name LIKE CONCAT('%', #{nameLike}, '%') LIMIT #{limit}")
    fun findAllByNameLikeLimit(
        @Param("nameLike") nameLike: String,
        @Param("limit") limit: Int
    ): List<TagEntity>

@InsertProvider(type = Sql::class, method = "insertOne")
    @Options(useGeneratedKeys = true, keyProperty = "id")
    fun insertOne(@Param("entity") entity: TagEntity): Boolean

@UpdateProvider(type = Sql::class, method = "updateOne")
    fun updateOne(@Param("entity") entity: TagEntity)

@Delete("DELETE FROM tag WHERE id = #{id}")
    fun deleteById(@Param("id") id: Long): Boolean

@JvmStatic
            fun updateOne(@Param("entity") entity: TagEntity): String =
                DaoUtils.updateOne(entity)
        }
    }
}

Ignore Space Show notes View src/main/kotlin/service/AudioService.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.service import net.piedpiper.bremer.dao. import net.piedpiper.bremer.entity.AudioEntity import net.piedpiper.bremer.entity.AudioPlayHistoryEntity import net.piedpiper.bremer.exception.NotFoundException import net.piedpiper.bremer.model.api.AudioListResponse import net.piedpiper.bremer.model.api.AudioRequest import org.springframework.beans.factory.annotation.Qualifier import org.springframework.stereotype.Service import org.springframework.transaction.annotation.Transactional import java.io.File import java.time.LocalDateTime import java.time.ZoneId @Service("bremer.service.AudioService") class AudioService( @Qualifier("bremer.dao.AudioDao") private val audioDao: AudioDao, @Qualifier("bremer.dao.ArtistDao") private val artistDao: ArtistDao, @Qualifier("bremer.dao.AlbumDao") private val albumDao: AlbumDao, @Qualifier("bremer.dao.AudioPlayHistoryDao") private val audioPlayHistoryDao: AudioPlayHistoryDao, @Qualifier("bremer.dao.TagDao") private val tagDao: TagDao ) { /** 音楽ファイル取得 / @Transactional fun getAudioFile(slug: String): File { val audio = audioDao.findOneBySlug(slug) ?: throw NotFoundException() val file = File(audio.path) if (!file.exists()) { throw NotFoundException() } return file } /* キーワード検索 / @Transactional fun getByKeywords( audioNamesLike: List<String>?, artistNamesLike: List<String>?, albumNamesLike: List<String>?, tagNamesLike: List<String>?, pageSize: Int ): AudioListResponse { val set = mutableSetOf<AudioEntity>() if (audioNamesLike?.isNotEmpty() == true) { set.addAll(audioDao.findAllByNameLikesLimit(audioNamesLike, pageSize)) } if (artistNamesLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByArtistNamesLikesLimit(artistNamesLike, pageSize)) } if (albumNamesLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByAlbumNamesLikeLimit(albumNamesLike, pageSize)) } if (tagNamesLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByTagNamesLikeLimit(tagNamesLike, pageSize)) } return AudioListResponse( set.sortedWith(compareBy({ it.albumId }, { it.sequence })) .take(pageSize) .toList() ) } /* 最近再生した曲一覧を取得 / @Transactional fun getLeastRecentlyAccessedAudio(pageSize: Int): AudioListResponse { val historyMap = audioPlayHistoryDao.findAllOrderLastPlayedAtDescLimit(pageSize) .associateBy { it.audioId } return if (historyMap.isNotEmpty()) audioDao.findAllByIdIn(historyMap.keys.map { it }) .sortedByDescending { historyMap[it.id]?.lastPlayedAt ?: LocalDateTime.MIN }.let { AudioListResponse(it) } else AudioListResponse() } @Transactional fun update(slug: String, request: AudioRequest) = audioDao.findOneBySlugWithLock(slug) ?.let { request.name?.apply { it.name = request.name audioDao.updateOne(it) } albumDao.findOneByIdWithLock(it.albumId)?.let { album -> request.album?.apply { album.name = request.album albumDao.updateOne(album) } request.artist?.apply { artistDao.findOneByIdWithLock(album.artistId)?.let { artist -> artist.name = request.artist artistDao.updateOne(artist) } } } } ?: throw NotFoundException() fun updateHistory(slug: String) { audioDao.findOneBySlug(slug)?.let { audioPlayHistoryDao.insertOrUpdateOne( AudioPlayHistoryEntity( audioId = it.id, lastPlayedAt = LocalDateTime.now(ZoneId.of("Asia/Tokyo")) ) ) } } private fun findAllByArtistNamesLikesLimit( artistNameLikes: List<String>, limit: Int ): List<AudioEntity> { val artists = artistDao.findAllByNamesLikeLimit(artistNameLikes, limit) if (artists.isEmpty()) { return emptyList() } val albums = albumDao.findAllByArtistIdInLimit(artists.map { it.id }.distinct(), limit) if (albums.isEmpty()) { return emptyList() } return audioDao.findAllByAlbumIdIn(albums.map { it.id }.distinct()) } private fun findAllByAlbumNamesLikeLimit(albumNamesLike: List<String>, limit: Int): List<AudioEntity> { val albums = albumDao.findAllByNamesLikeLimit(albumNamesLike, limit) return if (albums.isNotEmpty()) audioDao .findAllByAlbumIdIn(albums.map { it.id }) else emptyList() } private fun findAllByTagNamesLikeLimit(tagNamesLike: List<String>, limit: Int): List<AudioEntity> { val tags = tagDao.findAllByNamesLikeLimit(tagNamesLike, limit) return if (tags.isNotEmpty()) audioDao.findAllByTagIdIn(tags.map { it.id }) else emptyList() } } / * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.service import net.piedpiper.bremer.dao. import net.piedpiper.bremer.entity.AudioEntity import net.piedpiper.bremer.entity.AudioPlayHistoryEntity import net.piedpiper.bremer.exception.NotFoundException import net.piedpiper.bremer.model.api.AudioListResponse import net.piedpiper.bremer.model.api.AudioRequest import org.springframework.beans.factory.annotation.Qualifier import org.springframework.stereotype.Service import org.springframework.transaction.annotation.Transactional import java.io.File import java.time.LocalDateTime import java.time.ZoneId @Service("bremer.service.AudioService") class AudioService( @Qualifier("bremer.dao.AudioDao") private val audioDao: AudioDao, @Qualifier("bremer.dao.ArtistDao") private val artistDao: ArtistDao, @Qualifier("bremer.dao.AlbumDao") private val albumDao: AlbumDao, @Qualifier("bremer.dao.AudioPlayHistoryDao") private val audioPlayHistoryDao: AudioPlayHistoryDao, @Qualifier("bremer.dao.TagDao") private val tagDao: TagDao ) { /** 音楽ファイル取得 / @Transactional fun getAudioFile(slug: String): File { val audio = audioDao.findOneBySlug(slug) ?: throw NotFoundException() val file = File(audio.path) if (!file.exists()) { throw NotFoundException() } return file } /* キーワード検索 / @Transactional fun getByKeywords( audioNameLike: String?, artistNameLike: String?, albumNameLike: String?, tagNameLike: String?, pageSize: Int ): AudioListResponse { val set = mutableSetOf<AudioEntity>() if (audioNameLike?.isNotEmpty() == true) { set.addAll(audioDao.findAllByNameLikeLimit(audioNameLike, pageSize)) } if (artistNameLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByArtistNameLikeLimit(artistNameLike, pageSize)) } if (albumNameLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByAlbumNameLikeLimit(albumNameLike, pageSize)) } if (tagNameLike?.isNotEmpty() == true && set.size <= pageSize) { set.addAll(findAllByTagNameLikeLimit(tagNameLike, pageSize)) } return AudioListResponse( set.sortedWith(compareBy({ it.albumId }, { it.sequence })) .take(pageSize) .toList() ) } /* 最近再生した曲一覧を取得 */ @Transactional fun getLeastRecentlyAccessedAudio(pageSize: Int): AudioListResponse { val historyMap = audioPlayHistoryDao.findAllOrderLastPlayedAtDescLimit(pageSize) .associateBy { it.audioId } return if (historyMap.isNotEmpty()) audioDao.findAllByIdIn(historyMap.keys.map { it }) .sortedByDescending { historyMap[it.id]?.lastPlayedAt ?: LocalDateTime.MIN }.let { AudioListResponse(it) } else AudioListResponse() } @Transactional fun update(slug: String, request: AudioRequest) = audioDao.findOneBySlugWithLock(slug) ?.let { request.name?.apply { it.name = request.name audioDao.updateOne(it) } albumDao.findOneByIdWithLock(it.albumId)?.let { album -> request.album?.apply { album.name = request.album albumDao.updateOne(album) } request.artist?.apply { artistDao.findOneByIdWithLock(album.artistId)?.let { artist -> artist.name = request.artist artistDao.updateOne(artist) } } } } ?: throw NotFoundException() fun updateHistory(slug: String) { audioDao.findOneBySlug(slug)?.let { audioPlayHistoryDao.insertOrUpdateOne( AudioPlayHistoryEntity( audioId = it.id, lastPlayedAt = LocalDateTime.now(ZoneId.of("Asia/Tokyo")) ) ) } } private fun findAllByArtistNameLikeLimit( artistNameLike: String, limit: Int ): List<AudioEntity> { val artists = artistDao.findAllByNameLikeLimit(artistNameLike, limit) if (artists.isEmpty()) { return emptyList() } val albums = albumDao.findAllByArtistIdInLimit(artists.map { it.id }.distinct(), limit) if (albums.isEmpty()) { return emptyList() } return audioDao.findAllByAlbumIdIn(albums.map { it.id }.distinct()) } private fun findAllByAlbumNameLikeLimit(albumNameLike: String, limit: Int): List<AudioEntity> { val albums = albumDao.findAllByNameLikeLimit(albumNameLike, limit) return if (albums.isNotEmpty()) audioDao .findAllByAlbumIdIn(albums.map { it.id }) else emptyList() } private fun findAllByTagNameLikeLimit(tagNameLike: String, limit: Int): List<AudioEntity> { val tags = tagDao.findAllByNameLikeLimit(tagNameLike, limit) return if (tags.isNotEmpty()) audioDao.findAllByTagIdIn(tags.map { it.id }) else emptyList() } }

Ignore Space Show notes View

src/main/kotlin/service/AudioService.kt

package net.piedpiper.bremer.service

import net.piedpiper.bremer.dao.*
import net.piedpiper.bremer.entity.AudioEntity
import net.piedpiper.bremer.entity.AudioPlayHistoryEntity
import net.piedpiper.bremer.exception.NotFoundException
import net.piedpiper.bremer.model.api.AudioListResponse
import net.piedpiper.bremer.model.api.AudioRequest
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Transactional
import java.io.File
import java.time.LocalDateTime
import java.time.ZoneId

@Service("bremer.service.AudioService")
class AudioService(
    @Qualifier("bremer.dao.AudioDao")
    private val audioDao: AudioDao,
    @Qualifier("bremer.dao.ArtistDao")
    private val artistDao: ArtistDao,
    @Qualifier("bremer.dao.AlbumDao")
    private val albumDao: AlbumDao,
    @Qualifier("bremer.dao.AudioPlayHistoryDao")
    private val audioPlayHistoryDao: AudioPlayHistoryDao,
    @Qualifier("bremer.dao.TagDao")
    private val tagDao: TagDao
) {

/** 音楽ファイル取得 */
    @Transactional
    fun getAudioFile(slug: String): File {
        val audio = audioDao.findOneBySlug(slug) ?: throw NotFoundException()
        val file = File(audio.path)
        if (!file.exists()) {
            throw NotFoundException()
        }
        return file
    }

/** キーワード検索 */
    @Transactional
    fun getByKeywords(
        audioNamesLike: List<String>?,
        artistNamesLike: List<String>?,
        albumNamesLike: List<String>?,
        tagNamesLike: List<String>?,
        pageSize: Int
    ): AudioListResponse {
        val set = mutableSetOf<AudioEntity>()
        if (audioNamesLike?.isNotEmpty() == true) {
            set.addAll(audioDao.findAllByNameLikesLimit(audioNamesLike, pageSize))
        }
        if (artistNamesLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByArtistNamesLikesLimit(artistNamesLike, pageSize))
        }
        if (albumNamesLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByAlbumNamesLikeLimit(albumNamesLike, pageSize))
        }
        if (tagNamesLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByTagNamesLikeLimit(tagNamesLike, pageSize))
        }
        return AudioListResponse(
            set.sortedWith(compareBy({ it.albumId }, { it.sequence }))
                .take(pageSize)
                .toList()
        )
    }

/** 最近再生した曲一覧を取得 */
    @Transactional
    fun getLeastRecentlyAccessedAudio(pageSize: Int): AudioListResponse {
        val historyMap = audioPlayHistoryDao.findAllOrderLastPlayedAtDescLimit(pageSize)
            .associateBy { it.audioId }
        return if (historyMap.isNotEmpty())
            audioDao.findAllByIdIn(historyMap.keys.map { it })
                .sortedByDescending {
                    historyMap[it.id]?.lastPlayedAt ?: LocalDateTime.MIN
                }.let {
                    AudioListResponse(it)
                }
        else AudioListResponse()
    }

@Transactional
    fun update(slug: String, request: AudioRequest) = audioDao.findOneBySlugWithLock(slug)
        ?.let {
            request.name?.apply {
                it.name = request.name
                audioDao.updateOne(it)
            }
            albumDao.findOneByIdWithLock(it.albumId)?.let { album ->
                request.album?.apply {
                    album.name = request.album
                    albumDao.updateOne(album)
                }
                request.artist?.apply {
                    artistDao.findOneByIdWithLock(album.artistId)?.let { artist ->
                        artist.name = request.artist
                        artistDao.updateOne(artist)
                    }
                }
            }
        } ?: throw NotFoundException()

fun updateHistory(slug: String) {
        audioDao.findOneBySlug(slug)?.let {
            audioPlayHistoryDao.insertOrUpdateOne(
                AudioPlayHistoryEntity(
                    audioId = it.id,
                    lastPlayedAt = LocalDateTime.now(ZoneId.of("Asia/Tokyo"))
                )
            )
        }
    }

private fun findAllByArtistNamesLikesLimit(
        artistNameLikes: List<String>,
        limit: Int
    ): List<AudioEntity> {
        val artists = artistDao.findAllByNamesLikeLimit(artistNameLikes, limit)
        if (artists.isEmpty()) {
            return emptyList()
        }
        val albums = albumDao.findAllByArtistIdInLimit(artists.map { it.id }.distinct(), limit)
        if (albums.isEmpty()) {
            return emptyList()
        }
        return audioDao.findAllByAlbumIdIn(albums.map { it.id }.distinct())
    }

private fun findAllByAlbumNamesLikeLimit(albumNamesLike: List<String>, limit: Int): List<AudioEntity> {
        val albums = albumDao.findAllByNamesLikeLimit(albumNamesLike, limit)
        return if (albums.isNotEmpty()) audioDao
            .findAllByAlbumIdIn(albums.map { it.id }) else emptyList()
    }

private fun findAllByTagNamesLikeLimit(tagNamesLike: List<String>, limit: Int): List<AudioEntity> {
        val tags = tagDao.findAllByNamesLikeLimit(tagNamesLike, limit)
        return if (tags.isNotEmpty()) audioDao.findAllByTagIdIn(tags.map { it.id }) else emptyList()
    }
}

package net.piedpiper.bremer.service

/** キーワード検索 */
    @Transactional
    fun getByKeywords(
        audioNameLike: String?,
        artistNameLike: String?,
        albumNameLike: String?,
        tagNameLike: String?,
        pageSize: Int
    ): AudioListResponse {
        val set = mutableSetOf<AudioEntity>()
        if (audioNameLike?.isNotEmpty() == true) {
            set.addAll(audioDao.findAllByNameLikeLimit(audioNameLike, pageSize))
        }
        if (artistNameLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByArtistNameLikeLimit(artistNameLike, pageSize))
        }
        if (albumNameLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByAlbumNameLikeLimit(albumNameLike, pageSize))
        }
        if (tagNameLike?.isNotEmpty() == true && set.size <= pageSize) {
            set.addAll(findAllByTagNameLikeLimit(tagNameLike, pageSize))
        }
        return AudioListResponse(
            set.sortedWith(compareBy({ it.albumId }, { it.sequence }))
                .take(pageSize)
                .toList()
        )
    }

private fun findAllByArtistNameLikeLimit(
        artistNameLike: String,
        limit: Int
    ): List<AudioEntity> {
        val artists = artistDao.findAllByNameLikeLimit(artistNameLike, limit)
        if (artists.isEmpty()) {
            return emptyList()
        }
        val albums = albumDao.findAllByArtistIdInLimit(artists.map { it.id }.distinct(), limit)
        if (albums.isEmpty()) {
            return emptyList()
        }
        return audioDao.findAllByAlbumIdIn(albums.map { it.id }.distinct())
    }

private fun findAllByAlbumNameLikeLimit(albumNameLike: String, limit: Int): List<AudioEntity> {
        val albums = albumDao.findAllByNameLikeLimit(albumNameLike, limit)
        return if (albums.isNotEmpty()) audioDao
            .findAllByAlbumIdIn(albums.map { it.id }) else emptyList()
    }

private fun findAllByTagNameLikeLimit(tagNameLike: String, limit: Int): List<AudioEntity> {
        val tags = tagDao.findAllByNameLikeLimit(tagNameLike, limit)
        return if (tags.isNotEmpty()) audioDao.findAllByTagIdIn(tags.map { it.id }) else emptyList()
    }
}

Ignore Space Show notes View src/main/kotlin/utils/SqlUtils.kt
/* * Copyright (c) 2023. yo-saito. All Rights Reserved. / package net.piedpiper.bremer.utils import net.piedpiper.bremer.utils.sql.Column import net.piedpiper.bremer.utils.sql.Table import org.apache.ibatis.jdbc.SQL import java.time.LocalDateTime import kotlin.reflect.KClass import kotlin.reflect.full.findAnnotation import kotlin.reflect.full.memberProperties import kotlin.reflect.javaType class SelectSQLBuilder<T : Any>(tableClass: KClass<T>) { private val tableName: String = tableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() private val joinTableMap : MutableMap<String, String> = mutableMapOf() private val sql: SQL = SQL().FROM(tableName) private var columns: String = tableClass.memberProperties .mapNotNull { it.findAnnotation<Column>()?.name } .joinToString(separator = ",") { "${tableName}.${it} AS ${it}" } fun <U : Any> leftOuterJoin( tableClass: KClass<U>, cond: String, ): SelectSQLBuilder<T> { return leftOuterJoin(tableClass, cond, Unit::class); } fun <U : Any, V : Any> leftOuterJoin( tableClass: KClass<U>, cond: String, parentTableClass: KClass<V> ): SelectSQLBuilder<T> { val joinTableName = tableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() val col : String if (parentTableClass == Unit::class) { col = joinTableName } else { val joinParentTableName = parentTableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() if (joinTableMap.containsKey(joinParentTableName)) { col = "${joinTableMap[joinParentTableName]}__${joinTableName}" joinTableMap.put(joinTableName, col) } else { throw IllegalArgumentException() } } joinTableMap.put(joinTableName, col) columns += "," + tableClass.memberProperties.mapNotNull { it.findAnnotation<Column>()?.name } .joinToString(separator = ",") { "${joinTableName}.${it} AS ${col}__${it}" } sql.LEFT_OUTER_JOIN("${joinTableName} ON ${cond}") return this } fun toSql(): SQL { return sql.SELECT(columns) } } object DaoUtils { @OptIn(ExperimentalStdlibApi::class) @JvmStatic fun <T : Any> insertOne(entity: T): String { val properties = entity::class.memberProperties .filter { it.findAnnotation<Column>()?.let { it.insertable } ?: false } .filter { it.getter.call(entity) != null } val sql = SQL().INSERT_INTO( entity::class.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ); val columns = properties.map { it.findAnnotation<Column>()?.name } val values = properties.map { if (it.returnType.javaType == LocalDateTime::class.java) "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}" else "#{entity.${it?.name}}" } repeat(columns.size) { sql.VALUES(columns[it], values[it]) } return sql.toString() } @OptIn(ExperimentalStdlibApi::class) @JvmStatic fun <T : Any> updateOne(entity: T): String { val properties = entity::class.memberProperties .filter { val column = it.findAnnotation<Column>() column != null && column.insertable } .filter { it.getter.call(entity) != null } val sql = SQL().UPDATE( entity::class.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ); properties.forEach { val v = if (it.returnType.javaType == LocalDateTime::class.java) "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}" else "#{entity.${it?.name}}" sql.SET("${it.findAnnotation<Column>()?.name} = ${v}") } return sql.WHERE("id = #{entity.id}").toString() } @JvmStatic fun <T : Any> deleteQuery( clazz: KClass<T>, ): SQL = SQL().DELETE_FROM( clazz.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ) @JvmStatic private fun <T : Any> deleteFrom( clazz: KClass<T>, ): SQL = SQL().DELETE_FROM( clazz.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ) } fun SQL.WHERE_IN( targetColumn: String, parameterName: String, num: Int, ): SQL { if (num == 0) { throw IllegalArgumentException() } generateSequence(0) { v -> v + 1 }.take(num).map { "#{${parameterName}[${it}]}" }.joinToString(",", "(", ")").let { WHERE("${targetColumn} IN ${it}") } return this } fun SQL.WHERE_LIKES( targetColumn: String, parameterName: String, num: Int, ): SQL { if (num == 0) { throw IllegalArgumentException() } generateSequence(0) { v -> v + 1 }.take(num).map { "${targetColumn} LIKE CONCAT('%', #{${parameterName}[${it}]}, '%')" }.joinToString(" AND ").let { WHERE("${it}") } return this } / * Copyright (c) 2023. yo-saito. All Rights Reserved. */ package net.piedpiper.bremer.utils import net.piedpiper.bremer.utils.sql.Column import net.piedpiper.bremer.utils.sql.Table import org.apache.ibatis.jdbc.SQL import java.time.LocalDateTime import kotlin.reflect.KClass import kotlin.reflect.full.findAnnotation import kotlin.reflect.full.memberProperties import kotlin.reflect.javaType class SelectSQLBuilder<T : Any>(tableClass: KClass<T>) { private val tableName: String = tableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() private val joinTableMap : MutableMap<String, String> = mutableMapOf() private val sql: SQL = SQL().FROM(tableName) private var columns: String = tableClass.memberProperties .mapNotNull { it.findAnnotation<Column>()?.name } .joinToString(separator = ",") { "${tableName}.${it} AS ${it}" } fun <U : Any> leftOuterJoin( tableClass: KClass<U>, cond: String, ): SelectSQLBuilder<T> { return leftOuterJoin(tableClass, cond, Unit::class); } fun <U : Any, V : Any> leftOuterJoin( tableClass: KClass<U>, cond: String, parentTableClass: KClass<V> ): SelectSQLBuilder<T> { val joinTableName = tableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() val col : String if (parentTableClass == Unit::class) { col = joinTableName } else { val joinParentTableName = parentTableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException() if (joinTableMap.containsKey(joinParentTableName)) { col = "${joinTableMap[joinParentTableName]}__${joinTableName}" joinTableMap.put(joinTableName, col) } else { throw IllegalArgumentException() } } joinTableMap.put(joinTableName, col) columns += "," + tableClass.memberProperties.mapNotNull { it.findAnnotation<Column>()?.name } .joinToString(separator = ",") { "${joinTableName}.${it} AS ${col}__${it}" } sql.LEFT_OUTER_JOIN("${joinTableName} ON ${cond}") return this } fun toSql(): SQL { return sql.SELECT(columns) } } object DaoUtils { @OptIn(ExperimentalStdlibApi::class) @JvmStatic fun <T : Any> insertOne(entity: T): String { val properties = entity::class.memberProperties .filter { it.findAnnotation<Column>()?.let { it.insertable } ?: false } .filter { it.getter.call(entity) != null } val sql = SQL().INSERT_INTO( entity::class.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ); val columns = properties.map { it.findAnnotation<Column>()?.name } val values = properties.map { if (it.returnType.javaType == LocalDateTime::class.java) "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}" else "#{entity.${it?.name}}" } repeat(columns.size) { sql.VALUES(columns[it], values[it]) } return sql.toString() } @OptIn(ExperimentalStdlibApi::class) @JvmStatic fun <T : Any> updateOne(entity: T): String { val properties = entity::class.memberProperties .filter { val column = it.findAnnotation<Column>() column != null && column.insertable } .filter { it.getter.call(entity) != null } val sql = SQL().UPDATE( entity::class.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ); properties.forEach { val v = if (it.returnType.javaType == LocalDateTime::class.java) "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}" else "#{entity.${it?.name}}" sql.SET("${it.findAnnotation<Column>()?.name} = ${v}") } return sql.WHERE("id = #{entity.id}").toString() } @JvmStatic fun <T : Any> deleteQuery( clazz: KClass<T>, ): SQL = SQL().DELETE_FROM( clazz.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ) @JvmStatic private fun <T : Any> deleteFrom( clazz: KClass<T>, ): SQL = SQL().DELETE_FROM( clazz.findAnnotation<Table>()?.name ?: throw java.lang.IllegalArgumentException() ) } fun SQL.WHERE_IN( targetColumn: String, parameterName: String, num: Int, ): SQL { if (num == 0) { throw IllegalArgumentException() } generateSequence(0) { v -> v + 1 }.take(num).map { "#{${parameterName}[${it}]}" }.joinToString(",", "(", ")").let { WHERE("${targetColumn} IN ${it}") } return this }

Ignore Space Show notes View

src/main/kotlin/utils/SqlUtils.kt

package net.piedpiper.bremer.utils

import net.piedpiper.bremer.utils.sql.Column
import net.piedpiper.bremer.utils.sql.Table
import org.apache.ibatis.jdbc.SQL
import java.time.LocalDateTime
import kotlin.reflect.KClass
import kotlin.reflect.full.findAnnotation
import kotlin.reflect.full.memberProperties
import kotlin.reflect.javaType

class SelectSQLBuilder<T : Any>(tableClass: KClass<T>) {
    private val tableName: String =
        tableClass.findAnnotation<Table>()?.name ?: throw IllegalArgumentException()
    private val joinTableMap : MutableMap<String, String> = mutableMapOf()
    private val sql: SQL = SQL().FROM(tableName)
    private var columns: String =
        tableClass.memberProperties
            .mapNotNull { it.findAnnotation<Column>()?.name }
            .joinToString(separator = ",") { "${tableName}.${it} AS ${it}" }

fun <U : Any> leftOuterJoin(
        tableClass: KClass<U>,
        cond: String,
    ): SelectSQLBuilder<T> {
        return leftOuterJoin(tableClass, cond, Unit::class);
    }

fun <U : Any, V : Any> leftOuterJoin(
        tableClass: KClass<U>,
        cond: String,
        parentTableClass: KClass<V>
    ): SelectSQLBuilder<T> {
        val joinTableName = tableClass.findAnnotation<Table>()?.name
            ?: throw IllegalArgumentException()
        val col : String
        if (parentTableClass == Unit::class) {
            col = joinTableName
        } else {
            val joinParentTableName = parentTableClass.findAnnotation<Table>()?.name
                ?: throw IllegalArgumentException()
            if (joinTableMap.containsKey(joinParentTableName)) {
                col = "${joinTableMap[joinParentTableName]}__${joinTableName}"
                joinTableMap.put(joinTableName, col)
            } else {
                throw IllegalArgumentException()
            }
        }
        joinTableMap.put(joinTableName, col)
        columns += "," + tableClass.memberProperties.mapNotNull { it.findAnnotation<Column>()?.name }
            .joinToString(separator = ",") { "${joinTableName}.${it} AS ${col}__${it}" }
        sql.LEFT_OUTER_JOIN("${joinTableName} ON ${cond}")
        return this
    }

fun toSql(): SQL {
        return sql.SELECT(columns)
    }
}

object DaoUtils {
    @OptIn(ExperimentalStdlibApi::class)
    @JvmStatic
    fun <T : Any> insertOne(entity: T): String {
        val properties = entity::class.memberProperties
            .filter {
                it.findAnnotation<Column>()?.let { it.insertable } ?: false
            }
            .filter { it.getter.call(entity) != null }
        val sql =
            SQL().INSERT_INTO(
                entity::class.findAnnotation<Table>()?.name
                    ?: throw java.lang.IllegalArgumentException()
            );
        val columns = properties.map { it.findAnnotation<Column>()?.name }
        val values = properties.map {
            if (it.returnType.javaType == LocalDateTime::class.java)
                "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}"
            else
                "#{entity.${it?.name}}"
        }
        repeat(columns.size) {
            sql.VALUES(columns[it], values[it])
        }
        return sql.toString()
    }

@OptIn(ExperimentalStdlibApi::class)
    @JvmStatic
    fun <T : Any> updateOne(entity: T): String {
        val properties = entity::class.memberProperties
            .filter {
                val column = it.findAnnotation<Column>()
                column != null && column.insertable
            }
            .filter { it.getter.call(entity) != null }
        val sql =
            SQL().UPDATE(
                entity::class.findAnnotation<Table>()?.name
                    ?: throw java.lang.IllegalArgumentException()
            );
        properties.forEach {
            val v = if (it.returnType.javaType == LocalDateTime::class.java)
                "#{entity.${it?.name}, typeHandler=net.piedpiper.bremer.dao.handler.LocalDateTimeTypeHandler}"
            else
                "#{entity.${it?.name}}"
            sql.SET("${it.findAnnotation<Column>()?.name} = ${v}")
        }
        return sql.WHERE("id = #{entity.id}").toString()
    }

@JvmStatic
    fun <T : Any> deleteQuery(
        clazz: KClass<T>,
    ): SQL = SQL().DELETE_FROM(
        clazz.findAnnotation<Table>()?.name
            ?: throw java.lang.IllegalArgumentException()
    )

@JvmStatic
    private fun <T : Any> deleteFrom(
        clazz: KClass<T>,
    ): SQL = SQL().DELETE_FROM(
        clazz.findAnnotation<Table>()?.name
            ?: throw java.lang.IllegalArgumentException()
    )
}

fun SQL.WHERE_IN(
    targetColumn: String,
    parameterName: String,
    num: Int,
): SQL {
    if (num == 0) {
        throw IllegalArgumentException()
    }
    generateSequence(0) { v -> v + 1 }.take(num).map {
        "#{${parameterName}[${it}]}"
    }.joinToString(",", "(", ")").let {
        WHERE("${targetColumn} IN ${it}")
    }
    return this
}

fun SQL.WHERE_LIKES(
    targetColumn: String,
    parameterName: String,
    num: Int,
): SQL {
    if (num == 0) {
        throw IllegalArgumentException()
    }
    generateSequence(0) { v -> v + 1 }.take(num).map {
        "${targetColumn} LIKE CONCAT('%', #{${parameterName}[${it}]}, '%')"
    }.joinToString(" AND ").let {
        WHERE("${it}")
    }
    return this
}

package net.piedpiper.bremer.utils

fun <U : Any> leftOuterJoin(
        tableClass: KClass<U>,
        cond: String,
    ): SelectSQLBuilder<T> {
        return leftOuterJoin(tableClass, cond, Unit::class);
    }

fun toSql(): SQL {
        return sql.SELECT(columns)
    }
}

Show line notes below