Spark连接数据库（查询，将数据插入数据库）

ゝ一纸荒年。 2023-02-13 08:06 55阅读 0赞

**1 需要的maven包：**

<dependency>
          <groupId>mysql</groupId>
          <artifactId>mysql-connector-java</artifactId>
          <version>6.0.6</version>
        </dependency>

**2 代码**

import java.sql.{ Connection, DriverManager}
    
    object scal_Mysql1 { 
    
      var conn: Connection = null
    
      def main(args: Array[String]): Unit = { 
    
        try { 
          Class.forName("com.mysql.jdbc.Driver")
          println("驱动加载成功")
          conn = DriverManager.getConnection("jdbc:mysql://HadoopNode1:3306/test?user=root&password=000000&useSSL=false")
          println("数据库连接成功")
          val statement = conn.createStatement()
          //执行插入操作
    //      println("开始插入数据")
           val rs2 = statement.executeUpdate("INSERT INTO student (id, NAME) VALUES (2, 'zhangsheng');")
          println("插入数据完成")
          //查询数据
          val resultSet = statement.executeQuery("select * from emp ")
          while (resultSet.next()) { 
    
            println(resultSet.getString(1))
    
          }
        } catch { 
          case _: Exception => 0
        } finally { 
          conn.close()
        }
    
      }
    }

发表评论取消回复

表情：

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

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

相关阅读

相关查询数据（数据库）——连接查询

目录 1.连接查询和单表查询的区别和联系 2. 为FROM子句后的表起别名 3. 使用JOIN…ON关键字 -------------------- 单表查询：

本是古典何须时尚/ 2024年03月22日 16:03/ 0 赞/ 213 阅读

相关 pandas连接数据库，从数据库读取数据，将数据保存到数据库

pandas连接数据库 import pymysql from sqlalchemy import create_engine sql

谁借莪１个温暖的怀抱￠/ 2023年07月05日 14:29/ 0 赞/ 99 阅读

相关 Spark连接数据库（查询，将数据插入数据库）

1 需要的maven包： <dependency> <groupId>mysql</groupId> <artifactId>

ゝ一纸荒年。/ 2023年02月13日 08:06/ 0 赞/ 56 阅读

相关数据库连接查询

SQL中将连接分成：内连接、外连接、自然连接、交叉连接（笛卡尔乘积连接，没有用处）其中内连接与外连接是比较常用的连接。 ①内连接：\[inner\] join：从左表中取

本是古典何须时尚/ 2022年09月30日 11:47/ 0 赞/ 313 阅读

相关 ·数据库连接查询

一、交叉连接查询将第一张表的所有记录分别与第二张表的每条记录形成一条新的记录。 select 列名 from 表名1 cross join 表名2 二、内连接查询

深碍√TFBOYSˉ_/ 2022年08月21日 06:40/ 0 赞/ 298 阅读

相关 03-JDBC连接MySQL数据库【插入数据】

JDBC连接mysql–学习目录： > 地址：[http://blog.csdn.net/baidu\_37107022/article/details/72600018][

灰太狼/ 2022年06月15日 02:36/ 0 赞/ 302 阅读

相关 Spark连接MySQL数据库并读取数据

（作者：陈玓玏）打开pyspark，带驱动的那种用命令行启动pyspark时需要加上jdbc的驱动路径： pyspark --driver-class-p

短命女/ 2022年04月14日 05:06/ 0 赞/ 504 阅读

相关 python连接mongodb数据库进行插入和查询数据操作

准备工作开发环境：windows 7 开发工具：pycharm python版本：python3.7 用到的库：pymongo，urllib 思路分析 1

àì夳堔傛蜴生んèń/ 2022年01月22日 01:15/ 0 赞/ 522 阅读

相关 Vue.js连接数据库并插入数据

Vue.js连接数据库并插入数据以下是我的学习总结：要求：在vue页面输入用户名和密码进行登陆，用户名和密码数据保存到数据库需要工具/软件： 1. 安装

Love The Way You Lie/ 2021年09月16日 19:34/ 0 赞/ 470 阅读

相关 Django 将数据批量插入数据库bulk_create()

在Django中需要向数据库中插入多条数据（list）。使用如下方法，每次save()的时候都会访问一次数据库。导致性能问题 for i in resultlist:

分手后的思念是犯贱/ 2021年09月13日 23:24/ 0 赞/ 829 阅读