SpringBoot如何使用Scala进行开发的实现

2023-08-05 03:59:04 332

Scala是一门多范式的编程语言，一种类似Java的编程语言，设计初衷是实现可伸缩的语言并集成面向对象编程。Scala把Erlang风格的基于actor的并发带进了JVM，开发者可以利用Scala的actor模型在JVM上设计具伸缩性的并发应用程序，它会自动获得多核心处理器带来的优势，而不必依照复杂的Java线程模型来编写程序，接下来就介绍一下如何在SpringBoot框架中使用Scala来进行简单的Web开发，对scala不了解的建议先去学习基础哦

一、导入依赖



4.0.0

org.springframework.boot
spring-boot-starter-parent
2.2.1.RELEASE


com.gjing.project
scala-demo
0.0.1-SNAPSHOT
scala-demo
DemoprojectforSpringBoot


1.8




org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-data-jpa


mysql
mysql-connector-java



org.scala-lang
scala-library
2.13.1



cn.gjing
tools-starter-swagger
1.3.0


cn.gjing
tools-common
1.2.7







org.scala-tools
maven-scala-plugin
2.15.2



compile
testCompile





org.springframework.boot
spring-boot-maven-plugin

通过上面我们可以发现，和创建Java版本的SpringBoot项目没啥不同，只是引入了scala-library这个我们之前没引入的包，同时增加了对scala编译的插件

二、配置YML文件

server:
port:8080
spring:
application:
name:scala-demo
datasource:
driver-class-name:com.mysql.cj.jdbc.Driver
url:jdbc:mysql://127.0.0.1:3306/demo?characterEncoding=utf8&useSSL=false
username:root
password:root
type:com.zaxxer.hikari.HikariDataSource
hikari:
maximum-pool-size:5
minimum-idle:1
idle-timeout:30000
connection-timeout:30000
jpa:
database:mysql
hibernate:
ddl-auto:update
#设置创表引擎为Innodb，不然默认为MyiSam
database-platform:org.hibernate.dialect.MySQL5InnoDBDialect

swagger:
base-package:com.gjing.project.scala.controller
title:scala学习的demo

三、创建实体类

importjavax.persistence._

importscala.beans.BeanProperty

/**
*@authorGjing
**/
@Entity
@Table(name="scala_customer")
classCustomer{

@Id
@GeneratedValue(strategy=GenerationType.IDENTITY)
@BeanProperty
varid:Integer=_

@BeanProperty
varcustomerName:String=_

defthis(customerName:String){
this()
this.customerName=customerName
}

overridedeftoString:String=s"Customer($id,$customerName)"
}

这块和我们用java开发没啥不同，只是@BeanProperty注解会帮我们生成get和set

四、Repository层

importcom.gjing.project.scala.entity.Customer
importorg.springframework.data.jpa.repository.JpaRepository
importorg.springframework.stereotype.Repository

/**
*@authorGjing
**/
@Repository
traitCustomerRepositoryextendsJpaRepository[Customer,Integer]{
/**
*通过用户名查询
*@paramname用户名
*@returnCustomer
*/
deffindByCustomerName(name:String):Customer
}

这里和JAVA不同的是泛型采用的是[]中括号，这点要注意

五、Service层

importcn.gjing.tools.common.result.PageResult
importcom.gjing.project.scala.entity.Customer
importcom.gjing.project.scala.exceptions.MyServiceException
importcom.gjing.project.scala.repository.CustomerRepository
importjavax.annotation.Resource
importorg.springframework.data.domain.Pageable
importorg.springframework.stereotype.Service

/**
*@authorGjing
**/
@Service
classCustomerService@Resource()(customerRepository:CustomerRepository){
/**
*保存用户
*
*@paramname用户名
*/
defsaveCustomer(name:String):Unit={
varcustomer=customerRepository.findByCustomerName(name)
if(customer!=null){
throwMyServiceException("添加失败，用户已存在")
}
customer=newCustomer(name)
customerRepository.save(customer)
}

/**
*分页查询
*
*@parampageable分页对象
*@return
*/
defpageCustomer(pageable:Pageable):PageResult[java.util.List[Customer]]={
valpage=customerRepository.findAll(pageable)
returnPageResult.of(page.getContent,page.getTotalPages,page.getSize,page.getTotalElements,page.getNumber)
}

/**
*更新用户名
*@paramid用户id
*@paramname用户名
*/
defupdateCustomer(id:Integer,name:String):Unit={
valcustomer=customerRepository.findById(id).orElseThrow(()=>MyServiceException("更新失败，用户不存在"))
customer.setCustomerName(name)
customerRepository.saveAndFlush(customer)
}

/**
*删除指定用户
*@paramid用户id
*/
defdeleteCustomer(id:Integer):Unit={
valcustomer=customerRepository.findById(id).orElseThrow(()=>MyServiceException("删除失败，用户不存在"))
customerRepository.delete(customer)
}
}

有意思的是，在scala中依赖注入是写在类名上的

六、Controller层

importcn.gjing.tools.common.annotation.NotEmpty
importcn.gjing.tools.common.result.PageResult
importcom.gjing.project.scala.entity.Customer
importcom.gjing.project.scala.service.CustomerService
importio.swagger.annotations.{Api,ApiImplicitParam,ApiImplicitParams,ApiOperation}
importjavax.annotation.Resource
importorg.springframework.data.domain.PageRequest
importorg.springframework.http.ResponseEntity
importorg.springframework.web.bind.annotation._

/**
*@authorGjing
**/
@RestController
@Api(tags=Array("用户的相关功能"))
classCustomerController@Resource()(customerService:CustomerService){
@PostMapping(Array("/customer"))
@ApiOperation("添加用户")
@ApiImplicitParam(name="customerName",value="用户名",dataType="String",required=true,paramType="query")
@NotEmpty
defsaveCustomer(customerName:String):ResponseEntity[String]={
customerService.saveCustomer(customerName)
ResponseEntity.ok("添加成功")
}

@GetMapping(Array("/customer_page"))
@ApiOperation("分页查询")
@ApiImplicitParams(Array(
newApiImplicitParam(name="page",value="页数",required=true,dataType="int",paramType="query"),
newApiImplicitParam(name="size",value="条数",required=true,dataType="int",paramType="query"),
))
defpageCustomer(page:Integer,size:Integer):ResponseEntity[PageResult[java.util.List[Customer]]]={
ResponseEntity.ok(customerService.pageCustomer(PageRequest.of(page,size)))
}


@NotEmpty
@PutMapping(Array("/customer"))
@ApiOperation("更新用户")
@ApiImplicitParams(Array(
newApiImplicitParam(name="id",value="用户ID",required=true,dataType="int",paramType="query"),
newApiImplicitParam(name="name",value="用户名",required=true,dataType="String",paramType="query")
))
defupdateCustomer(id:Integer,name:String):ResponseEntity[String]={
customerService.updateCustomer(id,name)
ResponseEntity.ok("修改成功")
}

@DeleteMapping(Array("/customer/{id}"))
@ApiOperation("删除用户")
defdeleteCustomer(id:Integer):ResponseEntity[String]={
customerService.deleteCustomer(id)
ResponseEntity.ok("删除成功")
}
}

这样我们一个简单的Scala版本的Web项目就写好啦，只需要启动就可以试着运行啦，本文的源代码地址：scala-demo，有任何不清楚的可以在评论区回复哈

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

SpringBoot如何使用Scala进行开发的实现

热门推荐

随机推荐