scala 对象和json互转，以及使用java的arrayList

蔚落 2022-10-15 05:00 221阅读 0赞

var 变量  
val 常量  
scala 使用fastjson 对象转json，再转对象(实体类每个字段都需要加注解 @BeanProperty  
import com.alibaba.fastjson.JSON  
import scala.beans.BeanProperty

package com.xxx.producer.modules.scala.entity
    
    import java.sql.Date
    
    import com.alibaba.fastjson.annotation.JSONField
    import com.baomidou.mybatisplus.annotation.{ TableField, TableId, TableName}
    import com.xxx.producer.verify.Verify
    import javax.validation.constraints.NotNull
    import org.apache.commons.lang3.builder.{ ToStringBuilder, ToStringStyle}
    
    import scala.beans.BeanProperty
    
    /** * 【】 * * @author yangjunxiong * Created on 2021/5/23 09:38 */
    @TableName("t_run_jar")
    class RunBatEntityScala extends Verify { 
    
      @TableId
      @BeanProperty
      var id: Long = _;
      /** * jar文件名称 */
      @NotNull(message = "jarName不能为空")
      @BeanProperty
      var jarName: String = _;
      /** * 端口号 */
      @BeanProperty
      var port: String = _;
      /** * 生成脚本的路径 */
      @BeanProperty
      var cmdPath: String = _;
      /** * start脚本 */
      @BeanProperty
      var startCmd: String = _;
      /** * 重启脚本 */
      @BeanProperty
      var reStartCmd: String = _;
      /** * 创建时间 */
      @JSONField(format = "yyyy-MM-dd HH:mm:ss")
      @BeanProperty
      var createTime: Date = _;
      /** * 修改时间 */
      @BeanProperty
      var updateTime: Date = _;
      /** * 注释 */
      @BeanProperty
      var descr: String = _;
      /** * 0 有效 */
      @BeanProperty
      var delFlag: Integer = _;
      /** * 远程监控是否启动成功url */
      @BeanProperty
      var checkBatUrl: String = _;
    
    
      override def toString = ToStringBuilder.reflectionToString(this, ToStringStyle.JSON_STYLE);
    }

val runBatEntityScala = JSON.parseObject(JSON.toJSONString(aa, null.asInstanceOf[Array[SerializeFilter]]), classOf[RunBatEntityScala]);
    
    //对象转json
    val str = JSON.toJSONString(aa, null.asInstanceOf[Array[SerializeFilter]]);
    //json转对象
    val runBatEntityScala = JSON.parseObject(str, classOf[RunBatEntityScala])

scala使用java的ArrayList

import scala.collection.JavaConverters.{ asScalaBufferConverter, bufferAsJavaListConverter
    
    val list = ListBuffer[RunBatEntityScala]().asJava
    val aaaa = list.asScala

scala的接口是trait ，Java的接口是interface  
scala可以直接继承java的接口并使用 例：继承Verify 接口  
scala的泛型使用\[ \],而java的泛型使用< > 例  
scala的Dao

package com.xxx.producer.modules.scala.dao
    
    import com.baomidou.mybatisplus.core.mapper.BaseMapper
    import com.xxx.producer.modules.scala.entity.RunBatEntityScala
    import org.apache.ibatis.annotations.Mapper
    import org.springframework.stereotype.Repository;
    
    /** * 【】 * * @author yangjunxiong * Created on 2021/5/23 16:33 */
    @Repository
    @Mapper
    trait RunBatDaoScala extends BaseMapper[RunBatEntityScala] {

java的Dao

package com.xxx.producer.modules.runbat.dao;
    
    import com.baomidou.mybatisplus.core.mapper.BaseMapper;
    import com.xxx.producer.modules.runbat.entity.RunBatEntity;
    import org.apache.ibatis.annotations.Mapper;
    import org.springframework.stereotype.Repository;
    
    /** * run_bat( bat脚本表 )(RunBat)表数据库访问层 * * @author yangjunxiong 2021-01-23 10:03:47 */
    @Mapper
    @Repository
    public interface RunBatDao extends BaseMapper<RunBatEntity> { 
    }

scala的Controller

package com.xxx.producer.modules.scala.controller
    
    import com.alibaba.fastjson.JSON
    import com.alibaba.fastjson.serializer.SerializeFilter
    import com.xxx.producer.modules.scala.dao.RunBatDaoScala
    import com.xxx.producer.modules.scala.entity.RunBatEntityScala
    import com.xxx.producer.msg.Message
    import org.springframework.beans.factory.annotation.Autowired
    import org.springframework.web.bind.annotation._
    
    import scala.collection.JavaConverters.{ asScalaBufferConverter, bufferAsJavaListConverter}
    import scala.collection.mutable.ListBuffer
    
    /** * 【】 * * @author yangjunxiong * Created on 2021/5/23 11:16 */
    
    @RestController
    @RequestMapping(Array("/runBatScala"))
    class RunBatEntityScalaController @Autowired()(runBatDao: RunBatDaoScala) { 
    
      @ResponseBody
      @GetMapping(Array("/getOne/{id}"))
      def getOne(@PathVariable("id") id: Int) = { 
        val aa = this.runBatDao.selectById(id);
        var l = System.currentTimeMillis();
        val list = ListBuffer[RunBatEntityScala]().asJava
        for (a <- 1 to 10000) { 
          aa.id = a;
          val str = JSON.toJSONString(aa, null.asInstanceOf[Array[SerializeFilter]]);
          val runBatEntityScala = JSON.parseObject(JSON.toJSONString(aa, null.asInstanceOf[Array[SerializeFilter]]), classOf[RunBatEntityScala])
          list.add(runBatEntityScala)
        }
        var l1 = System.currentTimeMillis();
        System.out.println("时间" + (l1 - l) );
        //添加完成后,如果想要转回scala的list,直接asScala就行了
        // for (item <- list.asScala) { 
        // println(item)
        // }
        val aaaa = list.asScala;
        Message.getSuccess("666", list);
      }
    }