Note/SpringBoot-Scala at master · abcdtianzi/Note

Name	Name	Last commit message	Last commit date
parent directory ..
image	image
README.md	README.md

SpringBoot Scala

可以说近几年Spark的流行带动了Scala的发展，它集成了面向对象编程和函数式编程的各种特性，Scala具有更纯Lambda表粹的函数式业务逻辑解决方案，其语法比Java8后Lambda更加简洁方便，SpringBoot为spring提供了一种更加方便快捷的方式，不再要求写大量的配置文件，作为一名Scala爱好者，使用SpringBoot结合Scala将大大节省我们开发的时间以及代码量,让程序员可以花更多的时间关注业务逻辑。项目源代码所在Github地址本文将使用SpringBoot+Scala+Gradle部署Web应用，如果你对Gradle不熟悉，或者IDE中没有Gradle，你可以使用Maven进行管理，原理上是一样的

1、首先是build.gradle文件

buildscript {  
    ext {  
        springBootVersion = '1.4.3.RELEASE'  
    }  
    repositories {  
        mavenCentral()  
    }  
    dependencies {  
        classpath("org.springframework.boot:spring-boot-gradle-plugin:${springBootVersion}")  
    }  
}  
apply plugin: 'java'  
apply plugin: 'scala'  
apply plugin: 'eclipse'  
apply plugin: 'application'  
apply plugin: 'org.springframework.boot'  
  
ext {  
    sourceCompatibility = 1.8  
    targetCompatibility = 1.8  
}  
jar {  
    baseName = 'spring-boot-scala'  
    version =  '0.1.0'  
}  
  
repositories {  
    mavenCentral()  
    maven { url "https://repo.spring.io/snapshot" }  
    maven { url "https://repo.spring.io/milestone" }  
}  
  
dependencies {  
    compile("org.springframework.boot:spring-boot-starter-web")  
    compile("org.springframework.boot:spring-boot-starter-actuator")  
    compile("org.springframework.boot:spring-boot-starter-data-jpa")  
    compile "org.scala-lang:scala-library:2.11.7"  
    compile "org.scala-lang:scala-compiler:2.11.7"  
    compile "org.scala-lang:scala-reflect:2.11.7"  
    testCompile("org.springframework.boot:spring-boot-starter-test")  
    //mysql driver  
    compile ("mysql:mysql-connector-java:5.1.38")  
    testCompile("junit:junit:4.12")  
}  
  
task wrapper(type: Wrapper) {  
    gradleVersion = '2.9'  
}  
  
bootRepackage.enabled = false

这里面引入了spring-boot-starter-data-jpa，它依赖于hibernate-core和spring-data-jpa，两者的结合可以更好的帮我们处理数据库层的操作。

2、springboot的配置文件src/main/resources/application.properties

#spring.datasource.url: jdbc:hsqldb:mem:scratchdb  
#logging.file: /tmp/logs/app.log  
  
#datasource  
spring.datasource.url = jdbc:mysql://localhost:3306/sss  
spring.datasource.username = root  
spring.datasource.password = root  
spring.datasource.driverClassName = com.mysql.jdbc.Driver  
  
# Specify the DBMS  
spring.jpa.database = MYSQL  
# Show or not log for each sql query  
spring.jpa.show-sql = true  
# Hibernate ddl auto (create, create-drop, update)  
spring.jpa.hibernate.ddl-auto = update  
# stripped before adding them to the entity manager)  
spring.jpa.properties.hibernate.dialect = org.hibernate.dialect.MySQL5Dialect  
  
# Server port  
server.port=8080

3、dao层代码src/main/scala/com/silence/repository/UserRepository.scala

package com.silence.repository  
  
import com.silence.enties.User  
import org.springframework.data.jpa.repository.JpaRepository  
import java.lang.Long  
  
trait UserRepository extends JpaRepository[User, Long]

Scala并没有Java概念中的Interface，不过Scala使用的trait特质来声明，注意，JpaRepository中的Long对象是来自java.lang.Long，而不是Scala特有的Long类型。

4、service层/src/main/scala/com/silence/service/BaseService.scala

package com.silence.service  
  
import org.springframework.data.jpa.repository.JpaRepository  
import org.springframework.beans.factory.annotation.Autowired  
import scala.reflect.ClassTag  
import java.lang.Long  
import org.springframework.data.domain.Page  
import java.util.List  
import org.springframework.context.annotation.ComponentScan  
import org.springframework.stereotype.Service  
import org.springframework.context.annotation.Bean  
import javax.transaction.Transactional  
import java.lang.Boolean  
import org.springframework.data.domain.PageRequest  
  
@Service  
abstract class BaseService[T: ClassTag] {  
      
    /** spring data jpa dao*/  
    @Autowired val jpaRepository: JpaRepository[T, Long] = null  
      
    /** 
     * @description 添加记录 
     * @param S <: T  
     * @return T 
     */  
    def save[S <: T](s: S) : T = jpaRepository.save(s)  
      
    /** 
     * @description 根据Id删除数据 
     * @param id 数据Id 
     * @return Unit 
     */  
    @Transactional  
    def delete(id: Long): Unit = jpaRepository.delete(id)  
      
    /** 
     * @description 实体批量删除 
     * @param List[T] 
     * @return Unit 
     */  
    @Transactional  
    def delete(lists: List[T]) : Unit = jpaRepository.delete(lists);  
      
    /** 
     * @description 根据Id更新数据 
     * @param S <: T  
     * @return T 
     */  
    @Transactional  
    def update[S <: T](s: S) : T = jpaRepository.save(s)  
      
    /** 
     * @description 根据Id查询 
     * @param id 数据Id 
     * @return T 
     */  
    def find[S <: T](id: Long) : T = jpaRepository.findOne(id)  
      
    /** 
     * @description 查询所有数据 
     * @return List[T] 
     */  
    def findAll[S <: T]: List[T] = jpaRepository.findAll  
      
    /** 
     * @description 集合Id查询数据 
     * @return List[T] 
     */  
    def findAll[S <: T](ids: List[Long]): List[T] = jpaRepository.findAll(ids)  
      
    /** 
     * @description 统计大小 
     * @return Long 
     */  
    def count : Long = jpaRepository.count  
      
    /** 
     * @description 判断数据是否存在 
     * @param id 数据Id 
     * @return Boolean 
     */  
    def exist(id: Long) : Boolean = jpaRepository.exists(id)  
      
    /** 
     * @description 查询分页 
     * @param page 起始页 
     * @param pageSize 每页大小 
     * @return Page[T] 
     */  
    def page[S <: T](page: Int, pageSize: Int): Page[T] = {  
      var rpage = if (page < 1) 1 else page;  
      var rpageSize = if (pageSize < 1) 5 else pageSize;  
          jpaRepository.findAll(new PageRequest(rpage - 1, pageSize))  
    }      
  
}

该类声明了针对DAO层的一系列操作，包括分页

5、UserService.scala

package com.silence.service  
  
import com.silence.enties.User  
import org.springframework.beans.factory.annotation.Autowired  
import com.silence.repository.UserRepository  
import org.springframework.stereotype.Service  
  
@Service  
class UserService extends BaseService[User] {  
    
  @Autowired val userRepository: UserRepository = null  
    
}

UserRepository是继承了JpaRepository接口的trait

6、src/main/scala/com/silence/controller/UserController.scala

package com.silence.controller  
  
import org.springframework.stereotype.Controller  
import org.springframework.web.bind.annotation.RequestMapping  
import org.springframework.web.bind.annotation.RequestMethod  
import org.springframework.context.annotation.ComponentScan  
import org.springframework.context.annotation.Configuration  
import org.springframework.web.bind.annotation.ResponseBody  
import org.springframework.beans.factory.annotation.Autowired  
import com.silence.repository.UserRepository  
import org.springframework.web.servlet.ModelAndView  
import com.silence.enties.User  
import java.util.List  
import org.springframework.web.bind.annotation.PathVariable  
import javax.validation.Valid  
import org.springframework.validation.BindingResult  
import org.springframework.web.bind.annotation.RequestParam  
import org.springframework.data.domain.Pageable  
import org.springframework.data.domain.PageRequest  
import org.springframework.data.domain.Page  
import com.silence.service.UserService  
  
@ComponentScan  
@Controller  
@ResponseBody  
class UserController @Autowired()(private val userService : UserService){  
    
    @RequestMapping(value = Array("/list"), method = Array(RequestMethod.GET))  
  def list() : List[User] = {  
      userService.findAll  
  }  
    
  @RequestMapping(value = Array("save"), method = Array(RequestMethod.POST))  
  def save(@Valid user : User) : User = {  
      userService.save(user)  
  }  
    
    @RequestMapping(value = Array("/find/{id}"), method = Array(RequestMethod.GET))  
  def find(@PathVariable(value = "id") id: Long) : User = {  
      userService.find(id)  
  }  
    
  @RequestMapping(value = Array("delete/{id}"), method = Array(RequestMethod.POST))  
  def delete(@PathVariable(value = "id") id: Long) : Unit = {  
      userService.delete(id)  
  }  
    
  @RequestMapping(value = Array("update"), method = Array(RequestMethod.POST))  
  def update(@Valid user : User, bindingResult : BindingResult) : User = {  
      userService.update(user)  
  }  
    
  @RequestMapping(value = Array("page"), method = Array(RequestMethod.GET))  
  def page(@RequestParam("page") page : Int, @RequestParam("pageSize") pageSize : Int) : Page[User] = {  
      userService.page(page, pageSize)  
  }  
    
}

7、SpringBoot启动src/main/scala/com/silence/SpringBootScalaApplication.scala

package com.silence  
  
import org.springframework.context.annotation.Configuration  
import org.springframework.boot.autoconfigure.EnableAutoConfiguration  
import org.springframework.context.annotation.ComponentScan  
import org.springframework.boot.SpringApplication  
import org.springframework.boot.autoconfigure.SpringBootApplication  
  
@Configuration  
@EnableAutoConfiguration  
@ComponentScan  
@SpringBootApplication  
class Config  
  
  
object SpringBootScalaApplication extends App {  
  
  SpringApplication.run(classOf[Config])  
    
}

8、运行，如果是使用IDE，可以直接在SpringBootScalaApplication中Run As -> Scala Application，或者在项目的根目录下使用命令行gradle bootRun

9、测试，可以使用浏览器打开测试，Linux可以使用crul

curl http://localhost:8080/list  
curl http://localhost:8080/find/2  
curl -d "name=silence&telephone=15345678960&birthday=1994-06-24" http://localhost:8080/save  
curl -d null http://localhost:8080/delete/505  
curl http://localhost:8080/page?pageSize=6&page=5

项目地址github.com/silence940109/SpringBoot-Scala

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

SpringBoot-Scala

SpringBoot-Scala

README.md

SpringBoot Scala

Files

SpringBoot-Scala

Directory actions

More options

Directory actions

More options

Latest commit

History

SpringBoot-Scala

Folders and files

parent directory

README.md

SpringBoot Scala