使用scala写一个jdbc

Myth丶恋晨 2022-12-07 15:25 171阅读 0赞

准备：  
先在数据库中创建好库，表，导入测试的数据  
库名为mydemo，表名为userinfos  
表有三个字段：userid，username，birthday  
scala的操作：  
1.创建实体类用于接收从数据库中获取的数据

case class UserInfos(var userid:Int,var username:String,var birthday:String)

2.创建BaseDao连接数据库执行操作

object BaseDao{
        
    //创建连接对象
      def getConnection() ={
        
        classOf[com.mysql.jdbc.Driver]
        DriverManager.getConnection("jdbc:mysql://192.168.56.111:3306/mydemo","root","root")
      }
      //创建修改数据的类
      def update(sql:String,params:Array[String])={
        
        val statement = getConnection().prepareStatement(sql)
        for (i<- 0 to params.length-1){
        
          statement.setObject(i+1,params(i))
        }
        statement.executeUpdate()
      }
    //创建查询的类
      def query(sql:String,params:Array[String]) ={
        
        val statement = getConnection().prepareStatement(sql)
        for(i<- 0 to params.length-1){
        
          statement.setObject(i+1,params(i))
        }
        statement.executeQuery()
      }
    //创建将结果集转为List的类
      def resultToList(sql: String,params:Array[String]) ={
        
        var resultSet = query(sql,params)
        var list:ListBuffer[UserInfos]=ListBuffer.empty[UserInfos]
        while (resultSet.next()){
        
          list.append(UserInfos(resultSet.getInt("userid"),
            resultSet.getString("username"),
            resultSet.getString("birthday")))
        }
        list
      }
    
      def main(args: Array[String]): Unit = {
        
        val unit = resultToList("select * from userinfos",Array())
        println(unit)
      }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，171人围观）

还没有评论，来说两句吧...

相关阅读

相关帮我用Scala写一个ATM机

好的，以下是一个简单的ATM机Scala代码示例： import scala.io.StdIn object ATM { def mai

你的名字/ 2024年03月25日 15:28/ 0 赞/ 74 阅读

相关 Scala之创建JDBC连接

Scala之创建JDBC连接 def jdbc()={ //获取连接 val prop: Properties

你的名字/ 2022年12月29日 04:49/ 0 赞/ 131 阅读

相关分别使用java和scala写双线程交替修改一个值

第一个线程对该数加1，第二个线程对该数进行减一，假设给定的初始值为10的话，第一个线程的结果为11，第二个线程的结果应为10，然后交替输出主要实现思路：第一条线程执行加法后

素颜马尾好姑娘i/ 2022年12月14日 13:48/ 0 赞/ 92 阅读

相关 Scala写一个日期转换函数

输入一个yyyy-MM-dd hh:mm:ss格式的日期，将其转化为星期数 def changeDay(date:String) ={

妖狐艹你老母/ 2022年12月11日 07:59/ 0 赞/ 115 阅读

相关使用scala写一个jdbc

准备：先在数据库中创建好库，表，导入测试的数据库名为mydemo，表名为userinfos 表有三个字段：userid，username，birthday

Myth丶恋晨/ 2022年12月07日 15:25/ 0 赞/ 172 阅读

相关如何使用scala+spark读写hbase？

最近工作有点忙，所以文章更新频率低了点，希望大家可以谅解，好了，言归正传，下面进入今天的主题：如何使用scala+spark读写Hbase 软件版本如下： scala2

偏执的太偏执、/ 2022年06月14日 06:40/ 0 赞/ 266 阅读

相关 jdbc写一个访问数据库的工具类

操作的工具类 package com.zjw.jdbc2; / jdbc操作的工具类 @author Administrator

约定不等于承诺〃/ 2022年05月11日 11:00/ 0 赞/ 216 阅读

相关使用IntelliJ IDEA来写spark（使用scala语言）

1. 创建项目：（包括配置java的JDK和scala的SDK） file ---> new ---> project ---> scala ---> idea（选择java

骑猪看日落/ 2022年05月08日 11:38/ 0 赞/ 143 阅读

相关如何使用scala+spark读写hbase？

最近工作有点忙，所以文章更新频率低了点，希望大家可以谅解，好了，言归正传，下面进入今天的主题：如何使用scala+spark读写Hbase 软件版本如下：

小鱼儿/ 2022年04月06日 08:39/ 0 赞/ 546 阅读

相关 Scala JDBC 操作 Mysql

文章目录表结构依赖代码 MysqlConnect CRUD

╰半夏微凉°/ 2022年02月27日 19:20/ 0 赞/ 276 阅读