美文网首页
09.scala操作外部数据

09.scala操作外部数据

作者: shone_shawn | 来源:发表于2019-08-24 19:48 被阅读0次

读取文件和网络数据

一行一行读

image.png

一个字母一个字母读

image.png

通过网络读

image.png

读取mysql

image.png image.png image.png

读取xml文件

image.png image.png image.png

读取XML属性内容

import scala.xml.XML

object XMLApp {
  def main(args: Array[String]): Unit = {
    //    loadXML()
    readXMLAttr()
  }


  def readXMLAttr() = {
    val xml = XML.load(this.getClass.getClassLoader.getResource("xxj.xml"))
    //打印一下结构
    println(xml)
    //header/field  header下的field
    val headerField = xml \ "header" \ "field"
    println(headerField)
    //all field所有的field
    val fields = xml \\ "field"
    for (field <- fields) {
      println(field)
    }
    //header/field/name header下field下name的值
    val fieldAttributes = (xml \ "header" \ "field").map(_ \ "@name")
    val fieldAttributes = (xml \ "header" \ "field" \\ "@name")
    for (fieldAttribute <- fieldAttributes) {
      println(fieldAttribute)
    }
    //name=hahahaha的message标签
    val filters = (xml \\ "message")
      .filter(_.attribute("name")
        .exists(_.text.equals("hahahaha")))
    val filters = (xml \\ "message")
      .filter(x => ((x \ "@name").text)
        .equals("hahahaha"))
    for (filter <- filters) {
      println(filter)
    }
    //header/field/name content获取内容
    (xml \ "header" \ "field")
      .map(x => (x \ "@name", x.text, x \ "@required"))
      .foreach(println)
  }

  def loadXML(): Unit = {
    val xml1 = XML.load(this.getClass.getClassLoader.getResource("test.xml"))
    //    println(xml1)
    val xml2 = XML.load(new FileInputStream("C:\\workspaces\\workspack_scala_2\\src\\main\\resources\\test.xml"))
    //    println(xml2)
    val xml3 = XML.load(new FileInputStream("C:\\workspaces\\workspack_scala_2\\src\\main\\resources\\test.xml"))
    //    println(xml3)
  }

}
image.png

相关文章

  • 09.scala操作外部数据

    读取文件和网络数据 一行一行读 一个字母一个字母读 通过网络读 读取mysql 读取xml文件 读取XML属性内容

  • scala操作外部数据

    读取文件 读取mysql中的数据 引入mysql的依赖 示例 读取xml文件 添加xml的依赖 示例

  • spark RDD学习

    数据集合parallelize 外部数据testfile map用于操作元素 filter用于过滤元素 flatM...

  • sparkRdd ,breeze

    常见RDD操作 textFile 在数据分析中最常见的时从外部获取数据集,这就需要textFile操作 textF...

  • 关于使用分布式缓存的思考

    1. 何时用缓存? 加快数据返回 减轻db压力 - 读操作远大于写操作 - 依赖外部接口数据,但是其access能...

  • 2020春招BAT面试真题详解,你还在犹豫看不看,别人已经学走了

    Android 基础与底层机制 数据库的操作类型有哪些,如何导入外部数据库? 数据库的操作类型:增、删、改、查;把...

  • flink状态

    Flink从外部数据源持续接收数据,每接收一条数据就会触发相应的计算操作。当Flink对数据进行聚合操作时,不可能...

  • SparkSQL操作外部数据源

    parquet数据 hive表数据 mysql表数据 hive与mysql结合 1.处理parquet数据 启动s...

  • 安装MySql

    使用yum安装mysql数据库 开启服务 配置数据信息 进入数据库操作 设置开机自动启动 如果要用外部软件连接数据...

  • ajax发送跨域post请求解决办法

    使用场景:在需要在本地服务器访问外部接口并获取外部接口返回的数据并操作本地数据库的情况 什么是跨域? 概念:只要协...

网友评论

      本文标题:09.scala操作外部数据

      本文链接:https://www.haomeiwen.com/subject/futtectx.html