A Tour of Paradigms - Java Closures and Lambda - page 175

lineNumber += 1;
String text = rs.getString(1);
if (!text.equals(lastText)) {
lastText = text;
}
int lineOffset = rs.getInt(2);
String word = rs.getString(3);
int wordOffset = rs.getInt(4);
if (lineOffset != lastLine) {
lastLine = lineOffset;
}
System.out.println(String.format(
"%s\t%d\t%s\t%d", text, lineOffset, word, wordOffset));
}
}
}
}
public static void main(String[] args) throws Exception {
Database database = new Database();
database.initializeDb();
new ShakespeareTextSource().getStream().sequential()
.map(new TextMapper())
.filter(Optional::isPresent).map(Optional::get)
// In a longer example, this next line might be broken out into
// distinct intermediate forms for providing text id, line id,
// and word id.
.map(new DatabaseLineMapper(database))
.forEach(database::insertLine);
printWordUsages(database);
printDatabaseSizing(database);
}
}
### Database.java
import java.sql.*;
import java.util.*;
import java.util.function.*;
/**
* Represents that database holding the text information
*/
public class Database {
private static final String SCHEMA = "shakespeare";