Spring Data and R2DBC by Example

plugins {

    id 'org.springframework.boot' version '2.4.4'

    id 'io.spring.dependency-management' version '1.0.11.RELEASE'

    id 'java'

    id 'scala'

}

group 'org.mazp.admin'

version '1.0-SNAPSHOT'

repositories {

    mavenCentral()

    maven { url 'https://repo.spring.io/milestone' }

    maven { url 'https://repo.spring.io/snapshot' }

}

dependencies {

    testImplementation 'org.junit.jupiter:junit-jupiter-api:5.7.0'

    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.7.0'

    implementation 'org.scala-lang:scala-library:2.12.6'

    testImplementation 'org.scalatest:scalatest_2.12:3.2.3'

    testImplementation 'org.scala-lang:scala-library:2.12.6'

    implementation 'org.springframework.boot:spring-boot-starter-webflux'

    implementation 'org.springframework.boot:spring-boot-starter-data-r2dbc'

    implementation  'dev.miku:r2dbc-mysql'

    implementation  'mysql:mysql-connector-java'

}

test { useJUnitPlatform() }

sourceSets {

    main { scala { srcDirs = ['src/main/scala'] } }

    test { scala { srcDirs = ['src/test/scala'] } }

}

springBoot {

    mainClass = 'com.mazp.admin.Main'

}

spring.r2dbc.url=r2dbc:mysql://localhost:3306/admin_r2dbc

spring.r2dbc.username=user_mysql

spring.r2dbc.password=password_user_mysql

package com.mazp.admin.model

import org.springframework.data.annotation.Id

import org.springframework.data.relational.core.mapping.Table

@Table("admin")

class AdminObject {

  @Id private var idAdmin:Integer = null

  private var adminCode:String = null

  private var description:String = null

  def getDescription() = description

  def setDescription(usr:String) = this.description = usr

  def getAdminCode() = adminCode

  def setAdminCode(ctId:String) = adminCode = ctId

  def getIdAdmin() = idAdmin

  def setIdAdmin(ctId:Integer) = idAdmin = ctId

}

package com.mazp.admin.respository

import com.mazp.admin.model.AdminObject

import org.springframework.data.repository.reactive.ReactiveCrudRepository

import reactor.core.publisher.Flux

trait AdminRepository extends ReactiveCrudRepository[AdminObject, Integer ]{

  /**

   * This method uses the convention name 

   * @param adminCode

   * @return

   */

  def findByAdminCode(adminCode:String):Flux[AdminObject]

}

package com.mazp.admin.service

import com.mazp.admin.respository.AdminRepository

import org.springframework.beans.factory.annotation.Autowired

import org.springframework.stereotype.Service

@Service

class AdminService (@Autowired val adminRepository: AdminRepository) {

  def getAdmin(adminCode:String)  =

    adminRepository.findByAdminCode(adminCode)

}

package com.mazp.admin.controller

import com.mazp.admin.service.AdminService

import org.springframework.beans.factory.annotation.Autowired

import org.springframework.web.bind.annotation.{GetMapping, PathVariable, RequestMapping, RestControllerAdvice}

@RestControllerAdvice

@RequestMapping(Array("/admin"))

class AdminController(@Autowired val adminService: AdminService) {

  @GetMapping(Array("/{adminCode}"))

  def route(@PathVariable adminCode: String) = {

    adminService.getAdmin(adminCode)

  }

}

package com.mazp.admin

import org.springframework.boot.SpringApplication

import org.springframework.boot.autoconfigure.{SpringBootApplication}

@SpringBootApplication

class Main

object Main extends App{

  SpringApplication.run(classOf[Main], args:_*)

}