Scala集合

集合

scala中的集合分为两种 ,可变集合和不可变集合, 不可变集合可以安全的并发的访问!
集合的类主要在一下两个包中

• 可变集合包    scala.collection.mutable
  
• 不可变集合包 scala.collection.immutable   默认的
  

Scala 不可变集合，就是指该集合对象不可修改，每次修改就会返回一个新对象，而不会对原对象进行修改。类似于 java 中的 String 对象
可变集合，就是这个集合可以直接对原对象进行修改，而不会返回新的对象。类似于 java 中 StringBuilder 对象
建议：在操作集合的时候，不可变用符号，可变用方法
scala默认使用的是不可变的集合 , 因此使用可变的集合需要导入可变集合的包
scala的集合主要分成三大类

• Seq 序列
  
• Set 不重复集
  
• Map 键值映射集
  

注意: 所有的集合都继承自Iterator迭代器这个特质
不可变集合继承图

迭代器

java中的iterator

在java中用迭代器读取文件中的数据，每次返回一行数据

1. package com.doit;
3. import java.io.BufferedReader;
4. import java.io.FileNotFoundException;
5. import java.io.FileReader;
6. import java.io.IOException;
7. import java.util.Iterator;
9. class MyHero implements Iterator<String> {
10.     BufferedReader buffer = null;
11.     String line = null;
13.     public MyHero() {
14.         try {
15.             buffer = new BufferedReader(new FileReader("data/hero.txt"));
16.         } catch (FileNotFoundException e) {
17.             e.printStackTrace();
18.         }
19.     }
21.     @Override
22.     public boolean hasNext() {
23.         try {
24.             line = buffer.readLine();
25.         } catch (IOException e) {
26.             e.printStackTrace();
27.         }
28.         return line != null;
29.     }
31.     @Override
32.     public String next() {
33.         return line;
34.     }
35. }
37. public class MyIterator{
38.     public static void main(String[] args) {
39.         MyHero myHero = new MyHero();
40.         while (myHero.hasNext()){
41.             System.out.println(myHero.next());
42.         }
43.     }
44. }

复制代码

在java中用迭代器读取mysql表中的数据，每次返回一行数据

1. package com.doit;
3. import java.sql.*;
4. import java.util.Iterator;
6. public class ReadTable implements Iterator<Login> {
7.     ResultSet resultSet = null;
8.     public ReadTable(){
9.         try {
10.             Class.forName("com.mysql.jdbc.Driver");
11.         } catch (ClassNotFoundException e) {
12.             e.printStackTrace();
13.         }
14.         try {
15.             Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/football", "root", "123456");
16.             PreparedStatement pps = conn.prepareStatement("select * from login ");
17.             resultSet = pps.executeQuery();
18.         } catch (SQLException e) {
19.             e.printStackTrace();
20.         }
21.     }
23.     @Override
24.     public boolean hasNext() {
25.         boolean flag = false;
26.         try {
27.             flag = resultSet.next();
28.         } catch (SQLException e) {
29.             e.printStackTrace();
30.         }
31.         return flag;
32.     }
34.     @Override
35.     public Login next() {
36.         Login login = new Login();
37.         try {
38.             login.setId(resultSet.getInt(1));
39.             login.setUser_id(resultSet.getInt(2));
40.             login.setClient_id(resultSet.getInt(3));
41.             login.setDate(resultSet.getString(4));
42.         } catch (SQLException e) {
43.             e.printStackTrace();
44.         }
45.         return login;
46.     }
49. }
52. class Login {
53.     private int id;
54.     private int user_id;
55.     private int client_id;
56.     private String date;
58.     public Login() {
59.     }
61.     public Login(int id, int user_id, int client_id, String date) {
62.         this.id = id;
63.         this.user_id = user_id;
64.         this.client_id = client_id;
65.         this.date = date;
66.     }
68.     public int getId() {
69.         return id;
70.     }
72.     public void setId(int id) {
73.         this.id = id;
74.     }
76.     public int getUser_id() {
77.         return user_id;
78.     }
80.     public void setUser_id(int user_id) {
81.         this.user_id = user_id;
82.     }
84.     public int getClient_id() {
85.         return client_id;
86.     }
88.     public void setClient_id(int client_id) {
89.         this.client_id = client_id;
90.     }
92.     public String getDate() {
93.         return date;
94.     }
96.     public void setDate(String date) {
97.         this.date = date;
98.     }
100.     @Override
101.     public String toString() {
102.         return "login{" +
103.                 "id=" + id +
104.                 ", user_id=" + user_id +
105.                 ", client_id=" + client_id +
106.                 ", date='" + date + '\'' +
107.                 '}';
108.     }
109. }

复制代码

java中的Iterable

代表可迭代的，返回的是一个迭代器

1. package com.doit;
3. import java.util.Iterator;
5. public class ReadTableIterable implements Iterable<Login>{
6.     @Override
7.     public Iterator iterator() {
8.         return new ReadTable();
9.     }
10. }
13. //测试
14. package com.doit;
16. import java.util.Iterator;
18. public class Test3 {
19.     public static void main(String[] args) {
20.         ReadTableIterable logins = new ReadTableIterable();
21.         //可迭代的都会有一个迭代器对象，获取出来后用hasnext next获取数据
22.         Iterator iterator = logins.iterator();
23.         while (iterator.hasNext()){
24.             System.out.println(iterator.next());
25.         }
26.         //可迭代的java底层都封装了增强for循环，也可以直接使用
27.         for (Login login : logins) {
28.             System.out.println(login);
29.         }
30.     }
31. }

复制代码

scala中的 iterator

[code]package com.doit.day01.day02import scala.io.{BufferedSource, Source}object MyIter {  def main(args: Array[String]): Unit = {    val iter: MyIter = new MyIter    while (iter.hasNext){      println(iter.next())    }  }}class MyIter extends Iterator[String]{  //读取数据  private val source: BufferedSource = Source.fromFile("data/hero.txt")  private val lines: Iterator[String] = source.getLines()  //用scala中返回迭代器中的hasNext方法直接判断  override def hasNext: Boolean = lines.hasNext  //用scala中返回迭代器中的next方法获取数据  override def next(): String = lines.next()}7.1.4scala中的IterableScalapackage com.doit.day01.day02import scala.io.{BufferedSource, Source}object MyIter {  def main(args: Array[String]): Unit = {    val iter: MyIter1 = new MyIter1    val iterator: Iterator[String] = iter.iterator    while (iterator.hasNext){      println(iterator.next())    }    for (elem