Scala: Odsłanianie JDBC ResultSet przez generator (iterable)

Question

Mam zestaw wierszy w bazie danych, i chciałbym, aby zapewnić interfejs do spin przez nich tak:

def findAll: Iterable[MyObject] 

Tam, gdzie nie potrzebujemy mieć wszystkich instancji w pamięci naraz. W języku C# można łatwo tworzyć generatory takie jak to przy użyciu yield, kompilator dba o konwersję kodu, który przechodzi przez zestaw rekordów do iteratora (rodzaj odwracania go).

Mój bieżący kod wygląda następująco:

def findAll: List[MyObject] = { 
    val rs = getRs 
    val values = new ListBuffer[MyObject] 
    while (rs.next()) 
    values += new valueFromResultSet(rs) 
    values.toList 
} 

Czy istnieje sposób mogę przekonwertować to do nie zapisać cały zestaw w pamięci? Może mógłbym użyć do zrozumienia?

Answer 1

Spróbuj zamiast tego użyć rozszerzenia Iteratora. Nie testowałem go, ale coś takiego:

def findAll: Iterator[MyObject] = new Iterator[MyObject] { 
    val rs = getRs 
    override def hasNext = rs.hasNext 
    override def next = new valueFromResultSet(rs.next) 
} 

ten powinien przechowywać rs kiedy to się nazywa, a inaczej po prostu być światłem wrapper do rozmów na RS.

Jeśli chcesz zapisać wartości, które przemierzasz, sprawdź Strumień.

Answer 2

natknąłem się na ten sam problem i opiera się na idei powyżej stworzyłem następujące rozwiązanie, po prostu pisząc klasy adaptera:

class RsIterator(rs: ResultSet) extends Iterator[ResultSet] { 
    def hasNext: Boolean = rs.next() 
    def next(): ResultSet = rs 
} 

Dzięki temu można na przykład wykonać mapę operacji na zbiorze wyników - co było moją osobistą intencją:

val x = new RsIterator(resultSet).map(x => { 
    (x.getString("column1"), x.getInt("column2")) 
}) 

Dołączenie .toList w celu zmuszenia ocenę. Jest to przydatne, jeśli połączenie z bazą danych zostanie zamknięte przed użyciem wartości. W przeciwnym razie pojawi się błąd informujący, że nie można uzyskać dostępu do ResultSet po zamknięciu połączenia.

Answer 3

Prostszy (idiomatyczne) sposób, aby osiągnąć ten sam byłby

Iterator.continually((rs.next(), rs)).takeWhile(_._1).map(r => valueFromResultSet(r._2)).toList 

potrzebny jest .toList zmusić ocenę, inaczej zbiór bazowy będzie strumień, a wynikowa może być zamknięty przed ewaluacja miała miejsce .